123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169 |
- #pragma once
- #ifdef __cplusplus
- #include <cstdlib>
- #else
- #include <stdlib.h>
- #endif
- #include <libgearman-1.0/limits.h>
- #include <libgearman-1.0/priority.h>
- #include <libgearman-server/verbose.h>
- #define GEARMAND_ARGS_BUFFER_SIZE 128
- #define GEARMAND_CONF_DISPLAY_WIDTH 80
- #define GEARMAND_CONF_MAX_OPTION_SHORT 128
- #define GEARMAND_DEFAULT_BACKLOG 64
- #define GEARMAND_DEFAULT_MAX_QUEUE_SIZE 0
- #define GEARMAND_DEFAULT_SOCKET_RECV_SIZE 32768
- #define GEARMAND_DEFAULT_SOCKET_SEND_SIZE 32768
- #define GEARMAND_DEFAULT_SOCKET_TIMEOUT 10
- #define GEARMAND_JOB_HANDLE_SIZE 64
- #define GEARMAND_DEFAULT_HASH_SIZE 991
- #define GEARMAND_MAX_COMMAND_ARGS 8
- #define GEARMAND_MAX_FREE_SERVER_CLIENT 1000
- #define GEARMAND_MAX_FREE_SERVER_CON 1000
- #define GEARMAND_MAX_FREE_SERVER_JOB 1000
- #define GEARMAND_MAX_FREE_SERVER_PACKET 2000
- #define GEARMAND_MAX_FREE_SERVER_WORKER 1000
- #define GEARMAND_OPTION_SIZE 64
- #define GEARMAND_PACKET_HEADER_SIZE 12
- #define GEARMAND_PIPE_BUFFER_SIZE 256
- #define GEARMAND_RECV_BUFFER_SIZE 8192
- #define GEARMAND_SEND_BUFFER_SIZE 8192
- #define GEARMAND_SERVER_CON_ID_SIZE 128
- #define GEARMAND_TEXT_RESPONSE_SIZE 8192
- #define GEARMAN_MAGIC_MEMORY (void*)(0x000001)
- enum gearmand_connection_options_t
- {
- GEARMAND_CON_PACKET_IN_USE,
- GEARMAND_CON_EXTERNAL_FD,
- GEARMAND_CON_CLOSE_AFTER_FLUSH,
- GEARMAND_CON_MAX
- };
- struct gearman_server_thread_st;
- struct gearman_server_st;
- struct gearman_server_con_st;
- struct gearmand_io_st;
- #ifdef __cplusplus
- extern "C" {
- #endif
- typedef void (gearman_server_thread_run_fn)(gearman_server_thread_st *thread,
- void *context);
- typedef gearmand_error_t (gearman_queue_add_fn)(gearman_server_st *server,
- void *context,
- const char *unique,
- size_t unique_size,
- const char *function_name,
- size_t function_name_size,
- const void *data,
- size_t data_size,
- gearman_job_priority_t priority,
- int64_t when);
- typedef gearmand_error_t (gearman_queue_flush_fn)(gearman_server_st *server,
- void *context);
- typedef gearmand_error_t (gearman_queue_done_fn)(gearman_server_st *server,
- void *context,
- const char *unique,
- size_t unique_size,
- const char *function_name,
- size_t function_name_size);
- typedef gearmand_error_t (gearman_queue_replay_fn)(gearman_server_st *server,
- void *context,
- gearman_queue_add_fn *add_fn,
- void *add_context);
- typedef gearmand_error_t (gearmand_connection_add_fn)(gearman_server_con_st *con);
- typedef gearmand_error_t (gearmand_connection_remove_fn)(gearman_server_con_st *con);
- typedef void (gearman_log_server_fn)(const char *line, gearmand_verbose_t verbose,
- struct gearmand_thread_st *context);
- typedef gearmand_error_t (gearmand_event_watch_fn)(gearmand_io_st *con,
- short events, void *context);
- typedef void (gearmand_connection_protocol_context_free_fn)(gearman_server_con_st *con,
- void *context);
- typedef void (gearmand_log_fn)(const char *line, gearmand_verbose_t verbose,
- void *context);
- #ifdef __cplusplus
- }
- #endif
|