Gearman Developer Documentation

Private Server Functions
[Gearman Server Declarations]

Functions

gearman_return_t _queue_replay_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 _server_error_packet (gearman_server_con_st *server_con, const char *error_code, const char *error_string)
static gearman_return_t _server_run_text (gearman_server_con_st *server_con, gearman_packet_st *packet)
static gearman_return_t _server_queue_work_data (gearman_server_job_st *server_job, gearman_packet_st *packet, gearman_command_t command)
static void _log (const char *line, gearman_verbose_t verbose, void *context)
gearman_return_t _thread_packet_read (gearman_server_con_st *con)
static gearman_return_t _thread_packet_flush (gearman_server_con_st *con)
static gearman_return_t _proc_thread_start (gearman_server_st *server)
static void _proc_thread_kill (gearman_server_st *server)
static void * _proc (void *data)

Function Documentation

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

Add job to queue wihle replaying queue during startup.

static gearman_return_t _server_error_packet ( gearman_server_con_st server_con,
const char *  error_code,
const char *  error_string 
) [static]

Queue an error packet.

Definition at line 731 of file server.c.

static gearman_return_t _server_run_text ( gearman_server_con_st server_con,
gearman_packet_st packet 
) [static]

Process text commands for a connection.

Definition at line 742 of file server.c.

static gearman_return_t _server_queue_work_data ( gearman_server_job_st server_job,
gearman_packet_st packet,
gearman_command_t  command 
) [static]

Send work result packets with data back to clients.

Definition at line 952 of file server.c.

static void _log ( const char *  line,
gearman_verbose_t  verbose,
void *  context 
) [static]

Wrapper for log handling.

Definition at line 1002 of file server.c.

gearman_return_t _thread_packet_read ( gearman_server_con_st con  ) 

Try reading packets for a connection.

Definition at line 286 of file thread.c.

static gearman_return_t _thread_packet_flush ( gearman_server_con_st con  )  [static]

Flush outgoing packets for a connection.

Definition at line 337 of file thread.c.

static gearman_return_t _proc_thread_start ( gearman_server_st server  )  [static]

Start processing thread for the server.

Definition at line 364 of file thread.c.

static void _proc_thread_kill ( gearman_server_st server  )  [static]

Kill processing thread for the server.

Definition at line 390 of file thread.c.

static void * _proc ( void *  data  )  [static]

Processing thread.

Definition at line 408 of file thread.c.

Generated on Mon Jun 14 15:58:45 2010 by  doxygen 1.6.3