kinetic-c  v0.12.0
Seagate Kinetic Protocol Client Library for C
Macros | Functions
listener_task.c File Reference
#include "listener_task.h"
#include "listener_task_internal.h"
#include "util.h"
#include "syscall.h"
#include <assert.h>
#include "listener_cmd.h"
#include "listener_io.h"
#include "atomic.h"

Go to the source code of this file.

Macros

#define WHILE   while
 

Functions

static void tick_handler (listener *l)
 
static void clean_up_completed_info (listener *l, rx_info_t *info)
 
static void retry_delivery (listener *l, rx_info_t *info)
 
static void observe_backpressure (listener *l, size_t backpressure)
 
void * ListenerTask_MainLoop (void *arg)
 Listener's main loop – function pointer for pthread start function. More...
 
void ListenerTask_DumpRXInfoTable (listener *l)
 Dump the RX info table. 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...
 
static connection_infoget_connection_info (struct listener *l, int fd)
 
void ListenerTask_ReleaseRXInfo (struct listener *l, rx_info_t *info)
 Release an INFO to the listener's info pool. More...
 
void ListenerTask_ReleaseMsg (struct listener *l, listener_msg *msg)
 Release a message to the listener's message 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...
 
uint16_t ListenerTask_GetBackpressure (struct listener *l)
 Get the current backpressure from the listener. More...
 

Macro Definition Documentation

#define WHILE   while

Definition at line 37 of file listener_task.c.

Function Documentation

static void tick_handler ( listener l)
static
static void clean_up_completed_info ( listener l,
rx_info_t info 
)
static
static void retry_delivery ( listener l,
rx_info_t info 
)
static
static void observe_backpressure ( listener l,
size_t  backpressure 
)
static

Definition at line 525 of file listener_task.c.

References listener::upstream_backpressure.

void* ListenerTask_MainLoop ( void *  arg)
void ListenerTask_DumpRXInfoTable ( listener l)
void ListenerTask_NotifyMessageFailure ( listener l,
rx_info_t info,
bus_send_status_t  status 
)
static connection_info* get_connection_info ( struct listener l,
int  fd 
)
static
void ListenerTask_ReleaseRXInfo ( listener l,
struct rx_info_t info 
)
void ListenerTask_ReleaseMsg ( listener l,
listener_msg msg 
)
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 
)
uint16_t ListenerTask_GetBackpressure ( struct listener l)