1

/*

     2

    Copyright Edouard TISSERANT 2024

     3

    See COPYING for details

     4

*/

     5

     6

#if !defined(_PLCObject_hpp_)

     7

#define _PLCObject_hpp_

     8

     9

#include <map>

    10

#include <vector>

    11

#include <mutex>

    12

#include <thread>

    13

    14

#include "blob.hpp"

    15

    16

#include "erpc_PLCObject_interface.hpp"

    17

    18

using namespace erpcShim;

    19

    20

#define FOR_EACH_PLC_SYMBOLS_DO(ACTION) \

    21

    ACTION(PLC_ID)\

    22

    ACTION(startPLC)\

    23

    ACTION(stopPLC)\

    24

    ACTION(ResetDebugVariables)\

    25

    ACTION(RegisterDebugVariable)\

    26

    ACTION(FreeDebugData)\

    27

    ACTION(GetDebugData)\

    28

    ACTION(suspendDebug)\

    29

    ACTION(ResumeDebug)\

    30

    ACTION(ResetLogCount)\

    31

    ACTION(GetLogCount)\

    32

    ACTION(LogMessage)\

    33

    ACTION(GetLogMessage)

    34

    35

typedef struct s_PLCSyms{

    36

    uint8_t *PLC_ID;

    37

    int (*startPLC)(int argc,char **argv);

    38

    int (*stopPLC)(void);

    39

    void (*ResetDebugVariables)(void);

    40

    int (*RegisterDebugVariable)(unsigned int idx, void* force, size_t force_size);

    41

    void (*FreeDebugData)(void);

    42

    int (*GetDebugData)(unsigned int *tick, unsigned int *size, void **buffer);

    43

    int (*suspendDebug)(int disable);

    44

    void (*ResumeDebug)(void);

    45

    void (*ResetLogCount)(void);

    46

    uint32_t (*GetLogCount)(uint8_t level);

    47

    int (*LogMessage)(uint8_t level, char* buf, uint32_t size);

    48

    uint32_t (*GetLogMessage)(uint8_t level, uint32_t msgidx, char* buf, uint32_t max_size, uint32_t* tick, uint32_t* tv_sec, uint32_t* tv_nsec);

    49

} PLCSyms;

    50

    51

class PLCObject : public BeremizPLCObjectService_interface

    52

{

    53

    public:

    54

    55

        PLCObject(void);

    56

        ~PLCObject(void);

    57

    58

        // ERPC interface

    59

        uint32_t AppendChunkToBlob(const binary_t * data, const binary_t * blobID, binary_t * newBlobID);

    60

        uint32_t GetLogMessage(uint8_t level, uint32_t msgID, log_message * message);

    61

        uint32_t GetPLCID(PSKID * plcID);

    62

        uint32_t GetPLCstatus(PLCstatus * status);

    63

        uint32_t GetTraceVariables(uint32_t debugToken, TraceVariables * traces);

    64

        uint32_t MatchMD5(const char * MD5, bool * match);

    65

        uint32_t NewPLC(const char * md5sum, const binary_t * plcObjectBlobID, const list_extra_file_1_t * extrafiles, bool * success);

    66

        uint32_t PurgeBlobs(void);

    67

        uint32_t RepairPLC(void);

    68

        uint32_t ResetLogCount(void);

    69

        uint32_t SeedBlob(const binary_t * seed, binary_t * blobID);

    70

        uint32_t SetTraceVariablesList(const list_trace_order_1_t * orders, int32_t * debugtoken);

    71

        uint32_t StartPLC(void);

    72

        uint32_t StopPLC(bool * success);

    73

    74

    private:

    75

        // A map of all the blobs

    76

        std::map<std::vector<uint8_t>, Blob*> m_mapBlobIDToBlob;

    77

    78

        // PLC object library handle

    79

        void * m_handle;

    80

    81

        // Shared object mutex

    82

        std::mutex m_PLClibMutex;

    83

    84

        // Symbols resolved from the PLC object

    85

        PLCSyms m_PLCSyms;

    86

    87

        // argc and argv for the PLC object

    88

        int m_argc;

    89

        char ** m_argv;

    90

    91

        // PLC status

    92

        PLCstatus m_status;

    93

    94

        // PLC ID

    95

        PSKID m_plcID;

    96

    97

        // Debug token, used for consistency check of traces

    98

        uint32_t m_debugToken;

    99

   100

        // Trace thread

   101

        std::thread m_traceThread;

   102

   103

        // Trace thread mutex

   104

        std::mutex m_tracesMutex;

   105

   106

        // Trace double buffer

   107

        std::vector<trace_sample> m_traces;

   108

   109

        uint32_t BlobAsFile(const binary_t * BlobID, std::filesystem::path filename);

   110

        uint32_t LoadPLC(void);

   111

        uint32_t UnLoadPLC(void);

   112

        uint32_t LogMessage(uint8_t level, std::string message);

   113

        uint32_t PurgePLC(void);

   114

        void TraceThreadProc(void);

   115

};

   116

   117

#endif