libgearman-server/queue_libsqlite3.c File Reference

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)))

---

Detailed Description

libsqlite3 Queue Storage Definitions

Definition in file queue_libsqlite3.c.

---

Define Documentation

#define MCO	(	__name,
		__value,
		__help		)	gearman_conf_module_add_option(module, __name, 0, __value, __help);

---

Function Documentation

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.