The Sequence Toolkit
www.sequence-toolkit.com |
#include "stk_data_flow.h"
Go to the source code of this file.
Macros | |
#define | stk_udp_create_subscriber stk_udp_listener_create_data_flow |
Functions | |
stk_data_flow_t * | stk_udp_listener_create_data_flow (stk_env_t *env, char *name, stk_uint64 id, stk_options_t *options) |
int | stk_udp_listener_fd (stk_data_flow_t *svr_df) |
stk_sequence_t * | stk_udp_listener_data_flow_rcv (stk_data_flow_t *df, stk_sequence_t *data_sequence, stk_uint64 flags) |
stk_ret | stk_udp_listener_data_flow_id_ip (stk_data_flow_t *df, struct sockaddr *data_flow_id, socklen_t addrlen) |
stk_ret | stk_udp_listener_data_flow_clientip (stk_data_flow_t *df, struct sockaddr *data_flow_id, socklen_t addrlen) |
The UDP listener module provides UDP listening sockets to applications. This module implements the data flow interface specified by the Sequence Toolkit. Applications should use the create API defined here, but use the standard destroy/send/receive APIs in stk_data_flow_api.h Applications may only receive on data flows.
#define stk_udp_create_subscriber stk_udp_listener_create_data_flow |
Alias for Subscribers
stk_data_flow_t* stk_udp_listener_create_data_flow | ( | stk_env_t * | env, |
char * | name, | ||
stk_uint64 | id, | ||
stk_options_t * | options | ||
) |
Create a UDP listening data flow
stk_ret stk_udp_listener_data_flow_clientip | ( | stk_data_flow_t * | df, |
struct sockaddr * | data_flow_id, | ||
socklen_t | addrlen | ||
) |
Get the client IP for this data flow.
stk_ret stk_udp_listener_data_flow_id_ip | ( | stk_data_flow_t * | df, |
struct sockaddr * | data_flow_id, | ||
socklen_t | addrlen | ||
) |
Get the IP acting as the ID for this data flow.
stk_sequence_t* stk_udp_listener_data_flow_rcv | ( | stk_data_flow_t * | df, |
stk_sequence_t * | data_sequence, | ||
stk_uint64 | flags | ||
) |
Receive data from a UDP data flow
int stk_udp_listener_fd | ( | stk_data_flow_t * | svr_df | ) |
Get the File Descriptor for a data flow. Applications may use this to register with an event processing loop which calls select()/poll() etc.