Data Structures | |
struct | gearman_queue_sqlite_st |
Defines | |
#define | GEARMAN_QUEUE_SQLITE_DEFAULT_TABLE "gearman_queue" |
#define | GEARMAN_QUEUE_QUERY_BUFFER 256 |
#define | SQLITE_MAX_TABLE_SIZE 256 |
#define | SQLITE_MAX_CREATE_TABLE_SIZE 1024 |
Functions | |
static int | _sqlite_query (gearman_server_st *server, gearman_queue_sqlite_st *queue, const char *query, size_t query_size, sqlite3_stmt **sth) |
static int | _sqlite_lock (gearman_server_st *server, gearman_queue_sqlite_st *queue) |
static int | _sqlite_commit (gearman_server_st *server, gearman_queue_sqlite_st *queue) |
static int | _sqlite_rollback (gearman_server_st *server, gearman_queue_sqlite_st *queue) |
static gearman_return_t | _sqlite_add (gearman_server_st *server, void *context, const void *unique, size_t unique_size, const void *function_name, size_t function_name_size, const void *data, size_t data_size, gearman_job_priority_t priority) |
static gearman_return_t | _sqlite_flush (gearman_server_st *server, void *context) |
static gearman_return_t | _sqlite_done (gearman_server_st *server, void *context, const void *unique, size_t unique_size, const void *function_name, size_t function_name_size) |
static gearman_return_t | _sqlite_replay (gearman_server_st *server, void *context, gearman_queue_add_fn *add_fn, void *add_context) |
#define GEARMAN_QUEUE_SQLITE_DEFAULT_TABLE "gearman_queue" |
Default values.
Definition at line 28 of file queue_libsqlite3.c.
#define GEARMAN_QUEUE_QUERY_BUFFER 256 |
Definition at line 29 of file queue_libsqlite3.c.
#define SQLITE_MAX_TABLE_SIZE 256 |
Definition at line 34 of file queue_libsqlite3.c.
#define SQLITE_MAX_CREATE_TABLE_SIZE 1024 |
Definition at line 35 of file queue_libsqlite3.c.
int _sqlite_query | ( | gearman_server_st * | server, | |
gearman_queue_sqlite_st * | queue, | |||
const char * | query, | |||
size_t | query_size, | |||
sqlite3_stmt ** | sth | |||
) | [static] |
Query error handling function.
Definition at line 287 of file queue_libsqlite3.c.
int _sqlite_lock | ( | gearman_server_st * | server, | |
gearman_queue_sqlite_st * | queue | |||
) | [static] |
Definition at line 315 of file queue_libsqlite3.c.
int _sqlite_commit | ( | gearman_server_st * | server, | |
gearman_queue_sqlite_st * | queue | |||
) | [static] |
Definition at line 354 of file queue_libsqlite3.c.
int _sqlite_rollback | ( | gearman_server_st * | server, | |
gearman_queue_sqlite_st * | queue | |||
) | [static] |
Definition at line 389 of file queue_libsqlite3.c.
static gearman_return_t _sqlite_add | ( | gearman_server_st * | server, | |
void * | context, | |||
const void * | unique, | |||
size_t | unique_size, | |||
const void * | function_name, | |||
size_t | function_name_size, | |||
const void * | data, | |||
size_t | data_size, | |||
gearman_job_priority_t | priority | |||
) | [static] |
Definition at line 426 of file queue_libsqlite3.c.
static gearman_return_t _sqlite_flush | ( | gearman_server_st * | server, | |
void * | context | |||
) | [static] |
static gearman_return_t _sqlite_done | ( | gearman_server_st * | server, | |
void * | context, | |||
const void * | unique, | |||
size_t | unique_size, | |||
const void * | function_name, | |||
size_t | function_name_size | |||
) | [static] |
static gearman_return_t _sqlite_replay | ( | gearman_server_st * | server, | |
void * | context, | |||
gearman_queue_add_fn * | add_fn, | |||
void * | add_context | |||
) | [static] |
Definition at line 616 of file queue_libsqlite3.c.