protocol.h 4.5 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697
  1. /* vim:expandtab:shiftwidth=2:tabstop=2:smarttab:
  2. *
  3. * Gearmand client and server library.
  4. *
  5. * Copyright (C) 2011-2012 Data Differential, http://datadifferential.com/
  6. * Copyright (C) 2008 Brian Aker, Eric Day
  7. * All rights reserved.
  8. *
  9. * Redistribution and use in source and binary forms, with or without
  10. * modification, are permitted provided that the following conditions are
  11. * met:
  12. *
  13. * * Redistributions of source code must retain the above copyright
  14. * notice, this list of conditions and the following disclaimer.
  15. *
  16. * * Redistributions in binary form must reproduce the above
  17. * copyright notice, this list of conditions and the following disclaimer
  18. * in the documentation and/or other materials provided with the
  19. * distribution.
  20. *
  21. * * The names of its contributors may not be used to endorse or
  22. * promote products derived from this software without specific prior
  23. * written permission.
  24. *
  25. * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS
  26. * "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT
  27. * LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR
  28. * A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT
  29. * OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
  30. * SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
  31. * LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE,
  32. * DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY
  33. * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
  34. * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE
  35. * OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
  36. *
  37. */
  38. #pragma once
  39. #define GEARMAN_DEFAULT_TCP_PORT 4730
  40. #define GEARMAN_DEFAULT_TCP_PORT_STRING "4730"
  41. #define GEARMAN_DEFAULT_TCP_SERVICE "gearman"
  42. enum gearman_command_t
  43. {
  44. GEARMAN_COMMAND_TEXT,
  45. GEARMAN_COMMAND_CAN_DO, /* W->J: FUNC */
  46. GEARMAN_COMMAND_CANT_DO, /* W->J: FUNC */
  47. GEARMAN_COMMAND_RESET_ABILITIES, /* W->J: -- */
  48. GEARMAN_COMMAND_PRE_SLEEP, /* W->J: -- */
  49. GEARMAN_COMMAND_UNUSED,
  50. GEARMAN_COMMAND_NOOP, /* J->W: -- */
  51. GEARMAN_COMMAND_SUBMIT_JOB, /* C->J: FUNC[0]UNIQ[0]ARGS */
  52. GEARMAN_COMMAND_JOB_CREATED, /* J->C: HANDLE */
  53. GEARMAN_COMMAND_GRAB_JOB, /* W->J: -- */
  54. GEARMAN_COMMAND_NO_JOB, /* J->W: -- */
  55. GEARMAN_COMMAND_JOB_ASSIGN, /* J->W: HANDLE[0]FUNC[0]ARG */
  56. GEARMAN_COMMAND_WORK_STATUS, /* W->J/C: HANDLE[0]NUMERATOR[0]DENOMINATOR */
  57. GEARMAN_COMMAND_WORK_COMPLETE, /* W->J/C: HANDLE[0]RES */
  58. GEARMAN_COMMAND_WORK_FAIL, /* W->J/C: HANDLE */
  59. GEARMAN_COMMAND_GET_STATUS, /* C->J: HANDLE */
  60. GEARMAN_COMMAND_ECHO_REQ, /* ?->J: TEXT */
  61. GEARMAN_COMMAND_ECHO_RES, /* J->?: TEXT */
  62. GEARMAN_COMMAND_SUBMIT_JOB_BG, /* C->J: FUNC[0]UNIQ[0]ARGS */
  63. GEARMAN_COMMAND_ERROR, /* J->?: ERRCODE[0]ERR_TEXT */
  64. GEARMAN_COMMAND_STATUS_RES, /* J->C: HANDLE[0]KNOWN[0]RUNNING[0]NUM[0]DENOM */
  65. GEARMAN_COMMAND_SUBMIT_JOB_HIGH, /* C->J: FUNC[0]UNIQ[0]ARGS */
  66. GEARMAN_COMMAND_SET_CLIENT_ID, /* W->J: [RANDOM_STRING_NO_WHITESPACE] */
  67. GEARMAN_COMMAND_CAN_DO_TIMEOUT, /* W->J: FUNC[0]TIMEOUT */
  68. GEARMAN_COMMAND_ALL_YOURS,
  69. GEARMAN_COMMAND_WORK_EXCEPTION, /* W->J/C: HANDLE[0] */
  70. GEARMAN_COMMAND_OPTION_REQ, /* ?->J: TEXT */
  71. GEARMAN_COMMAND_OPTION_RES, /* J->?: TEXT */
  72. GEARMAN_COMMAND_WORK_DATA,
  73. GEARMAN_COMMAND_WORK_WARNING,
  74. GEARMAN_COMMAND_GRAB_JOB_UNIQ, /* W->J: -- */
  75. GEARMAN_COMMAND_JOB_ASSIGN_UNIQ, /* J->W: */
  76. GEARMAN_COMMAND_SUBMIT_JOB_HIGH_BG,
  77. GEARMAN_COMMAND_SUBMIT_JOB_LOW,
  78. GEARMAN_COMMAND_SUBMIT_JOB_LOW_BG,
  79. GEARMAN_COMMAND_SUBMIT_JOB_SCHED,
  80. GEARMAN_COMMAND_SUBMIT_JOB_EPOCH,
  81. GEARMAN_COMMAND_SUBMIT_REDUCE_JOB, // C->J: FUNC[0]UNIQ[0]REDUCER[0]UNUSED[0]ARGS
  82. GEARMAN_COMMAND_SUBMIT_REDUCE_JOB_BACKGROUND, // C->J: FUNC[0]UNIQ[0]REDUCER[0]UNUSED[0]ARGS
  83. GEARMAN_COMMAND_GRAB_JOB_ALL, /* W->J -- */
  84. GEARMAN_COMMAND_JOB_ASSIGN_ALL, /* J->W: HANDLE[0]FUNC[0]UNIQ[0]REDUCER[0]ARGS */
  85. GEARMAN_COMMAND_GET_STATUS_UNIQUE, /* C->J: UNIQUE */
  86. GEARMAN_COMMAND_STATUS_RES_UNIQUE, /* J->C: UNIQUE[0]KNOWN[0]RUNNING[0]NUM[0]DENOM[0]CLIENT_COUNT */
  87. GEARMAN_COMMAND_MAX /* Always add new commands before this. */
  88. };
  89. #ifndef __cplusplus
  90. typedef enum gearman_command_t gearman_command_t;
  91. #endif