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 30 of file queue_libsqlite3.c.
#define SQLITE_MAX_CREATE_TABLE_SIZE 1024 |
Definition at line 31 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 285 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 356 of file queue_libsqlite3.c.
int _sqlite_rollback | ( | gearman_server_st * | server, |
gearman_queue_sqlite_st * | queue | ||
) | [static] |
Definition at line 394 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 435 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 628 of file queue_libsqlite3.c.