![]() |
kinetic-c
v0.12.0
Seagate Kinetic Protocol Client Library for C
|
#include "kinetic_client.h"
#include "kinetic_types.h"
#include "byte_array.h"
#include <stdlib.h>
#include <getopt.h>
#include <stdio.h>
#include <sys/param.h>
#include <sys/stat.h>
#include <sys/file.h>
#include <pthread.h>
#include <errno.h>
Go to the source code of this file.
Macros | |
#define | NUM_FILES (3) |
#define | REPORT_ERRNO(en, msg) if(en != 0){errno = en; perror(msg);} |
Functions | |
void * | store_data (void *args) |
int | main (int argc, char **argv) |
#define NUM_FILES (3) |
Definition at line 33 of file write_file_blocking_threads.c.
#define REPORT_ERRNO | ( | en, | |
msg | |||
) | if(en != 0){errno = en; perror(msg);} |
Definition at line 35 of file write_file_blocking_threads.c.
void* store_data | ( | void * | args | ) |
Definition at line 51 of file write_file_blocking_threads.c.
References ByteBuffer_AppendArray(), ByteBuffer_AppendCString(), ByteBuffer_BytesRemaining(), ByteBuffer_Consume(), ByteBuffer::bytesUsed, KineticEntry::key, Kinetic_GetStatusDescription(), KINETIC_OBJ_SIZE, KINETIC_STATUS_SUCCESS, KINETIC_SYNCHRONIZATION_WRITEBACK, KineticClient_Put(), KineticEntry::synchronization, and KineticEntry::value.
int main | ( | int | argc, |
char ** | argv | ||
) |
Definition at line 80 of file write_file_blocking_threads.c.
References ByteArray_CreateWithCString(), ByteBuffer_Create(), ByteBuffer_CreateAndAppendCString(), KineticSessionConfig::host, KINETIC_ALGORITHM_SHA1, Kinetic_GetStatusDescription(), KINETIC_PORT, KINETIC_STATUS_SUCCESS, KineticClient_CreateSession(), KineticClient_DestroySession(), KineticClient_Init(), KineticClient_Shutdown(), KineticClientConfig::logFile, NUM_FILES, REPORT_ERRNO, and store_data().