00001
00002
00003
00004
00005
00006
00007
00008
00014 #ifndef __GEARMAN_SERVER_H__
00015 #define __GEARMAN_SERVER_H__
00016
00017 #include <libgearman/gearman.h>
00018 #include <libgearman-server/constants.h>
00019 #include <libgearman-server/structs.h>
00020 #include <libgearman-server/conf.h>
00021 #include <libgearman-server/conf_module.h>
00022 #include <libgearman-server/conn.h>
00023 #include <libgearman-server/packet.h>
00024 #include <libgearman-server/function.h>
00025 #include <libgearman-server/client.h>
00026 #include <libgearman-server/worker.h>
00027 #include <libgearman-server/job.h>
00028 #include <libgearman-server/thread.h>
00029
00030 #ifdef __cplusplus
00031 extern "C" {
00032 #endif
00033
00047 GEARMAN_API
00048 gearman_server_st *gearman_server_create(gearman_server_st *server);
00049
00055 GEARMAN_API
00056 void gearman_server_free(gearman_server_st *server);
00057
00064 GEARMAN_API
00065 void gearman_server_set_job_retries(gearman_server_st *server,
00066 uint8_t job_retries);
00067
00076 GEARMAN_API
00077 void gearman_server_set_log_fn(gearman_server_st *server,
00078 gearman_log_fn *function,
00079 const void *context, gearman_verbose_t verbose);
00080
00087 GEARMAN_API
00088 gearman_return_t gearman_server_run_command(gearman_server_con_st *server_con,
00089 gearman_packet_st *packet);
00090
00098 GEARMAN_API
00099 gearman_return_t gearman_server_shutdown_graceful(gearman_server_st *server);
00100
00109 GEARMAN_API
00110 gearman_return_t gearman_server_queue_replay(gearman_server_st *server);
00111
00115 GEARMAN_API
00116 void *gearman_server_queue_context(const gearman_server_st *server);
00117
00122 GEARMAN_API
00123 void gearman_server_set_queue_context(gearman_server_st *server,
00124 const void *context);
00125
00129 GEARMAN_API
00130 void gearman_server_set_queue_add_fn(gearman_server_st *server,
00131 gearman_queue_add_fn *function);
00132
00136 GEARMAN_API
00137 void gearman_server_set_queue_flush_fn(gearman_server_st *server,
00138 gearman_queue_flush_fn *function);
00139
00143 GEARMAN_API
00144 void gearman_server_set_queue_done_fn(gearman_server_st *server,
00145 gearman_queue_done_fn *function);
00146
00151 GEARMAN_API
00152 void gearman_server_set_queue_replay_fn(gearman_server_st *server,
00153 gearman_queue_replay_fn *function);
00154
00157 #ifdef __cplusplus
00158 }
00159 #endif
00160
00161 #endif