process_manager.c 18 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602
  1. /**
  2. * @file process_manager.c
  3. * @author Ambroz Bizjak <ambrop7@gmail.com>
  4. *
  5. * @section LICENSE
  6. *
  7. * Redistribution and use in source and binary forms, with or without
  8. * modification, are permitted provided that the following conditions are met:
  9. * 1. Redistributions of source code must retain the above copyright
  10. * notice, this list of conditions and the following disclaimer.
  11. * 2. Redistributions in binary form must reproduce the above copyright
  12. * notice, this list of conditions and the following disclaimer in the
  13. * documentation and/or other materials provided with the distribution.
  14. * 3. Neither the name of the author nor the
  15. * names of its contributors may be used to endorse or promote products
  16. * derived from this software without specific prior written permission.
  17. *
  18. * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS" AND
  19. * ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED
  20. * WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE
  21. * DISCLAIMED. IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR ANY
  22. * DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES
  23. * (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES;
  24. * LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND
  25. * ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT
  26. * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS
  27. * SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
  28. *
  29. * @section DESCRIPTION
  30. *
  31. * Module which allows starting and stopping processes from templates dynamically.
  32. *
  33. * Synopsis: process_manager()
  34. * Description: manages processes. On deinitialization, initiates termination of all
  35. * contained processes and waits for them to terminate.
  36. *
  37. * Synopsis: process_manager::start(string name, string template_name, list args)
  38. * Description: creates a new process from the template named template_name, with arguments args,
  39. * identified by name within the process manager. If a process with this name already exists
  40. * and is not being terminated, does nothing. If it is being terminated, it will be restarted
  41. * using the given parameters after it terminates.
  42. * The process can access objects as seen from the process_manager() statement via _caller.
  43. *
  44. * Synopsis: process_manager::stop(string name)
  45. * Description: initiates termination of the process identified by name within the process manager.
  46. * If there is no such process, or the process is already being terminated, does nothing.
  47. */
  48. #include <stdlib.h>
  49. #include <string.h>
  50. #include <misc/offset.h>
  51. #include <misc/debug.h>
  52. #include <misc/strdup.h>
  53. #include <structure/LinkedList1.h>
  54. #include <ncd/NCDModule.h>
  55. #include <ncd/extra/value_utils.h>
  56. #include <generated/blog_channel_ncd_process_manager.h>
  57. #define ModuleLog(i, ...) NCDModuleInst_Backend_Log((i), BLOG_CURRENT_CHANNEL, __VA_ARGS__)
  58. #define RETRY_TIME 10000
  59. #define PROCESS_STATE_RUNNING 1
  60. #define PROCESS_STATE_STOPPING 2
  61. #define PROCESS_STATE_RESTARTING 3
  62. #define PROCESS_STATE_RETRYING 4
  63. struct instance {
  64. NCDModuleInst *i;
  65. LinkedList1 processes_list;
  66. int dying;
  67. };
  68. struct process {
  69. struct instance *manager;
  70. char *name;
  71. size_t name_len;
  72. BTimer retry_timer;
  73. LinkedList1Node processes_list_node;
  74. int have_params;
  75. NCD_string_id_t params_template_name;
  76. NCDValMem params_mem;
  77. NCDValRef params_args;
  78. int have_module_process;
  79. NCDValMem process_mem;
  80. NCDValRef process_args;
  81. NCDModuleProcess module_process;
  82. int state;
  83. };
  84. static struct process * find_process (struct instance *o, const char *name, size_t name_len);
  85. static int process_new (struct instance *o, const char *name, size_t name_len, NCDValRef template_name, NCDValRef args);
  86. static void process_free (struct process *p);
  87. static void process_retry_timer_handler (struct process *p);
  88. static void process_module_process_handler_event (NCDModuleProcess *process, int event);
  89. static int process_module_process_func_getspecialobj (NCDModuleProcess *process, NCD_string_id_t name, NCDObject *out_object);
  90. static int process_module_process_caller_obj_func_getobj (const NCDObject *obj, NCD_string_id_t name, NCDObject *out_object);
  91. static void process_stop (struct process *p);
  92. static int process_restart (struct process *p, NCDValRef template_name, NCDValRef args);
  93. static void process_try (struct process *p);
  94. static int process_set_params (struct process *p, NCDValRef template_name, NCDValMem mem, NCDValSafeRef args);
  95. static void instance_free (struct instance *o);
  96. enum {STRING_CALLER};
  97. static struct NCD_string_request strings[] = {
  98. {"_caller"}, {NULL}
  99. };
  100. struct process * find_process (struct instance *o, const char *name, size_t name_len)
  101. {
  102. LinkedList1Node *n = LinkedList1_GetFirst(&o->processes_list);
  103. while (n) {
  104. struct process *p = UPPER_OBJECT(n, struct process, processes_list_node);
  105. if (p->name_len == name_len && !memcmp(p->name, name, name_len)) {
  106. return p;
  107. }
  108. n = LinkedList1Node_Next(n);
  109. }
  110. return NULL;
  111. }
  112. int process_new (struct instance *o, const char *name, size_t name_len, NCDValRef template_name, NCDValRef args)
  113. {
  114. ASSERT(!o->dying)
  115. ASSERT(!find_process(o, name, name_len))
  116. ASSERT(NCDVal_IsString(template_name))
  117. ASSERT(NCDVal_IsList(args))
  118. // allocate structure
  119. struct process *p = malloc(sizeof(*p));
  120. if (!p) {
  121. ModuleLog(o->i, BLOG_ERROR, "malloc failed");
  122. goto fail0;
  123. }
  124. // set manager
  125. p->manager = o;
  126. // copy name
  127. if (!(p->name = b_strdup_bin(name, name_len))) {
  128. ModuleLog(o->i, BLOG_ERROR, "b_strdup_bin failed");
  129. goto fail1;
  130. }
  131. p->name_len = name_len;
  132. // init retry timer
  133. BTimer_Init(&p->retry_timer, RETRY_TIME, (BTimer_handler)process_retry_timer_handler, p);
  134. // insert to processes list
  135. LinkedList1_Append(&o->processes_list, &p->processes_list_node);
  136. // have no params
  137. p->have_params = 0;
  138. // have no module process
  139. p->have_module_process = 0;
  140. // copy arguments
  141. NCDValMem mem;
  142. NCDValMem_Init(&mem);
  143. NCDValRef args2 = NCDVal_NewCopy(&mem, args);
  144. if (NCDVal_IsInvalid(args2)) {
  145. ModuleLog(o->i, BLOG_ERROR, "NCDVal_NewCopy failed");
  146. goto fail2;
  147. }
  148. // set params
  149. if (!process_set_params(p, template_name, mem, NCDVal_ToSafe(args2))) {
  150. goto fail2;
  151. }
  152. // try starting it
  153. process_try(p);
  154. return 1;
  155. fail2:
  156. NCDValMem_Free(&mem);
  157. LinkedList1_Remove(&o->processes_list, &p->processes_list_node);
  158. free(p->name);
  159. fail1:
  160. free(p);
  161. fail0:
  162. return 0;
  163. }
  164. void process_free (struct process *p)
  165. {
  166. ASSERT(!p->have_module_process)
  167. struct instance *o = p->manager;
  168. // free params
  169. if (p->have_params) {
  170. NCDValMem_Free(&p->params_mem);
  171. }
  172. // remove from processes list
  173. LinkedList1_Remove(&o->processes_list, &p->processes_list_node);
  174. // free timer
  175. BReactor_RemoveTimer(o->i->params->iparams->reactor, &p->retry_timer);
  176. // free name
  177. free(p->name);
  178. // free structure
  179. free(p);
  180. }
  181. void process_retry_timer_handler (struct process *p)
  182. {
  183. struct instance *o = p->manager;
  184. B_USE(o)
  185. ASSERT(p->state == PROCESS_STATE_RETRYING)
  186. ASSERT(!o->dying)
  187. ASSERT(p->have_params)
  188. ASSERT(!p->have_module_process)
  189. // retry
  190. process_try(p);
  191. }
  192. void process_module_process_handler_event (NCDModuleProcess *process, int event)
  193. {
  194. struct process *p = UPPER_OBJECT(process, struct process, module_process);
  195. struct instance *o = p->manager;
  196. ASSERT(p->have_module_process)
  197. if (event == NCDMODULEPROCESS_EVENT_DOWN) {
  198. // allow process to continue
  199. NCDModuleProcess_Continue(&p->module_process);
  200. }
  201. if (event != NCDMODULEPROCESS_EVENT_TERMINATED) {
  202. return;
  203. }
  204. // free module process
  205. NCDModuleProcess_Free(&p->module_process);
  206. // free arguments mem
  207. NCDValMem_Free(&p->process_mem);
  208. // set no module process
  209. p->have_module_process = 0;
  210. switch (p->state) {
  211. case PROCESS_STATE_STOPPING: {
  212. // free process
  213. process_free(p);
  214. // if manager is dying and there are no more processes, let it die
  215. if (o->dying && LinkedList1_IsEmpty(&o->processes_list)) {
  216. instance_free(o);
  217. }
  218. return;
  219. } break;
  220. case PROCESS_STATE_RESTARTING: {
  221. ASSERT(!o->dying)
  222. ASSERT(p->have_params)
  223. // restart
  224. process_try(p);
  225. } break;
  226. default: ASSERT(0);
  227. }
  228. }
  229. int process_module_process_func_getspecialobj (NCDModuleProcess *process, NCD_string_id_t name, NCDObject *out_object)
  230. {
  231. struct process *p = UPPER_OBJECT(process, struct process, module_process);
  232. ASSERT(p->have_module_process)
  233. if (name == strings[STRING_CALLER].id) {
  234. *out_object = NCDObject_Build(-1, p, NCDObject_no_getvar, process_module_process_caller_obj_func_getobj);
  235. return 1;
  236. }
  237. return 0;
  238. }
  239. int process_module_process_caller_obj_func_getobj (const NCDObject *obj, NCD_string_id_t name, NCDObject *out_object)
  240. {
  241. struct process *p = NCDObject_DataPtr(obj);
  242. struct instance *o = p->manager;
  243. ASSERT(p->have_module_process)
  244. return NCDModuleInst_Backend_GetObj(o->i, name, out_object);
  245. }
  246. void process_stop (struct process *p)
  247. {
  248. switch (p->state) {
  249. case PROCESS_STATE_RETRYING: {
  250. ASSERT(!p->have_module_process)
  251. // free process
  252. process_free(p);
  253. return;
  254. } break;
  255. case PROCESS_STATE_RUNNING: {
  256. ASSERT(p->have_module_process)
  257. // request process to terminate
  258. NCDModuleProcess_Terminate(&p->module_process);
  259. // set state
  260. p->state = PROCESS_STATE_STOPPING;
  261. } break;
  262. case PROCESS_STATE_RESTARTING: {
  263. ASSERT(p->have_params)
  264. // free params
  265. NCDValMem_Free(&p->params_mem);
  266. p->have_params = 0;
  267. // set state
  268. p->state = PROCESS_STATE_STOPPING;
  269. } break;
  270. case PROCESS_STATE_STOPPING: {
  271. // nothing to do
  272. } break;
  273. default: ASSERT(0);
  274. }
  275. }
  276. int process_restart (struct process *p, NCDValRef template_name, NCDValRef args)
  277. {
  278. struct instance *o = p->manager;
  279. ASSERT(!o->dying)
  280. ASSERT(p->state == PROCESS_STATE_STOPPING)
  281. ASSERT(!p->have_params)
  282. ASSERT(NCDVal_IsString(template_name))
  283. ASSERT(NCDVal_IsList(args))
  284. // copy arguments
  285. NCDValMem mem;
  286. NCDValMem_Init(&mem);
  287. NCDValRef args2 = NCDVal_NewCopy(&mem, args);
  288. if (NCDVal_IsInvalid(args2)) {
  289. ModuleLog(o->i, BLOG_ERROR, "NCDVal_NewCopy failed");
  290. goto fail1;
  291. }
  292. // set params
  293. if (!process_set_params(p, template_name, mem, NCDVal_ToSafe(args2))) {
  294. goto fail1;
  295. }
  296. // set state
  297. p->state = PROCESS_STATE_RESTARTING;
  298. return 1;
  299. fail1:
  300. NCDValMem_Free(&mem);
  301. return 0;
  302. }
  303. void process_try (struct process *p)
  304. {
  305. struct instance *o = p->manager;
  306. ASSERT(!o->dying)
  307. ASSERT(p->have_params)
  308. ASSERT(!p->have_module_process)
  309. ModuleLog(o->i, BLOG_INFO, "trying process");
  310. // move params
  311. p->process_mem = p->params_mem;
  312. p->process_args = NCDVal_Moved(&p->process_mem, p->params_args);
  313. // init module process
  314. if (!NCDModuleProcess_InitId(&p->module_process, o->i, p->params_template_name, p->process_args, process_module_process_handler_event)) {
  315. ModuleLog(o->i, BLOG_ERROR, "NCDModuleProcess_Init failed");
  316. // set timer
  317. BReactor_SetTimer(o->i->params->iparams->reactor, &p->retry_timer);
  318. // set state
  319. p->state = PROCESS_STATE_RETRYING;
  320. return;
  321. }
  322. // set special objects function
  323. NCDModuleProcess_SetSpecialFuncs(&p->module_process, process_module_process_func_getspecialobj);
  324. // free params
  325. p->have_params = 0;
  326. // set have module process
  327. p->have_module_process = 1;
  328. // set state
  329. p->state = PROCESS_STATE_RUNNING;
  330. }
  331. int process_set_params (struct process *p, NCDValRef template_name, NCDValMem mem, NCDValSafeRef args)
  332. {
  333. ASSERT(!p->have_params)
  334. ASSERT(NCDVal_IsString(template_name))
  335. ASSERT(NCDVal_IsList(NCDVal_FromSafe(&mem, args)))
  336. // get string ID for template name
  337. p->params_template_name = ncd_get_string_id(template_name, p->manager->i->params->iparams->string_index);
  338. if (p->params_template_name < 0) {
  339. ModuleLog(p->manager->i, BLOG_ERROR, "ncd_get_string_id failed");
  340. return 0;
  341. }
  342. // eat arguments
  343. p->params_mem = mem;
  344. p->params_args = NCDVal_FromSafe(&p->params_mem, args);
  345. // set have params
  346. p->have_params = 1;
  347. return 1;
  348. }
  349. static void func_new (void *vo, NCDModuleInst *i, const struct NCDModuleInst_new_params *params)
  350. {
  351. struct instance *o = vo;
  352. o->i = i;
  353. // check arguments
  354. if (!NCDVal_ListRead(params->args, 0)) {
  355. ModuleLog(o->i, BLOG_ERROR, "wrong arity");
  356. goto fail0;
  357. }
  358. // init processes list
  359. LinkedList1_Init(&o->processes_list);
  360. // set not dying
  361. o->dying = 0;
  362. // signal up
  363. NCDModuleInst_Backend_Up(o->i);
  364. return;
  365. fail0:
  366. NCDModuleInst_Backend_SetError(i);
  367. NCDModuleInst_Backend_Dead(i);
  368. }
  369. void instance_free (struct instance *o)
  370. {
  371. ASSERT(LinkedList1_IsEmpty(&o->processes_list))
  372. NCDModuleInst_Backend_Dead(o->i);
  373. }
  374. static void func_die (void *vo)
  375. {
  376. struct instance *o = vo;
  377. ASSERT(!o->dying)
  378. // request all processes to die
  379. LinkedList1Node *n = LinkedList1_GetFirst(&o->processes_list);
  380. while (n) {
  381. LinkedList1Node *next = LinkedList1Node_Next(n);
  382. struct process *p = UPPER_OBJECT(n, struct process, processes_list_node);
  383. process_stop(p);
  384. n = next;
  385. }
  386. // if there are no processes, die immediately
  387. if (LinkedList1_IsEmpty(&o->processes_list)) {
  388. instance_free(o);
  389. return;
  390. }
  391. // set dying
  392. o->dying = 1;
  393. }
  394. static void start_func_new (void *unused, NCDModuleInst *i, const struct NCDModuleInst_new_params *params)
  395. {
  396. // check arguments
  397. NCDValRef name_arg;
  398. NCDValRef template_name_arg;
  399. NCDValRef args_arg;
  400. if (!NCDVal_ListRead(params->args, 3, &name_arg, &template_name_arg, &args_arg)) {
  401. ModuleLog(i, BLOG_ERROR, "wrong arity");
  402. goto fail0;
  403. }
  404. if (!NCDVal_IsString(name_arg) || !NCDVal_IsString(template_name_arg) ||
  405. !NCDVal_IsList(args_arg)) {
  406. ModuleLog(i, BLOG_ERROR, "wrong type");
  407. goto fail0;
  408. }
  409. const char *name = NCDVal_StringData(name_arg);
  410. size_t name_len = NCDVal_StringLength(name_arg);
  411. // signal up.
  412. // Do it before creating the process so that the process starts initializing before our own process continues.
  413. NCDModuleInst_Backend_Up(i);
  414. // get method object
  415. struct instance *mo = NCDModuleInst_Backend_GetUser((NCDModuleInst *)params->method_user);
  416. if (mo->dying) {
  417. ModuleLog(i, BLOG_INFO, "manager is dying, not creating process");
  418. } else {
  419. struct process *p = find_process(mo, name, name_len);
  420. if (p && p->state != PROCESS_STATE_STOPPING) {
  421. ModuleLog(i, BLOG_INFO, "process already started");
  422. } else {
  423. if (p) {
  424. if (!process_restart(p, template_name_arg, args_arg)) {
  425. ModuleLog(i, BLOG_ERROR, "failed to restart process");
  426. goto fail0;
  427. }
  428. } else {
  429. if (!process_new(mo, name, name_len, template_name_arg, args_arg)) {
  430. ModuleLog(i, BLOG_ERROR, "failed to create process");
  431. goto fail0;
  432. }
  433. }
  434. }
  435. }
  436. return;
  437. fail0:
  438. NCDModuleInst_Backend_SetError(i);
  439. NCDModuleInst_Backend_Dead(i);
  440. }
  441. static void stop_func_new (void *unused, NCDModuleInst *i, const struct NCDModuleInst_new_params *params)
  442. {
  443. // check arguments
  444. NCDValRef name_arg;
  445. if (!NCDVal_ListRead(params->args, 1, &name_arg)) {
  446. ModuleLog(i, BLOG_ERROR, "wrong arity");
  447. goto fail0;
  448. }
  449. if (!NCDVal_IsString(name_arg)) {
  450. ModuleLog(i, BLOG_ERROR, "wrong type");
  451. goto fail0;
  452. }
  453. const char *name = NCDVal_StringData(name_arg);
  454. size_t name_len = NCDVal_StringLength(name_arg);
  455. // signal up.
  456. // Do it before stopping the process so that the process starts terminating before our own process continues.
  457. NCDModuleInst_Backend_Up(i);
  458. // get method object
  459. struct instance *mo = NCDModuleInst_Backend_GetUser((NCDModuleInst *)params->method_user);
  460. if (mo->dying) {
  461. ModuleLog(i, BLOG_INFO, "manager is dying, not stopping process");
  462. } else {
  463. struct process *p = find_process(mo, name, name_len);
  464. if (!(p && p->state != PROCESS_STATE_STOPPING)) {
  465. ModuleLog(i, BLOG_INFO, "process already stopped");
  466. } else {
  467. process_stop(p);
  468. }
  469. }
  470. return;
  471. fail0:
  472. NCDModuleInst_Backend_SetError(i);
  473. NCDModuleInst_Backend_Dead(i);
  474. }
  475. static struct NCDModule modules[] = {
  476. {
  477. .type = "process_manager",
  478. .func_new2 = func_new,
  479. .func_die = func_die,
  480. .alloc_size = sizeof(struct instance)
  481. }, {
  482. .type = "process_manager::start",
  483. .func_new2 = start_func_new
  484. }, {
  485. .type = "process_manager::stop",
  486. .func_new2 = stop_func_new
  487. }, {
  488. .type = NULL
  489. }
  490. };
  491. const struct NCDModuleGroup ncdmodule_process_manager = {
  492. .modules = modules,
  493. .strings = strings
  494. };