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

Go to the source code of this file.

Macros

#define DUMP_READ   0
 

Functions

static ssize_t socket_read_plain (struct bus *b, listener *l, int pfd_i, connection_info *ci)
 
static ssize_t socket_read_ssl (struct bus *b, listener *l, int pfd_i, connection_info *ci)
 
static bool sink_socket_read (struct bus *b, listener *l, connection_info *ci, ssize_t size)
 
static void print_SSL_error (struct bus *b, connection_info *ci, int lvl, const char *prefix)
 
static void set_error_for_socket (listener *l, int id, int fd, rx_error_t err)
 
static void process_unpacked_message (listener *l, connection_info *ci, bus_unpack_cb_res_t result)
 
static void move_errored_active_sockets_to_end (listener *l)
 
void ListenerIO_AttemptRecv (listener *l, int available)
 

Macro Definition Documentation

#define DUMP_READ   0

Definition at line 223 of file listener_io.c.

Function Documentation

static ssize_t socket_read_plain ( struct bus b,
listener l,
int  pfd_i,
connection_info ci 
)
static
static ssize_t socket_read_ssl ( struct bus b,
listener l,
int  pfd_i,
connection_info ci 
)
static
static bool sink_socket_read ( struct bus b,
listener l,
connection_info ci,
ssize_t  size 
)
static
static void print_SSL_error ( struct bus b,
connection_info ci,
int  lvl,
const char *  prefix 
)
static

Definition at line 151 of file listener_io.c.

References BUS_LOG_SNPRINTF, connection_info::fd, LOG_LISTENER, and bus::udata.

static void set_error_for_socket ( listener l,
int  id,
int  fd,
rx_error_t  err 
)
static
static void process_unpacked_message ( listener l,
connection_info ci,
bus_unpack_cb_res_t  result 
)
static
static void move_errored_active_sockets_to_end ( listener l)
static
void ListenerIO_AttemptRecv ( listener l,
int  available 
)