libsqlite3 Queue Storage Definitions More...
#include "common.h"
#include <libgearman-server/queue_libsqlite3.h>
#include <sqlite3.h>
Go to the source code of this file.
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 |
#define | MCO(__name, __value, __help) gearman_conf_module_add_option(module, __name, 0, __value, __help); |
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) |
gearman_return_t | gearman_server_queue_libsqlite3_conf (gearman_conf_st *conf) |
gearman_return_t | gearman_server_queue_libsqlite3_init (gearman_server_st *server, gearman_conf_st *conf) |
gearman_return_t | gearman_server_queue_libsqlite3_deinit (gearman_server_st *server) |
gearman_return_t | gearmand_queue_libsqlite3_init (gearmand_st *gearmand, gearman_conf_st *conf) |
gearman_return_t | gearmand_queue_libsqlite3_deinit (gearmand_st *gearmand) |
static gearman_return_t | _sqlite_flush (gearman_server_st *server, void *context __attribute__((unused))) |
static gearman_return_t | _sqlite_done (gearman_server_st *server, void *context, const void *unique, size_t unique_size, const void *function_name __attribute__((unused)), size_t function_name_size __attribute__((unused))) |
libsqlite3 Queue Storage Definitions
Definition in file queue_libsqlite3.c.
#define MCO | ( | __name, | |||
__value, | |||||
__help | ) | gearman_conf_module_add_option(module, __name, 0, __value, __help); |
static gearman_return_t _sqlite_flush | ( | gearman_server_st * | server, | |
void *context | __attribute__(unused) | |||
) | [static] |
Definition at line 555 of file queue_libsqlite3.c.
static gearman_return_t _sqlite_done | ( | gearman_server_st * | server, | |
void * | context, | |||
const void * | unique, | |||
size_t | unique_size, | |||
const void *function_name | __attribute__(unused), | |||
size_t function_name_size | __attribute__(unused) | |||
) | [static] |
Definition at line 563 of file queue_libsqlite3.c.