/users/dtb26/GITROOT/vs-vetserial-poc/include/messaging.h

Go to the documentation of this file.

#ifndef MESSAGING_H_
#define MESSAGING_H_

#ifdef __cplusplus
extern "C" {
#endif

#include <stdlib.h>

#ifdef __cplusplus
        //#include "boost/cstdint.hpp"
        #include <stdint.h>
#else
        #include <stdint.h>
#endif

struct array;
struct datum;

typedef enum {
        NULL_CONTENT = 0, 
        BYTE_CONTENT = 1, 
        INT8_CONTENT = 2, 
        UINT8_CONTENT = 3, 
        INT16_CONTENT = 4, 
        UINT16_CONTENT = 5, 
        INT32_CONTENT = 6, 
        UINT32_CONTENT = 7,
        INT64_CONTENT = 8,
        UINT64_CONTENT = 9,
        FLOAT_CONTENT = 10, 
        DOUBLE_CONTENT = 11
} Message_content_type;

typedef struct connection Connection;

typedef struct channel Channel;

typedef struct data {

        int length;

        Message_content_type type;

        void const *content;
} Data;

typedef struct message {
        int length;

        Data *fields;
} Message;

typedef struct messaging_controller {

        void (*poll)(Connection *connection[], int count, int timeout);

        void (*send_immediate)(Channel *channel, Message *message);

        int (*process_messages)(Connection *connection, short limit);
} Messaging_Controller;

typedef void (*callback)(Channel *channel, Message *mesg, void *state);

typedef struct messaging {

        Connection *(*open_connection)(void);

        Channel *(*open_channel)(Connection *connection, const char * channel_name);

        void (*close_connection)(Connection *connection);

        void (*close_channel)(Channel *channel);

        void (*send)(Channel *channel, Message *message);

        void (*unsubscribe)(Channel *channel);

        void (*subscribe)(Channel *channel, callback fp, void *state);

        Messaging_Controller *(*get_controller)();

} Messaging;

#ifdef __cplusplus
}
#endif

#endif /* MESSAGING_H_ */

---