/* vim:expandtab:shiftwidth=2:tabstop=2:smarttab: * * Gearmand client and server library. * * Copyright (C) 2012 Data Differential, http://datadifferential.com/ * All rights reserved. * * Redistribution and use in source and binary forms, with or without * modification, are permitted provided that the following conditions are * met: * * * Redistributions of source code must retain the above copyright * notice, this list of conditions and the following disclaimer. * * * Redistributions in binary form must reproduce the above * copyright notice, this list of conditions and the following disclaimer * in the documentation and/or other materials provided with the * distribution. * * * The names of its contributors may not be used to endorse or * promote products derived from this software without specific prior * written permission. * * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS * "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT * LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR * A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT * OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, * SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT * LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE * OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. * */ #pragma once #include "libgearman/actions.hpp" #include "libgearman/interface/universal.hpp" #include "libgearman/is.hpp" struct Client { struct Options { bool non_blocking; bool unbuffered_result; bool no_new; bool free_tasks; bool generate_unique; bool exceptions; Options(): non_blocking(false), unbuffered_result(false), no_new(false), free_tasks(false), generate_unique(false), exceptions(false) { } } options; enum gearman_client_t state; uint32_t new_tasks; uint32_t running_tasks; uint32_t task_count; void *context; struct gearman_connection_st *con; gearman_task_st *task; gearman_task_st *task_list; gearman_task_context_free_fn *task_context_free_fn; gearman_universal_st universal; struct gearman_actions_t actions; gearman_job_handle_t _do_handle; // Backwards compatible Client(gearman_client_st* shell_) : state(GEARMAN_CLIENT_STATE_IDLE), new_tasks(0), running_tasks(0), task_count(0), context(NULL), con(NULL), task(NULL), task_list(NULL), task_context_free_fn(NULL), actions(gearman_actions_default()), _shell(shell_) { _do_handle[0]= 0; if (shell_ and shell_ == &_owned_shell) { gearman_set_allocated(_shell, true); } else if (shell_) { gearman_set_allocated(_shell, false); } else { _shell= &_owned_shell; gearman_set_allocated(_shell, true); } _shell->impl(this); gearman_set_initialized(_shell, true); } gearman_return_t add_server(const char *host, const char* service_); ~Client() { if (_shell) { #ifndef NDBUG if (_shell == &_owned_shell) { assert(gearman_is_allocated(_shell)); } else // _shell != &_owned_shell #endif { gearman_set_allocated(_shell, false); gearman_set_initialized(_shell, false); _shell->_impl= NULL; } } } gearman_client_st* shell() { return _shell; } bool ssl() const { return universal.ssl(); } void ssl(bool ssl_) { universal.ssl(ssl_); } const char* error() const { return universal.error(); } gearman_return_t error_code() const { return universal.error_code(); } private: gearman_client_st* _shell; gearman_client_st _owned_shell; };