![]() |
kinetic-c
v0.12.0
Seagate Kinetic Protocol Client Library for C
|
#include "kinetic_session.h"
#include "kinetic_types_internal.h"
#include "kinetic_controller.h"
#include "kinetic_socket.h"
#include "kinetic_response.h"
#include "kinetic_operation.h"
#include "kinetic_allocator.h"
#include "kinetic_resourcewaiter.h"
#include "kinetic_logger.h"
#include <stdlib.h>
#include <string.h>
#include <pthread.h>
#include <errno.h>
#include <sys/time.h>
Go to the source code of this file.
Macros | |
#define | ATOMIC_FETCH_AND_INCREMENT(P) __sync_fetch_and_add(P, 1) |
Functions | |
KineticStatus | KineticSession_Create (KineticSession *const session, KineticClient *const client) |
KineticStatus | KineticSession_Destroy (KineticSession *const session) |
KineticStatus | KineticSession_Connect (KineticSession *const session) |
KineticStatus | KineticSession_Disconnect (KineticSession *const session) |
KineticStatus | KineticSession_GetTerminationStatus (KineticSession const *const session) |
void | KineticSession_SetTerminationStatus (KineticSession *const session, KineticStatus status) |
int64_t | KineticSession_GetNextSequenceCount (KineticSession *const session) |
int64_t | KineticSession_GetClusterVersion (KineticSession const *const session) |
void | KineticSession_SetClusterVersion (KineticSession *const session, int64_t cluster_version) |
int64_t | KineticSession_GetConnectionID (KineticSession const *const session) |
void | KineticSession_SetConnectionID (KineticSession *const session, int64_t id) |
#define ATOMIC_FETCH_AND_INCREMENT | ( | P | ) | __sync_fetch_and_add(P, 1) |
Definition at line 165 of file kinetic_session.c.
KineticStatus KineticSession_Create | ( | KineticSession *const | session, |
KineticClient *const | client | ||
) |
Definition at line 37 of file kinetic_session.c.
References KINETIC_MAX_OUTSTANDING_OPERATIONS_PER_SESSION, KINETIC_SOCKET_INVALID, KINETIC_STATUS_MEMORY_ERROR, KINETIC_STATUS_SESSION_EMPTY, KINETIC_STATUS_SUCCESS, KineticCountingSemaphore_Create(), and LOG0.
KineticStatus KineticSession_Destroy | ( | KineticSession *const | session | ) |
Definition at line 68 of file kinetic_session.c.
References KINETIC_STATUS_SESSION_EMPTY, KINETIC_STATUS_SUCCESS, KineticAllocator_FreeSession(), and KineticCountingSemaphore_Destroy().
KineticStatus KineticSession_Connect | ( | KineticSession *const | session | ) |
Definition at line 79 of file kinetic_session.c.
References Bus_RegisterSocket(), BUS_SOCKET_PLAIN, BUS_SOCKET_SSL, KINETIC_ASSERT, KINETIC_CONNECTION_TIMEOUT_SECS, KINETIC_SOCKET_DESCRIPTOR_INVALID, KINETIC_STATUS_CONNECTION_ERROR, KINETIC_STATUS_MEMORY_ERROR, KINETIC_STATUS_SESSION_EMPTY, KINETIC_STATUS_SUCCESS, KineticResourceWaiter_WaitTilAvailable(), KineticSession_GetConnectionID(), KineticSocket_Close(), KineticSocket_Connect(), LOG0, LOGF1, and PDU_PROTO_MAX_LEN.
KineticStatus KineticSession_Disconnect | ( | KineticSession *const | session | ) |
Definition at line 131 of file kinetic_session.c.
References Bus_ReleaseSocket(), KINETIC_SOCKET_INVALID, KINETIC_STATUS_CONNECTION_ERROR, KINETIC_STATUS_SESSION_EMPTY, and KINETIC_STATUS_SUCCESS.
KineticStatus KineticSession_GetTerminationStatus | ( | KineticSession const *const | session | ) |
Definition at line 151 of file kinetic_session.c.
References KINETIC_STATUS_SESSION_INVALID.
void KineticSession_SetTerminationStatus | ( | KineticSession *const | session, |
KineticStatus | status | ||
) |
Definition at line 159 of file kinetic_session.c.
References KINETIC_ASSERT.
int64_t KineticSession_GetNextSequenceCount | ( | KineticSession *const | session | ) |
Definition at line 167 of file kinetic_session.c.
References ATOMIC_FETCH_AND_INCREMENT, and KINETIC_ASSERT.
int64_t KineticSession_GetClusterVersion | ( | KineticSession const *const | session | ) |
Definition at line 174 of file kinetic_session.c.
References KINETIC_ASSERT.
void KineticSession_SetClusterVersion | ( | KineticSession *const | session, |
int64_t | cluster_version | ||
) |
Definition at line 180 of file kinetic_session.c.
References KINETIC_ASSERT.
int64_t KineticSession_GetConnectionID | ( | KineticSession const *const | session | ) |
Definition at line 186 of file kinetic_session.c.
References KINETIC_ASSERT.
void KineticSession_SetConnectionID | ( | KineticSession *const | session, |
int64_t | id | ||
) |
Definition at line 192 of file kinetic_session.c.
References KINETIC_ASSERT.