![]() |
kinetic-c
v0.12.0
Seagate Kinetic Protocol Client Library for C
|
#include "kinetic_bus.h"
#include "kinetic_nbo.h"
#include "kinetic_session.h"
#include "kinetic_socket.h"
#include "kinetic_hmac.h"
#include "kinetic_logger.h"
#include "kinetic.pb-c.h"
#include "kinetic_allocator.h"
#include "kinetic_controller.h"
#include "bus.h"
#include "kinetic_pdu_unpack.h"
#include <time.h>
Go to the source code of this file.
Functions | |
static void | log_cb (log_event_t event, int log_level, const char *msg, void *udata) |
static bus_sink_cb_res_t | reset_transfer (socket_info *si) |
static bool | unpack_header (uint8_t const *const read_buf, size_t const read_size, KineticPDUHeader *const header) |
static bus_sink_cb_res_t | sink_cb (uint8_t *read_buf, size_t read_size, void *socket_udata) |
static void | log_response_seq_id (int fd, int64_t seq_id) |
static bus_unpack_cb_res_t | unpack_cb (void *msg, void *socket_udata) |
bool | KineticBus_Init (KineticClient *client, KineticClientConfig *config) |
void | KineticBus_Shutdown (KineticClient *const client) |
|
static |
Definition at line 36 of file kinetic_bus.c.
References Bus_LogEventStr(), and KineticLogger_LogPrintf().
|
static |
Definition at line 42 of file kinetic_bus.c.
References KineticPDUHeader, bus_sink_cb_res_t::next_read, STATE_AWAITING_HEADER, and UNPACK_ERROR_UNDEFINED.
|
static |
Definition at line 54 of file kinetic_bus.c.
References KineticNBO_ToHostU32(), KineticPDUHeader, and PDU_PROTO_MAX_LEN.
|
static |
Definition at line 80 of file kinetic_bus.c.
References KINETIC_ASSERT, KineticPDUHeader, bus_sink_cb_res_t::next_read, PDU_HEADER_LEN, reset_transfer(), STATE_AWAITING_BODY, STATE_AWAITING_HEADER, STATE_UNINIT, UNPACK_ERROR_INVALID_HEADER, UNPACK_ERROR_SUCCESS, and unpack_header().
|
static |
Definition at line 161 of file kinetic_bus.c.
References LOGF2.
|
static |
Definition at line 173 of file kinetic_bus.c.
References BUS_NO_SEQ_ID, COM__SEAGATE__KINETIC__PROTO__MESSAGE__AUTH_TYPE__UNSOLICITEDSTATUS, KineticResponse::command, KineticResponse::header, KINETIC_ASSERT, KineticAllocator_NewKineticResponse(), KineticPDU_unpack_command(), KineticPDU_unpack_message(), KineticSession_GetConnectionID(), log_response_seq_id(), KineticResponse::proto, UNPACK_ERROR_PAYLOAD_MALLOC_FAIL, UNPACK_ERROR_SUCCESS, and KineticResponse::value.
bool KineticBus_Init | ( | KineticClient * | client, |
KineticClientConfig * | config | ||
) |
Definition at line 242 of file kinetic_bus.c.
References KineticController_HandleUnexpectedResponse(), log_cb(), bus_config::log_cb, KineticClientConfig::logLevel, KineticClientConfig::maxThreadpoolThreads, KineticClientConfig::readerThreads, sink_cb(), unexpected_msg_cb(), and unpack_cb().
void KineticBus_Shutdown | ( | KineticClient *const | client | ) |
Definition at line 268 of file kinetic_bus.c.
References Bus_Free(), and Bus_Shutdown().