Gearman Developer Documentation

sqlite Queue Storage Functions

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 Documentation

#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.


Function Documentation

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.


Generated on Tue Oct 13 20:19:22 2009 by  doxygen 1.6.1