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