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

This html diff was produced by rfcdiff 1.41. The latest version is available from http://tools.ietf.org/tools/rfcdiff/