client.h | client.h | |||
---|---|---|---|---|
skipping to change at line 696 | skipping to change at line 696 | |||
/** | /** | |||
* Run tasks that have been added in parallel. | * Run tasks that have been added in parallel. | |||
* | * | |||
* @param[in] client Structure previously initialized with | * @param[in] client Structure previously initialized with | |||
* gearman_client_create() or gearman_client_clone(). | * gearman_client_create() or gearman_client_clone(). | |||
* @return Standard gearman return value. | * @return Standard gearman return value. | |||
*/ | */ | |||
GEARMAN_API | GEARMAN_API | |||
gearman_return_t gearman_client_run_tasks(gearman_client_st *client); | gearman_return_t gearman_client_run_tasks(gearman_client_st *client); | |||
GEARMAN_LOCAL | ||||
gearman_return_t gearman_client_run_block_tasks(gearman_client_st *client); | ||||
GEARMAN_API | GEARMAN_API | |||
bool gearman_client_compare(const gearman_client_st *first, const gearman_c lient_st *second); | bool gearman_client_compare(const gearman_client_st *first, const gearman_c lient_st *second); | |||
GEARMAN_API | GEARMAN_API | |||
bool gearman_client_set_server_option(gearman_client_st *self, const char * option_arg, size_t option_arg_size); | bool gearman_client_set_server_option(gearman_client_st *self, const char * option_arg, size_t option_arg_size); | |||
GEARMAN_LOCAL | ||||
size_t gearman_client_count_tasks(gearman_client_st *client); | ||||
GEARMAN_API | GEARMAN_API | |||
void gearman_client_set_namespace(gearman_client_st *self, const char *name space_key, size_t namespace_key_size); | void gearman_client_set_namespace(gearman_client_st *self, const char *name space_key, size_t namespace_key_size); | |||
GEARMAN_API | GEARMAN_API | |||
gearman_return_t gearman_client_set_identifier(gearman_client_st *client, | gearman_return_t gearman_client_set_identifier(gearman_client_st *client, | |||
const char *id, size_t id_si ze); | const char *id, size_t id_si ze); | |||
const char *gearman_client_namespace(gearman_client_st *self); | const char *gearman_client_namespace(gearman_client_st *self); | |||
GEARMAN_API | GEARMAN_API | |||
End of changes. 2 change blocks. | ||||
6 lines changed or deleted | 0 lines changed or added | |||
constants.h | constants.h | |||
---|---|---|---|---|
skipping to change at line 111 | skipping to change at line 111 | |||
* Options for gearman_client_st. | * Options for gearman_client_st. | |||
*/ | */ | |||
typedef enum | typedef enum | |||
{ | { | |||
GEARMAN_CLIENT_ALLOCATED= (1 << 0), | GEARMAN_CLIENT_ALLOCATED= (1 << 0), | |||
GEARMAN_CLIENT_NON_BLOCKING= (1 << 1), | GEARMAN_CLIENT_NON_BLOCKING= (1 << 1), | |||
GEARMAN_CLIENT_TASK_IN_USE= (1 << 2), | GEARMAN_CLIENT_TASK_IN_USE= (1 << 2), | |||
GEARMAN_CLIENT_UNBUFFERED_RESULT= (1 << 3), | GEARMAN_CLIENT_UNBUFFERED_RESULT= (1 << 3), | |||
GEARMAN_CLIENT_NO_NEW= (1 << 4), | GEARMAN_CLIENT_NO_NEW= (1 << 4), | |||
GEARMAN_CLIENT_FREE_TASKS= (1 << 5), | GEARMAN_CLIENT_FREE_TASKS= (1 << 5), | |||
GEARMAN_CLIENT_MAX= (1 << 6) | GEARMAN_CLIENT_GENERATE_UNIQUE= (1 << 6), | |||
GEARMAN_CLIENT_MAX= (1 << 7) | ||||
} gearman_client_options_t; | } gearman_client_options_t; | |||
/** | /** | |||
* @ingroup gearman_worker | * @ingroup gearman_worker | |||
* Options for gearman_worker_st. | * Options for gearman_worker_st. | |||
*/ | */ | |||
typedef enum | typedef enum | |||
{ | { | |||
GEARMAN_WORKER_ALLOCATED= (1 << 0), | GEARMAN_WORKER_ALLOCATED= (1 << 0), | |||
GEARMAN_WORKER_NON_BLOCKING= (1 << 1), | GEARMAN_WORKER_NON_BLOCKING= (1 << 1), | |||
End of changes. 1 change blocks. | ||||
1 lines changed or deleted | 2 lines changed or added | |||
function.h | function.h | |||
---|---|---|---|---|
skipping to change at line 87 | skipping to change at line 87 | |||
typedef struct gearman_function_t gearman_function_t; | typedef struct gearman_function_t gearman_function_t; | |||
#endif | #endif | |||
#ifdef __cplusplus | #ifdef __cplusplus | |||
extern "C" { | extern "C" { | |||
#endif | #endif | |||
GEARMAN_API | GEARMAN_API | |||
gearman_function_t gearman_function_create(gearman_function_fn func); | gearman_function_t gearman_function_create(gearman_function_fn func); | |||
GEARMAN_LOCAL | ||||
gearman_function_t gearman_function_create_null(void); | ||||
GEARMAN_API | GEARMAN_API | |||
gearman_function_t gearman_function_create_partition(gearman_function_fn func, | gearman_function_t gearman_function_create_partition(gearman_function_fn func, | |||
gearman_aggregator_f n aggregator); | gearman_aggregator_f n aggregator); | |||
GEARMAN_API | GEARMAN_API | |||
gearman_function_t gearman_function_create_v1(gearman_worker_fn func); | gearman_function_t gearman_function_create_v1(gearman_worker_fn func); | |||
GEARMAN_API | GEARMAN_API | |||
gearman_function_t gearman_function_create_v2(gearman_function_fn func); | gearman_function_t gearman_function_create_v2(gearman_function_fn func); | |||
End of changes. 1 change blocks. | ||||
3 lines changed or deleted | 0 lines changed or added | |||
ostream.hpp | ostream.hpp | |||
---|---|---|---|---|
skipping to change at line 49 | skipping to change at line 49 | |||
#include <libgearman-1.0/gearman.h> | #include <libgearman-1.0/gearman.h> | |||
#include <ostream> | #include <ostream> | |||
static inline std::ostream& operator<<(std::ostream& output, const enum gea rman_return_t &arg) | static inline std::ostream& operator<<(std::ostream& output, const enum gea rman_return_t &arg) | |||
{ | { | |||
output << gearman_strerror(arg); | output << gearman_strerror(arg); | |||
return output; | return output; | |||
} | } | |||
static inline std::ostream& operator<<(std::ostream& output, const gearman_ | ||||
task_st &arg) | ||||
{ | ||||
output << std::boolalpha | ||||
<< "job: " << gearman_task_job_handle(&arg) | ||||
<< " unique: " << gearman_task_unique(&arg) | ||||
<< " complete: " << gearman_task_numerator(&arg) << "/" << gearman_task | ||||
_denominator(&arg) | ||||
<< " state: " << gearman_task_strstate(&arg) | ||||
<< " is_known: " << gearman_task_is_known(&arg) | ||||
<< " is_running: " << gearman_task_is_running(&arg) | ||||
<< " ret: " << gearman_task_return(&arg); | ||||
return output; | ||||
} | ||||
static inline std::ostream& operator<<(std::ostream& output, const gearman_ status_t &arg) | static inline std::ostream& operator<<(std::ostream& output, const gearman_ status_t &arg) | |||
{ | { | |||
output << std::boolalpha | output << std::boolalpha | |||
<< " is_known: " << gearman_status_is_known(arg) | << " is_known: " << gearman_status_is_known(arg) | |||
<< " is_running: " << gearman_status_is_running(arg) | << " is_running: " << gearman_status_is_running(arg) | |||
<< " complete: " << gearman_status_numerator(arg) << "/" << gearman_sta tus_denominator(arg) | << " complete: " << gearman_status_numerator(arg) << "/" << gearman_sta tus_denominator(arg) | |||
<< " ret: " << gearman_strerror(gearman_status_return(arg)); | << " ret: " << gearman_strerror(gearman_status_return(arg)); | |||
return output; | return output; | |||
} | } | |||
End of changes. 1 change blocks. | ||||
16 lines changed or deleted | 0 lines changed or added | |||
task_attr.h | task_attr.h | |||
---|---|---|---|---|
skipping to change at line 81 | skipping to change at line 81 | |||
GEARMAN_API | GEARMAN_API | |||
gearman_task_attr_t gearman_task_attr_init(gearman_job_priority_t priorit y); | gearman_task_attr_t gearman_task_attr_init(gearman_job_priority_t priorit y); | |||
GEARMAN_API | GEARMAN_API | |||
gearman_task_attr_t gearman_task_attr_init_epoch(time_t epoch, gearman_jo b_priority_t priority); | gearman_task_attr_t gearman_task_attr_init_epoch(time_t epoch, gearman_jo b_priority_t priority); | |||
GEARMAN_API | GEARMAN_API | |||
gearman_task_attr_t gearman_task_attr_init_background(gearman_job_priorit y_t priority); | gearman_task_attr_t gearman_task_attr_init_background(gearman_job_priorit y_t priority); | |||
// Everything below here is private | ||||
GEARMAN_LOCAL | ||||
time_t gearman_task_attr_has_epoch(const gearman_task_attr_t *); | ||||
GEARMAN_LOCAL | ||||
gearman_job_priority_t gearman_task_attr_priority(const gearman_task_attr_t | ||||
*); | ||||
GEARMAN_LOCAL | ||||
bool gearman_task_attr_is_background(const gearman_task_attr_t *); | ||||
#ifdef __cplusplus | #ifdef __cplusplus | |||
} | } | |||
#endif | #endif | |||
End of changes. 1 change blocks. | ||||
12 lines changed or deleted | 0 lines changed or added | |||
version.h | version.h | |||
---|---|---|---|---|
skipping to change at line 40 | skipping to change at line 40 | |||
* LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, | * LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, | |||
* DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY | * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY | |||
* THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT | * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT | |||
* (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE | * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE | |||
* OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. | * OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. | |||
* | * | |||
*/ | */ | |||
#pragma once | #pragma once | |||
#define LIBGEARMAN_VERSION_STRING "1.1.3" | #define LIBGEARMAN_VERSION_STRING "1.1.4" | |||
#define LIBGEARMAN_VERSION_HEX 0x01001003 | #define LIBGEARMAN_VERSION_HEX 0x01001004 | |||
End of changes. 1 change blocks. | ||||
0 lines changed or deleted | 0 lines changed or added | |||