gearmand.cc 20 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704
  1. /* vim:expandtab:shiftwidth=2:tabstop=2:smarttab:
  2. *
  3. * Cycle the Gearmand server
  4. *
  5. * Copyright (C) 2011 Data Differential, http://datadifferential.com/
  6. *
  7. * Redistribution and use in source and binary forms, with or without
  8. * modification, are permitted provided that the following conditions are
  9. * met:
  10. *
  11. * * Redistributions of source code must retain the above copyright
  12. * notice, this list of conditions and the following disclaimer.
  13. *
  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
  17. * distribution.
  18. *
  19. * * The names of its contributors may not be used to endorse or
  20. * promote products derived from this software without specific prior
  21. * written permission.
  22. *
  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.
  34. *
  35. */
  36. /*
  37. Test that we are cycling the servers we are creating during testing.
  38. */
  39. #include "gear_config.h"
  40. #include <libtest/test.hpp>
  41. #include "libgearman/client.hpp"
  42. #include "libgearman/worker.hpp"
  43. using namespace org::gearmand;
  44. #include <fstream>
  45. using namespace libtest;
  46. #ifndef __INTEL_COMPILER
  47. #pragma GCC diagnostic ignored "-Wstrict-aliasing"
  48. #endif
  49. static std::string executable;
  50. static test_return_t postion_TEST(void *)
  51. {
  52. const char *args[]= { "foo", 0 };
  53. ASSERT_EQ(EXIT_FAILURE, exec_cmdline(gearmand_binary(), args, true));
  54. return TEST_SUCCESS;
  55. }
  56. static test_return_t partial_TEST(void *)
  57. {
  58. const char *args[]= { "--log", 0 };
  59. ASSERT_EQ(EXIT_FAILURE, exec_cmdline(gearmand_binary(), args, true));
  60. return TEST_SUCCESS;
  61. }
  62. static test_return_t check_args_test(void *)
  63. {
  64. const char *args[]= { "--check-args", 0 };
  65. ASSERT_EQ(EXIT_SUCCESS, exec_cmdline(gearmand_binary(), args, true));
  66. return TEST_SUCCESS;
  67. }
  68. static test_return_t long_backlog_test(void *)
  69. {
  70. const char *args[]= { "--check-args", "--backlog=10", 0 };
  71. ASSERT_EQ(EXIT_SUCCESS, exec_cmdline(gearmand_binary(), args, true));
  72. return TEST_SUCCESS;
  73. }
  74. static test_return_t short_backlog_test(void *)
  75. {
  76. const char *args[]= { "--check-args", "-b", "10", 0 };
  77. ASSERT_EQ(EXIT_SUCCESS, exec_cmdline(gearmand_binary(), args, true));
  78. return TEST_SUCCESS;
  79. }
  80. static test_return_t long_daemon_test(void *)
  81. {
  82. const char *args[]= { "--check-args", "--daemon", 0 };
  83. ASSERT_EQ(EXIT_SUCCESS, exec_cmdline(gearmand_binary(), args, true));
  84. return TEST_SUCCESS;
  85. }
  86. static test_return_t long_coredump_TEST(void *)
  87. {
  88. const char *args[]= { "--check-args", "--coredump", 0 };
  89. ASSERT_EQ(EXIT_SUCCESS, exec_cmdline(gearmand_binary(), args, true));
  90. return TEST_SUCCESS;
  91. }
  92. static test_return_t short_daemon_test(void *)
  93. {
  94. const char *args[]= { "--check-args", "-d", 0 };
  95. ASSERT_EQ(EXIT_SUCCESS, exec_cmdline(gearmand_binary(), args, true));
  96. return TEST_SUCCESS;
  97. }
  98. static test_return_t long_file_descriptors_test(void *)
  99. {
  100. const char *args[]= { "--check-args", "--file-descriptors=10", 0 };
  101. ASSERT_EQ(EXIT_SUCCESS, exec_cmdline(gearmand_binary(), args, true));
  102. return TEST_SUCCESS;
  103. }
  104. static test_return_t short_file_descriptors_test(void *)
  105. {
  106. const char *args[]= { "--check-args", "-f", "10", 0 };
  107. ASSERT_EQ(EXIT_SUCCESS, exec_cmdline(gearmand_binary(), args, true));
  108. return TEST_SUCCESS;
  109. }
  110. static test_return_t long_help_test(void *)
  111. {
  112. const char *args[]= { "--check-args", "--help", 0 };
  113. ASSERT_EQ(EXIT_SUCCESS, exec_cmdline(gearmand_binary(), args, true));
  114. return TEST_SUCCESS;
  115. }
  116. static test_return_t short_help_test(void *)
  117. {
  118. const char *args[]= { "--check-args", "-h", 0 };
  119. ASSERT_EQ(EXIT_SUCCESS, exec_cmdline(gearmand_binary(), args, true));
  120. return TEST_SUCCESS;
  121. }
  122. static test_return_t long_keepalive_TEST(void *)
  123. {
  124. const char *args[]= { "--check-args", "--keepalive", 0 };
  125. ASSERT_EQ(EXIT_SUCCESS, exec_cmdline(gearmand_binary(), args, true));
  126. return TEST_SUCCESS;
  127. }
  128. static test_return_t long_keepalive_idle_TEST(void *)
  129. {
  130. const char *args[]= { "--check-args", "--keepalive-idle=10", 0 };
  131. ASSERT_EQ(EXIT_SUCCESS, exec_cmdline(gearmand_binary(), args, true));
  132. return TEST_SUCCESS;
  133. }
  134. static test_return_t long_keepalive_interval_TEST(void *)
  135. {
  136. const char *args[]= { "--check-args", "--keepalive-interval=3", 0 };
  137. ASSERT_EQ(EXIT_SUCCESS, exec_cmdline(gearmand_binary(), args, true));
  138. return TEST_SUCCESS;
  139. }
  140. static test_return_t long_keepalive_count_TEST(void *)
  141. {
  142. const char *args[]= { "--check-args", "--keepalive-count=10", 0 };
  143. ASSERT_EQ(EXIT_SUCCESS, exec_cmdline(gearmand_binary(), args, true));
  144. return TEST_SUCCESS;
  145. }
  146. static test_return_t long_keepalive_start_TEST(void *)
  147. {
  148. in_port_t port= libtest::get_free_port();
  149. char port_str[1024];
  150. ASSERT_TRUE(snprintf(port_str, sizeof(port_str), "--port=%d", int32_t(port)) > 0);
  151. const char *args[]= {
  152. port_str,
  153. "--check-args",
  154. "--log-file=stderr",
  155. "--keepalive-count=10",
  156. "--keepalive-interval=3",
  157. "--keepalive-idle=10", 0 };
  158. Application app(gearmand_binary(), true);
  159. Application::error_t ret= app.run(args);
  160. ASSERT_EQ(Application::SUCCESS, ret);
  161. ret= app.join();
  162. ASSERT_EQ_(Application::SUCCESS, ret, "ret: %s stderr: '%s' stdout: `%s'",
  163. Application::toString(ret),
  164. app.stderr_c_str(), app.stdout_c_str());
  165. return TEST_SUCCESS;
  166. }
  167. static test_return_t long_log_file_test(void *)
  168. {
  169. const char *args[]= { "--check-args", "--log-file=\"tmp/foo\"", 0 };
  170. ASSERT_EQ(EXIT_SUCCESS, exec_cmdline(gearmand_binary(), args, true));
  171. return TEST_SUCCESS;
  172. }
  173. static test_return_t long_log_file_stderr_TEST(void *)
  174. {
  175. const char *args[]= { "--check-args", "--log-file=stderr", 0 };
  176. ASSERT_EQ(EXIT_SUCCESS, exec_cmdline(gearmand_binary(), args, true));
  177. return TEST_SUCCESS;
  178. }
  179. static test_return_t short_log_file_test(void *)
  180. {
  181. const char *args[]= { "--check-args", "-l", "\"tmp/foo\"", 0 };
  182. ASSERT_EQ(EXIT_SUCCESS, exec_cmdline(gearmand_binary(), args, true));
  183. return TEST_SUCCESS;
  184. }
  185. static test_return_t long_listen_test(void *)
  186. {
  187. const char *args[]= { "--check-args", "--listen=10", 0 };
  188. ASSERT_EQ(EXIT_SUCCESS, exec_cmdline(gearmand_binary(), args, true));
  189. return TEST_SUCCESS;
  190. }
  191. static test_return_t short_listen_test(void *)
  192. {
  193. const char *args[]= { "--check-args", "-L", "10", 0 };
  194. ASSERT_EQ(EXIT_SUCCESS, exec_cmdline(gearmand_binary(), args, true));
  195. return TEST_SUCCESS;
  196. }
  197. static test_return_t long_port_test(void *)
  198. {
  199. const char *args[]= { "--check-args", "--port=10", 0 };
  200. ASSERT_EQ(EXIT_SUCCESS, exec_cmdline(gearmand_binary(), args, true));
  201. return TEST_SUCCESS;
  202. }
  203. static test_return_t short_port_test(void *)
  204. {
  205. const char *args[]= { "--check-args", "-p", "10", 0 };
  206. ASSERT_EQ(EXIT_SUCCESS, exec_cmdline(gearmand_binary(), args, true));
  207. return TEST_SUCCESS;
  208. }
  209. static test_return_t long_pid_file_test(void *)
  210. {
  211. const char *args[]= { "--check-args", "--pid-file=\"tmp/gearmand.pid\"", 0 };
  212. ASSERT_EQ(EXIT_SUCCESS, exec_cmdline(gearmand_binary(), args, true));
  213. return TEST_SUCCESS;
  214. }
  215. static test_return_t short_pid_file_test(void *)
  216. {
  217. const char *args[]= { "--check-args", "-P", "\"tmp/gearmand.pid\"", 0 };
  218. ASSERT_EQ(EXIT_SUCCESS, exec_cmdline(gearmand_binary(), args, true));
  219. return TEST_SUCCESS;
  220. }
  221. static test_return_t long_round_robin_test(void *)
  222. {
  223. const char *args[]= { "--check-args", "--round-robin", 0 };
  224. ASSERT_EQ(EXIT_SUCCESS, exec_cmdline(gearmand_binary(), args, true));
  225. return TEST_SUCCESS;
  226. }
  227. static test_return_t short_round_robin_test(void *)
  228. {
  229. const char *args[]= { "--check-args", "-R", 0 };
  230. ASSERT_EQ(EXIT_SUCCESS, exec_cmdline(gearmand_binary(), args, true));
  231. return TEST_SUCCESS;
  232. }
  233. static test_return_t long_syslog_test(void *)
  234. {
  235. const char *args[]= { "--check-args", "--syslog", 0 };
  236. ASSERT_EQ(EXIT_SUCCESS, exec_cmdline(gearmand_binary(), args, true));
  237. return TEST_SUCCESS;
  238. }
  239. static test_return_t SSL_TEST(void *)
  240. {
  241. const char *args[]= { "--check-args", "--ssl", 0 };
  242. ASSERT_EQ(EXIT_SUCCESS, exec_cmdline(gearmand_binary(), args, true));
  243. return TEST_SUCCESS;
  244. }
  245. static test_return_t long_threads_test(void *)
  246. {
  247. const char *args[]= { "--check-args", "--threads=10", 0 };
  248. ASSERT_EQ(EXIT_SUCCESS, exec_cmdline(gearmand_binary(), args, true));
  249. return TEST_SUCCESS;
  250. }
  251. static test_return_t short_threads_test(void *)
  252. {
  253. const char *args[]= { "--check-args", "-t", "8", 0 };
  254. ASSERT_EQ(EXIT_SUCCESS, exec_cmdline(gearmand_binary(), args, true));
  255. return TEST_SUCCESS;
  256. }
  257. static test_return_t long_user_test(void *)
  258. {
  259. const char *args[]= { "--check-args", "--user=nobody", 0 };
  260. ASSERT_EQ(EXIT_SUCCESS, exec_cmdline(gearmand_binary(), args, true));
  261. return TEST_SUCCESS;
  262. }
  263. static test_return_t short_user_test(void *)
  264. {
  265. const char *args[]= { "--check-args", "-u", "nobody", 0 };
  266. ASSERT_EQ(EXIT_SUCCESS, exec_cmdline(gearmand_binary(), args, true));
  267. return TEST_SUCCESS;
  268. }
  269. static test_return_t long_version_test(void *)
  270. {
  271. const char *args[]= { "--check-args", "--version", 0 };
  272. ASSERT_EQ(EXIT_SUCCESS, exec_cmdline(gearmand_binary(), args, true));
  273. return TEST_SUCCESS;
  274. }
  275. static test_return_t short_version_test(void *)
  276. {
  277. const char *args[]= { "--check-args", "-V", 0 };
  278. ASSERT_EQ(EXIT_SUCCESS, exec_cmdline(gearmand_binary(), args, true));
  279. return TEST_SUCCESS;
  280. }
  281. static test_return_t verbose_bad_option_TEST(void *)
  282. {
  283. const char *args[]= { "--check-args", "--verbose=BAD", 0 };
  284. ASSERT_EQ(EXIT_FAILURE, exec_cmdline(gearmand_binary(), args, true));
  285. return TEST_SUCCESS;
  286. }
  287. static test_return_t verbose_DEBUG_TEST(void *)
  288. {
  289. const char *args[]= { "--check-args", "--verbose=DEBUG", 0 };
  290. ASSERT_EQ(EXIT_SUCCESS, exec_cmdline(gearmand_binary(), args, true));
  291. return TEST_SUCCESS;
  292. }
  293. static test_return_t verbose_ERROR_TEST(void *)
  294. {
  295. const char *args[]= { "--check-args", "--verbose=ERROR", 0 };
  296. ASSERT_EQ(EXIT_SUCCESS, exec_cmdline(gearmand_binary(), args, true));
  297. return TEST_SUCCESS;
  298. }
  299. static test_return_t verbose_ALERT_TEST(void *)
  300. {
  301. const char *args[]= { "--check-args", "--verbose=ALERT", 0 };
  302. ASSERT_EQ(EXIT_SUCCESS, exec_cmdline(gearmand_binary(), args, true));
  303. return TEST_SUCCESS;
  304. }
  305. static test_return_t verbose_INFO_TEST(void *)
  306. {
  307. const char *args[]= { "--check-args", "--verbose=INFO", 0 };
  308. ASSERT_EQ(EXIT_SUCCESS, exec_cmdline(gearmand_binary(), args, true));
  309. return TEST_SUCCESS;
  310. }
  311. static test_return_t verbose_WARNING_TEST(void *)
  312. {
  313. const char *args[]= { "--check-args", "--verbose=WARNING", 0 };
  314. ASSERT_EQ(EXIT_SUCCESS, exec_cmdline(gearmand_binary(), args, true));
  315. return TEST_SUCCESS;
  316. }
  317. static test_return_t verbose_NOTICE_TEST(void *)
  318. {
  319. const char *args[]= { "--check-args", "--verbose=NOTICE", 0 };
  320. ASSERT_EQ(EXIT_SUCCESS, exec_cmdline(gearmand_binary(), args, true));
  321. return TEST_SUCCESS;
  322. }
  323. static test_return_t verbose_FATAL_TEST(void *)
  324. {
  325. const char *args[]= { "--check-args", "--verbose=FATAL", 0 };
  326. ASSERT_EQ(EXIT_SUCCESS, exec_cmdline(gearmand_binary(), args, true));
  327. return TEST_SUCCESS;
  328. }
  329. static test_return_t verbose_CRITICAL_TEST(void *)
  330. {
  331. const char *args[]= { "--check-args", "--verbose=CRITICAL", 0 };
  332. ASSERT_EQ(EXIT_SUCCESS, exec_cmdline(gearmand_binary(), args, true));
  333. return TEST_SUCCESS;
  334. }
  335. static test_return_t verbose_deprecated_TEST(void *)
  336. {
  337. const char *args[]= { "--check-args", "-vvv", 0 };
  338. ASSERT_EQ(EXIT_FAILURE, exec_cmdline(gearmand_binary(), args, true));
  339. return TEST_SUCCESS;
  340. }
  341. static test_return_t long_worker_wakeup_test(void *)
  342. {
  343. const char *args[]= { "--check-args", "--worker-wakeup=4", 0 };
  344. ASSERT_EQ(EXIT_SUCCESS, exec_cmdline(gearmand_binary(), args, true));
  345. return TEST_SUCCESS;
  346. }
  347. static test_return_t short_worker_wakeup_test(void *)
  348. {
  349. const char *args[]= { "--check-args", "-V", 0 };
  350. ASSERT_EQ(EXIT_SUCCESS, exec_cmdline(gearmand_binary(), args, true));
  351. return TEST_SUCCESS;
  352. }
  353. static test_return_t protocol_test(void *)
  354. {
  355. const char *args[]= { "--check-args", "--protocol=http", 0 };
  356. ASSERT_EQ(EXIT_SUCCESS, exec_cmdline(gearmand_binary(), args, true));
  357. return TEST_SUCCESS;
  358. }
  359. static test_return_t queue_test(void *)
  360. {
  361. const char *args[]= { "--check-args", "--queue-type=builtin", 0 };
  362. ASSERT_EQ(EXIT_SUCCESS, exec_cmdline(gearmand_binary(), args, true));
  363. return TEST_SUCCESS;
  364. }
  365. static test_return_t long_job_retries_test(void *)
  366. {
  367. const char *args[]= { "--check-args", "--job-retries=4", 0 };
  368. ASSERT_EQ(EXIT_SUCCESS, exec_cmdline(gearmand_binary(), args, true));
  369. return TEST_SUCCESS;
  370. }
  371. static test_return_t job_handle_prefix_TEST(void *)
  372. {
  373. const char *args[]= { "--check-args", "--job-handle-prefix=my_own_private_handle", 0 };
  374. ASSERT_EQ(EXIT_SUCCESS, exec_cmdline(gearmand_binary(), args, true));
  375. return TEST_SUCCESS;
  376. }
  377. static test_return_t hashtable_buckets_TEST(void *)
  378. {
  379. const char *args[]= { "--check-args", "--hashtable-buckets=2000", 0 };
  380. ASSERT_EQ(EXIT_SUCCESS, exec_cmdline(gearmand_binary(), args, true));
  381. return TEST_SUCCESS;
  382. }
  383. static test_return_t short_job_retries_test(void *)
  384. {
  385. const char *args[]= { "--check-args", "-j", "6", 0 };
  386. ASSERT_EQ(EXIT_SUCCESS, exec_cmdline(gearmand_binary(), args, true));
  387. return TEST_SUCCESS;
  388. }
  389. static test_return_t http_port_test(void *)
  390. {
  391. const char *args[]= { "--check-args", "--protocol=http", "--http-port=8090", 0 };
  392. ASSERT_EQ(EXIT_SUCCESS, exec_cmdline(gearmand_binary(), args, true));
  393. return TEST_SUCCESS;
  394. }
  395. static test_return_t config_file_TEST(void *)
  396. {
  397. ASSERT_EQ(-1, access("etc/gearmand.conf", R_OK));
  398. const char *args[]= { "--check-args", "--config-file=etc/gearmand.conf", 0 };
  399. ASSERT_EQ(EXIT_FAILURE, exec_cmdline(gearmand_binary(), args, true));
  400. return TEST_SUCCESS;
  401. }
  402. static test_return_t config_file_DEFAULT_TEST(void *)
  403. {
  404. const char *args[]= { "--check-args", "--config-file", 0 };
  405. ASSERT_EQ(EXIT_FAILURE, exec_cmdline(gearmand_binary(), args, true));
  406. return TEST_SUCCESS;
  407. }
  408. static test_return_t config_file_FAIL_TEST(void *)
  409. {
  410. const char *args[]= { "--check-args", "--config-file=etc/grmandfoo.conf", 0 };
  411. ASSERT_EQ(EXIT_FAILURE, exec_cmdline(gearmand_binary(), args, true));
  412. return TEST_SUCCESS;
  413. }
  414. static test_return_t config_file_SIMPLE_TEST(void *)
  415. {
  416. in_port_t port= libtest::get_free_port();
  417. char port_str[1024];
  418. ASSERT_TRUE(snprintf(port_str, sizeof(port_str), "%d", int32_t(port)) > 0);
  419. std::string config_file= "etc/gearmand.conf";
  420. {
  421. char current_directory_buffer[1024];
  422. char *current_directory= getcwd(current_directory_buffer, sizeof(current_directory_buffer));
  423. std::string config_path;
  424. config_path+= current_directory;
  425. config_path+= "/";
  426. config_path+= config_file;
  427. std::fstream file_stream;
  428. file_stream.open(config_path.c_str(), std::fstream::out | std::fstream::trunc);
  429. ASSERT_TRUE(file_stream.good());
  430. file_stream << "--port " << port_str << std::endl;
  431. ASSERT_TRUE(file_stream.good());
  432. file_stream.close();
  433. }
  434. test_zero(access(config_file.c_str(), R_OK));
  435. char args_buffer[1024];
  436. snprintf(args_buffer, sizeof(args_buffer), "--config-file=%s", config_file.c_str());
  437. const char *args[]= { "--check-args", args_buffer, 0 };
  438. ASSERT_EQ(EXIT_SUCCESS, exec_cmdline(gearmand_binary(), args, true));
  439. unlink(config_file.c_str());
  440. return TEST_SUCCESS;
  441. }
  442. static test_return_t maxqueue_TEST(void *)
  443. {
  444. return TEST_SKIPPED;
  445. #if 0
  446. in_port_t port= libtest::get_free_port();
  447. Application gearmand(gearmand_binary(), true);
  448. char buffer[1024];
  449. test_true(snprintf(buffer, sizeof(buffer), "%d", int32_t(port)) > 0);
  450. gearmand.add_long_option("--port=", buffer);
  451. ASSERT_EQ(Application::SUCCESS, gearmand.run());
  452. test::Worker worker(port);
  453. ASSERT_EQ(GEARMAN_SUCCESS, gearman_worker_register(&worker, __func__, 0));
  454. ASSERT_EQ(GEARMAN_SUCCESS, gearman_worker_unregister(&worker, __func__));
  455. ASSERT_EQ(Application::SUCCESS, gearmand.join());
  456. return TEST_SUCCESS;
  457. #endif
  458. }
  459. test_st bad_option_TESTS[] ={
  460. {"position argument", 0, postion_TEST },
  461. {"partial argument", 0, partial_TEST },
  462. {0, 0, 0}
  463. };
  464. test_st gearmand_option_tests[] ={
  465. {"--check-args", 0, check_args_test},
  466. {"--backlog=", 0, long_backlog_test},
  467. {"-b", 0, short_backlog_test},
  468. {"--coredump", 0, long_coredump_TEST},
  469. {"--daemon", 0, long_daemon_test},
  470. {"-d", 0, short_daemon_test},
  471. {"--file-descriptors=", 0, long_file_descriptors_test},
  472. {"-f", 0, short_file_descriptors_test},
  473. {"--help", 0, long_help_test},
  474. {"-h", 0, short_help_test},
  475. {"--keepalive", 0, long_keepalive_TEST},
  476. {"--keepalive-idle", 0, long_keepalive_idle_TEST},
  477. {"--keepalive-interval", 0, long_keepalive_interval_TEST},
  478. {"--keepalive-count", 0, long_keepalive_count_TEST},
  479. {"--log-file=", 0, long_log_file_test},
  480. {"--log-file=stderr", 0, long_log_file_stderr_TEST},
  481. {"-l", 0, short_log_file_test},
  482. {"--listen=", 0, long_listen_test},
  483. {"-L", 0, short_listen_test},
  484. {"--port=", 0, long_port_test},
  485. {"-p", 0, short_port_test},
  486. {"--pid-file=", 0, long_pid_file_test},
  487. {"-P", 0, short_pid_file_test},
  488. {"--round-robin", 0, long_round_robin_test},
  489. {"-R", 0, short_round_robin_test},
  490. {"--ssl", 0, SSL_TEST},
  491. {"--syslog=", 0, long_syslog_test},
  492. {"--threads=", 0, long_threads_test},
  493. {"-T", 0, short_threads_test},
  494. {"--user=", 0, long_user_test},
  495. {"-u", 0, short_user_test},
  496. {"--user=", 0, long_user_test},
  497. {"-u", 0, short_user_test},
  498. {"-vvv", 0, verbose_deprecated_TEST},
  499. {"--verbose=FATAL", 0, verbose_FATAL_TEST},
  500. {"--verbose=ALERT", 0, verbose_ALERT_TEST},
  501. {"--verbose=CRITICAL", 0, verbose_CRITICAL_TEST},
  502. {"--verbose=ERROR", 0, verbose_ERROR_TEST},
  503. {"--verbose=WARNING", 0, verbose_WARNING_TEST},
  504. {"--verbose=NOTICE", 0, verbose_NOTICE_TEST},
  505. {"--verbose=INFO", 0, verbose_INFO_TEST},
  506. {"--verbose=DEBUG", 0, verbose_DEBUG_TEST},
  507. {"--verbose=BAD", 0, verbose_bad_option_TEST},
  508. {"--version", 0, long_version_test},
  509. {"-V", 0, short_version_test},
  510. {"--worker_wakeup=", 0, long_worker_wakeup_test},
  511. {"-w", 0, short_worker_wakeup_test},
  512. {"--protocol=", 0, protocol_test},
  513. {"--queue-type=", 0, queue_test},
  514. {"--job-retries=", 0, long_job_retries_test},
  515. {"-hashtable-buckets", 0, hashtable_buckets_TEST},
  516. {"--job-handle-prefix=", 0, job_handle_prefix_TEST},
  517. {"-j", 0, short_job_retries_test},
  518. {"--config-file=etc/gearmand.conf no file present", 0, config_file_TEST },
  519. {"--config-file", 0, config_file_DEFAULT_TEST },
  520. {"--config-file=etc/grmandfoo.conf", 0, config_file_FAIL_TEST },
  521. {"--config-file=etc/gearmand.conf", 0, config_file_SIMPLE_TEST },
  522. {"start server with all --keepalive options", 0, long_keepalive_start_TEST},
  523. {0, 0, 0}
  524. };
  525. test_st gearmand_httpd_option_tests[] ={
  526. {"--http-port=", 0, http_port_test},
  527. {0, 0, 0}
  528. };
  529. test_st maxqueue_TESTS[] ={
  530. { "maxqueue=", 0, maxqueue_TEST },
  531. {0, 0, 0}
  532. };
  533. static test_return_t option_SETUP(void*)
  534. {
  535. unlink("etc/gearmand.conf");
  536. return TEST_SUCCESS;
  537. }
  538. collection_st collection[] ={
  539. { "bad options", 0, 0, bad_option_TESTS },
  540. { "basic options", option_SETUP, 0, gearmand_option_tests },
  541. { "httpd options", 0, 0, gearmand_httpd_option_tests },
  542. { "maxqueue", 0, 0, maxqueue_TESTS },
  543. {0, 0, 0, 0}
  544. };
  545. void get_world(libtest::Framework *world)
  546. {
  547. world->collections(collection);
  548. }