stk_data_flow_api.h

Go to the documentation of this file.

#ifndef STK_DATA_FLOW_API_H
#define STK_DATA_FLOW_API_H
#include "stk_env.h"
#include "stk_data_flow.h"

stk_data_flow_t *stk_alloc_data_flow(stk_env_t *env,stk_uint16 flow_type,char *name,stk_data_flow_id id,int extendedsz,stk_data_flow_module_t *fptrs,stk_options_t *options);
void stk_hold_data_flow(stk_data_flow_t *df);
stk_ret stk_free_data_flow(stk_data_flow_t *df);
void *stk_data_flow_module_data(stk_data_flow_t *df);
int stk_data_flow_errno(stk_data_flow_t *df);
void stk_set_data_flow_errno(stk_data_flow_t *df,int newerrno);
stk_env_t *stk_env_from_data_flow(stk_data_flow_t *df);
stk_data_flow_id stk_get_data_flow_id(stk_data_flow_t *df);
stk_uint16 stk_get_data_flow_type(stk_data_flow_t *df);
char *stk_data_flow_name(stk_data_flow_t *df);

stk_ret stk_destroy_data_flow(stk_data_flow_t *df);

stk_ret stk_data_flow_send(stk_data_flow_t *df,stk_sequence_t *data_sequence,stk_uint64 flags);

stk_sequence_t *stk_data_flow_rcv(stk_data_flow_t *df,stk_sequence_t *data_sequence,stk_uint64 flags);

stk_ret stk_data_flow_id_ip(stk_data_flow_t *flow,struct sockaddr *data_flow_id,socklen_t addrlen);

stk_ret stk_data_flow_id_ip_nw(stk_data_flow_t *df,struct sockaddr_in *data_flow_id,socklen_t addrlen);

char *stk_data_flow_protocol(stk_data_flow_t *flow);

stk_ret stk_data_flow_buffered(stk_data_flow_t *df);

stk_ret stk_data_flow_client_ip(stk_sequence_t *seq,struct sockaddr_in *client_ip,socklen_t *addrlen);

stk_ret stk_data_flow_add_client_ip(stk_sequence_t *seq,struct sockaddr_in *client_ip,socklen_t addrlen);

stk_ret stk_data_flow_client_protocol(stk_sequence_t *seq,char *protocol_ptr, stk_uint64 *len);

stk_ret stk_data_flow_add_client_protocol(stk_sequence_t *seq,char *protocol);

stk_data_flow_t *stk_data_flow_process_extended_options(stk_env_t *env, stk_options_t *options, char *option_name, stk_create_data_flow_t create_data_flow);

void stk_data_flow_parse_protocol_str(stk_protocol_def_t *def,char *str);
#endif