kinetic-c  v0.12.0
Seagate Kinetic Protocol Client Library for C
Functions
listener_task.h File Reference
#include "bus_types.h"
#include "bus_internal_types.h"
#include "listener_internal_types.h"

Go to the source code of this file.

Functions

void * ListenerTask_MainLoop (void *arg)
 Listener's main loop – function pointer for pthread start function. More...
 
void ListenerTask_ReleaseMsg (listener *l, listener_msg *msg)
 Release a message to the listener's message pool. More...
 
void ListenerTask_ReleaseRXInfo (listener *l, struct rx_info_t *info)
 Release an INFO to the listener's info pool. More...
 
bool ListenerTask_GrowReadBuf (listener *l, size_t nsize)
 Grow the listener's read buffer to NSIZE. More...
 
void ListenerTask_AttemptDelivery (listener *l, struct rx_info_t *info)
 Attempt delivery of the message boxed in INFO. More...
 
void ListenerTask_NotifyMessageFailure (listener *l, rx_info_t *info, bus_send_status_t status)
 Notify the client that the event in INFO has failed with STATUS. More...
 
uint16_t ListenerTask_GetBackpressure (struct listener *l)
 Get the current backpressure from the listener. More...
 
void ListenerTask_DumpRXInfoTable (listener *l)
 Dump the RX info table. More...
 

Function Documentation

void* ListenerTask_MainLoop ( void *  arg)
void ListenerTask_ReleaseMsg ( listener l,
listener_msg msg 
)
void ListenerTask_ReleaseRXInfo ( listener l,
struct rx_info_t info 
)
bool ListenerTask_GrowReadBuf ( listener l,
size_t  nsize 
)

Grow the listener's read buffer to NSIZE.

Definition at line 448 of file listener_task.c.

References listener::bus, BUS_LOG_SNPRINTF, LOG_MEMORY, listener::read_buf, listener::read_buf_size, and bus::udata.

void ListenerTask_AttemptDelivery ( listener l,
struct rx_info_t info 
)
void ListenerTask_NotifyMessageFailure ( listener l,
rx_info_t info,
bus_send_status_t  status 
)
uint16_t ListenerTask_GetBackpressure ( struct listener l)
void ListenerTask_DumpRXInfoTable ( listener l)