Static libsqlite3 Queue Storage Definitions
[libsqlite3 Queue Storage Declarations]

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 30 of file queue_libsqlite3.c.

#define SQLITE_MAX_CREATE_TABLE_SIZE   1024

Definition at line 31 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 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.