stk_rawudp_api.h

Go to the documentation of this file.

#ifndef STK_RAWUDP_API_H
#define STK_RAWUDP_API_H
#include "stk_udp.h"
#include "stk_data_flow.h"
#include <sys/socket.h>

stk_data_flow_t *stk_rawudp_listener_create_data_flow(stk_env_t *env,char *name,stk_uint64 id,stk_options_t *options);
#define stk_rawudp_create_subscriber stk_rawudp_listener_create_data_flow 
int stk_rawudp_listener_fd(stk_data_flow_t *svr_df);

stk_sequence_t *stk_rawudp_listener_data_flow_rcv(stk_data_flow_t *df,stk_sequence_t *data_sequence,stk_uint64 flags);
stk_uint64 stk_rawudp_listener_recv(stk_data_flow_t *df,stk_udp_wire_read_buf_t *bufread);
stk_ret stk_rawudp_listener_add_client_ip(stk_data_flow_t *df,stk_sequence_t *seq,stk_udp_wire_read_buf_t *bufread);

stk_ret stk_rawudp_listener_data_flow_id_ip(stk_data_flow_t *df,struct sockaddr *data_flow_id,socklen_t addrlen);
stk_ret stk_rawudp_listener_data_flow_clientip(stk_data_flow_t *df,struct sockaddr *data_flow_id,socklen_t addrlen);
stk_ret stk_rawudp_listener_data_flow_sendbuf(stk_data_flow_t *df,char *buf,stk_uint64 buflen,stk_uint64 flags);
stk_ret stk_rawudp_listener_data_flow_send_dest(stk_data_flow_t *df,char *buf,stk_uint64 buflen,stk_uint64 flags,struct sockaddr_in *dest_addr,size_t sz);
stk_data_flow_t *stk_rawudp_client_create_data_flow(stk_env_t *env,char *name,stk_uint64 id,stk_options_t *options);
#define stk_rawudp_create_publisher stk_rawudp_client_create_data_flow 
int stk_rawudp_client_fd(stk_data_flow_t *df);

stk_ret stk_rawudp_client_data_flow_id_ip(stk_data_flow_t *df,struct sockaddr *data_flow_id,socklen_t addrlen);
stk_ret stk_rawudp_client_data_flow_serverip(stk_data_flow_t *df,struct sockaddr *data_flow_id,socklen_t addrlen);

#endif