1
/* vim:expandtab:shiftwidth=2:tabstop=2:smarttab:
3
* Cycle the Gearmand server
5
* Copyright (C) 2011 Data Differential, http://datadifferential.com/
7
* Redistribution and use in source and binary forms, with or without
8
* modification, are permitted provided that the following conditions are
11
* * Redistributions of source code must retain the above copyright
12
* notice, this list of conditions and the following disclaimer.
14
* * Redistributions in binary form must reproduce the above
15
* copyright notice, this list of conditions and the following disclaimer
16
* in the documentation and/or other materials provided with the
19
* * The names of its contributors may not be used to endorse or
20
* promote products derived from this software without specific prior
23
* THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS
24
* "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT
25
* LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR
26
* A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT
27
* OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
28
* SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
29
* LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
30
* DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
31
* THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
32
* (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE
33
* OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
39
Test that we are cycling the servers we are creating during testing.
43
#include <libtest/test.hpp>
45
using namespace libtest;
46
#include <libgearman/gearman.h>
48
#include "tests/ports.h"
49
#include "tests/start_worker.h"
51
static gearman_return_t success_fn(gearman_job_st*, void* /* context */)
53
return GEARMAN_SUCCESS;
56
static test_return_t single_cycle(void *)
60
gearman_function_t success_function= gearman_function_create(success_fn);
61
worker_handle_st *worker= test_worker_start(CYCLE_TEST_PORT, NULL, "success", success_function, NULL, gearman_worker_options_t());
63
test_true(worker->shutdown());
70
static test_return_t kill_test(void *)
77
test_st kill_tests[] ={
78
{"kill", true, (test_callback_fn*)kill_test },
82
test_st worker_tests[] ={
83
{"single startup/shutdown", true, (test_callback_fn*)single_cycle },
87
collection_st collection[] ={
88
{"kill", 0, 0, kill_tests},
89
{"worker", 0, 0, worker_tests},
93
static void *world_create(server_startup_st& servers, test_return_t& error)
95
const char *argv[1]= { "client_gearmand" };
96
if (server_startup(servers, "gearmand", CYCLE_TEST_PORT, 1, argv) == false)
104
void get_world(Framework *world)
106
world->collections= collection;
107
world->_create= world_create;