mdata_channel.h

Go to the documentation of this file.

#pragma once
#include "mdata_engine.h"
#include <common/xroad_xml.h>
 
#ifdef __cplusplus
extern "C"
{
#endif
 
typedef struct
{
   void* ctx;
   void (*on_subscribe_result)(mdata_subscribe_result_t*, void*);
 
   void (*on_feed_state)(mdata_feed_state_type_t, void*, xroad_mdsource_t*);
 
   void (*on_instr_feed_state)(mdata_feed_state_type_t, void*, xroad_instr_t*);
 
   xroad_errno_t (*on_prepare_mdata)(mdata_proto_type_t, void*, void*);
 
   xroad_errno_t (*on_mdata)(mdata_proto_type_t, void*, void*, xroad_mdsource_t*);
   void (*on_subscribe)(mdata_subscribe_t*, void*, void*);
 
   void (*on_connected)(void*);
 
   void (*on_disconnected)(void*);
} mdata_channel_callback_t;
 
typedef struct mdata_channel_s mdata_channel_t;
mdata_channel_t* mdata_channel_server_create(mdata_channel_callback_t cb, int snd_buf_size, int snd_buf_size_max,
      int recv_buf_size, int recv_buf_size_max, int heartbeat_int, xroad_str_t uri, int cpu, int weight, 
      bool use_thread, bool write_crc, bool low_latency);
 
mdata_channel_t* mdata_channel_client_create(mdata_channel_callback_t cb, int snd_buf_size, int snd_buf_size_max,
      int recv_buf_size, int recv_buf_size_max, int heartbeat_int, xroad_str_t uri, int wait_timeout_us, bool check_crc,
      bool use_fake_fd);
 
xroad_errno_t mdata_channel_start(mdata_channel_t* mdata);
 
void mdata_channel_stop(mdata_channel_t* mdata);
 
void mdata_channel_destroy(mdata_channel_t* mdata);
 
uint64_t mdata_channel_put(mdata_channel_t* mdata, mdata_proto_type_t type, void* val);
 
xroad_errno_t mdata_channel_flush(mdata_channel_t* mdata);
 
xroad_errno_t mdata_channel_send(mdata_channel_t* mdata, mdata_proto_type_t type, void* val);
 
xroad_errno_t mdata_channel_subscribe(mdata_channel_t* mdata, xroad_instr_t* instr, mdata_subscription_mask_t mask, mdata_callback_t cb);
 
/* *
 * deactivates channel in case of issues wih mdata feed
 * @param[in] c - pointer to the mdata_channel_t instance
 * */
void mdata_channel_deactivate(mdata_channel_t* c);
 
/* *
 * activates channel
 * @param[in] c - pointer to the mdata_channel_t instance
 * */
void mdata_channel_activate(mdata_channel_t* c);
 
xroad_mdsource_t* mdata_channel_get_source(mdata_channel_t* c);
 
void mdata_channel_set_source(mdata_channel_t* c, xroad_mdsource_t* source);
 
mdata_feed_state_type_t mdata_channel_get_state(mdata_channel_t* c);
 
int32_t  mdata_channel_decr_ref(mdata_channel_t* c);
 
int32_t  mdata_channel_inc_ref(mdata_channel_t* c);
 
 
#ifdef __cplusplus
}
#endif