NCDModule.c 21 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722
  1. /**
  2. * @file NCDModule.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. #include <stdarg.h>
  30. #include <string.h>
  31. #include <stddef.h>
  32. #include <inttypes.h>
  33. #include <limits.h>
  34. #include <misc/string_begins_with.h>
  35. #include <misc/parse_number.h>
  36. #include <ncd/NCDModule.h>
  37. #define STATE_INIT 1
  38. #define STATE_UNINIT 2
  39. #define STATE_DEAD 3
  40. #define STATE_DOWN_CLEAN 4
  41. #define STATE_UP 5
  42. #define STATE_DOWN_UNCLEAN 6
  43. #define STATE_DOWN_PCLEAN 7
  44. #define STATE_DOWN_DIE 8
  45. #define STATE_UP_DIE 9
  46. #define STATE_DYING 10
  47. #define PROCESS_STATE_INIT 1
  48. #define PROCESS_STATE_DOWN 2
  49. #define PROCESS_STATE_UP_PENDING 3
  50. #define PROCESS_STATE_UP 4
  51. #define PROCESS_STATE_DOWN_PENDING 5
  52. #define PROCESS_STATE_DOWN_WAITING 6
  53. #define PROCESS_STATE_DOWN_CONTINUE_PENDING 7
  54. #define PROCESS_STATE_TERMINATING 8
  55. #define PROCESS_STATE_TERMINATED_PENDING 9
  56. #define PROCESS_STATE_TERMINATED 10
  57. static int object_func_getvar (NCDModuleInst *n, const char *name, NCDValMem *mem, NCDValRef *out_value);
  58. static int object_func_getobj (NCDModuleInst *n, const char *name, NCDObject *out_object);
  59. static int process_args_object_func_getvar (NCDModuleProcess *o, const char *name, NCDValMem *mem, NCDValRef *out_value);
  60. static int process_arg_object_func_getvar2 (NCDModuleProcess *o, void *n_ptr, const char *name, NCDValMem *mem, NCDValRef *out_value);
  61. static void frontend_event (NCDModuleInst *n, int event)
  62. {
  63. n->params->func_event(n->user, event);
  64. }
  65. static void job_handler (NCDModuleInst *n)
  66. {
  67. DebugObject_Access(&n->d_obj);
  68. switch (n->state) {
  69. case STATE_INIT: {
  70. n->state = STATE_DOWN_CLEAN;
  71. if (n->m->func_new2) {
  72. n->m->func_new2(n->inst_user, n);
  73. } else {
  74. n->m->func_new(n);
  75. }
  76. return;
  77. } break;
  78. case STATE_UNINIT: {
  79. n->state = STATE_DEAD;
  80. frontend_event(n, NCDMODULE_EVENT_DEAD);
  81. return;
  82. } break;
  83. case STATE_DOWN_DIE:
  84. case STATE_UP_DIE: {
  85. n->state = STATE_DYING;
  86. if (!n->m->func_die) {
  87. NCDModuleInst_Backend_Dead(n);
  88. return;
  89. }
  90. n->m->func_die(n->inst_user);
  91. return;
  92. } break;
  93. case STATE_DOWN_PCLEAN: {
  94. n->state = STATE_DOWN_CLEAN;
  95. if (n->m->func_clean) {
  96. n->m->func_clean(n->inst_user);
  97. return;
  98. }
  99. } break;
  100. default: ASSERT(0);
  101. }
  102. }
  103. static void process_event_job_handler (NCDModuleProcess *o)
  104. {
  105. DebugObject_Access(&o->d_obj);
  106. switch (o->state) {
  107. case PROCESS_STATE_DOWN_CONTINUE_PENDING: {
  108. o->state = PROCESS_STATE_DOWN;
  109. o->interp_func_event(o->interp_user, NCDMODULEPROCESS_INTERP_EVENT_CONTINUE);
  110. } break;
  111. case PROCESS_STATE_UP_PENDING: {
  112. o->state = PROCESS_STATE_UP;
  113. o->handler_event(o->user, NCDMODULEPROCESS_EVENT_UP);
  114. return;
  115. } break;
  116. case PROCESS_STATE_DOWN_PENDING: {
  117. o->state = PROCESS_STATE_DOWN_WAITING;
  118. o->handler_event(o->user, NCDMODULEPROCESS_EVENT_DOWN);
  119. return;
  120. } break;
  121. case PROCESS_STATE_TERMINATED_PENDING: {
  122. o->state = PROCESS_STATE_TERMINATED;
  123. o->handler_event(o->user, NCDMODULEPROCESS_EVENT_TERMINATED);
  124. return;
  125. } break;
  126. default: ASSERT(0);
  127. }
  128. }
  129. static void inst_assert_backend (NCDModuleInst *n)
  130. {
  131. ASSERT(n->state == STATE_DOWN_PCLEAN || n->state == STATE_DOWN_UNCLEAN || n->state == STATE_DOWN_CLEAN ||
  132. n->state == STATE_UP || n->state == STATE_DOWN_DIE || n->state == STATE_UP_DIE ||
  133. n->state == STATE_DYING)
  134. }
  135. void NCDModuleInst_Init (NCDModuleInst *n, const struct NCDModule *m, void *mem, const NCDObject *method_object, NCDValRef args, void *user, const struct NCDModuleInst_params *params, const struct NCDModuleInst_iparams *iparams)
  136. {
  137. ASSERT(m)
  138. ASSERT(m->alloc_size >= 0)
  139. ASSERT(!!mem == m->alloc_size > 0)
  140. ASSERT(NCDVal_IsList(args))
  141. ASSERT(params)
  142. ASSERT(params->func_event)
  143. ASSERT(params->func_getobj)
  144. ASSERT(params->logfunc)
  145. ASSERT(iparams)
  146. ASSERT(iparams->func_initprocess)
  147. ASSERT(iparams->func_interp_exit)
  148. ASSERT(iparams->func_interp_getargs)
  149. ASSERT(iparams->func_interp_getretrytime)
  150. // init arguments
  151. n->m = m;
  152. n->method_user = (method_object ? method_object->user : NULL);
  153. n->args = args;
  154. n->user = user;
  155. n->params = params;
  156. n->iparams = iparams;
  157. // set initial instance argument
  158. n->inst_user = mem;
  159. // init job
  160. BPending_Init(&n->job, BReactor_PendingGroup(iparams->reactor), (BPending_handler)job_handler, n);
  161. BPending_Set(&n->job);
  162. // set initial state
  163. n->state = STATE_INIT;
  164. // clear error flag
  165. n->is_error = 0;
  166. DebugObject_Init(&n->d_obj);
  167. }
  168. void NCDModuleInst_Free (NCDModuleInst *n)
  169. {
  170. DebugObject_Free(&n->d_obj);
  171. ASSERT(n->state == STATE_DEAD)
  172. // free jobs
  173. BPending_Free(&n->job);
  174. }
  175. void NCDModuleInst_Die (NCDModuleInst *n)
  176. {
  177. DebugObject_Access(&n->d_obj);
  178. switch (n->state) {
  179. case STATE_INIT: {
  180. n->state = STATE_UNINIT;
  181. BPending_Set(&n->job);
  182. } break;
  183. case STATE_DOWN_CLEAN:
  184. case STATE_DOWN_UNCLEAN: {
  185. n->state = STATE_DOWN_DIE;
  186. BPending_Set(&n->job);
  187. } break;
  188. case STATE_DOWN_PCLEAN: {
  189. n->state = STATE_DOWN_DIE;
  190. BPending_Set(&n->job);
  191. } break;
  192. case STATE_UP: {
  193. n->state = STATE_UP_DIE;
  194. BPending_Set(&n->job);
  195. } break;
  196. default: ASSERT(0);
  197. }
  198. }
  199. void NCDModuleInst_Clean (NCDModuleInst *n)
  200. {
  201. DebugObject_Access(&n->d_obj);
  202. switch (n->state) {
  203. case STATE_INIT:
  204. case STATE_DOWN_CLEAN:
  205. case STATE_DOWN_PCLEAN: {
  206. } break;
  207. case STATE_DOWN_UNCLEAN: {
  208. n->state = STATE_DOWN_PCLEAN;
  209. BPending_Set(&n->job);
  210. } break;
  211. default: ASSERT(0);
  212. }
  213. }
  214. NCDObject NCDModuleInst_Object (NCDModuleInst *n)
  215. {
  216. DebugObject_Access(&n->d_obj);
  217. const char *type = (n->m->base_type ? n->m->base_type : n->m->type);
  218. return NCDObject_Build(type, n, (NCDObject_func_getvar)object_func_getvar, (NCDObject_func_getobj)object_func_getobj);
  219. }
  220. static int can_resolve (NCDModuleInst *n)
  221. {
  222. switch (n->state) {
  223. case STATE_UP:
  224. case STATE_UP_DIE:
  225. return 1;
  226. case STATE_DOWN_CLEAN:
  227. case STATE_DOWN_UNCLEAN:
  228. case STATE_DOWN_PCLEAN:
  229. case STATE_DOWN_DIE:
  230. return !!(n->m->flags & NCDMODULE_FLAG_CAN_RESOLVE_WHEN_DOWN);
  231. default:
  232. return 0;
  233. }
  234. }
  235. static int object_func_getvar (NCDModuleInst *n, const char *name, NCDValMem *mem, NCDValRef *out_value)
  236. {
  237. DebugObject_Access(&n->d_obj);
  238. if (!n->m->func_getvar || !can_resolve(n)) {
  239. return 0;
  240. }
  241. int res = n->m->func_getvar(n->inst_user, name, mem, out_value);
  242. ASSERT(res == 0 || res == 1)
  243. ASSERT(res == 0 || (NCDVal_Assert(*out_value), 1))
  244. return res;
  245. }
  246. static int object_func_getobj (NCDModuleInst *n, const char *name, NCDObject *out_object)
  247. {
  248. DebugObject_Access(&n->d_obj);
  249. if (!n->m->func_getobj || !can_resolve(n)) {
  250. return 0;
  251. }
  252. int res = n->m->func_getobj(n->inst_user, name, out_object);
  253. ASSERT(res == 0 || res == 1)
  254. return res;
  255. }
  256. int NCDModuleInst_HaveError (NCDModuleInst *n)
  257. {
  258. DebugObject_Access(&n->d_obj);
  259. ASSERT(n->state == STATE_DEAD)
  260. return n->is_error;
  261. }
  262. void NCDModuleInst_Backend_SetUser (NCDModuleInst *n, void *user)
  263. {
  264. DebugObject_Access(&n->d_obj);
  265. ASSERT(n->state == STATE_DOWN_PCLEAN || n->state == STATE_DOWN_UNCLEAN || n->state == STATE_DOWN_CLEAN ||
  266. n->state == STATE_UP || n->state == STATE_DOWN_DIE || n->state == STATE_UP_DIE ||
  267. n->state == STATE_DYING)
  268. n->inst_user = user;
  269. }
  270. void * NCDModuleInst_Backend_GetUser (NCDModuleInst *n)
  271. {
  272. DebugObject_Access(&n->d_obj);
  273. ASSERT(n->state == STATE_DOWN_PCLEAN || n->state == STATE_DOWN_UNCLEAN || n->state == STATE_DOWN_CLEAN ||
  274. n->state == STATE_UP || n->state == STATE_DOWN_DIE || n->state == STATE_UP_DIE ||
  275. n->state == STATE_DYING)
  276. return n->inst_user;
  277. }
  278. void NCDModuleInst_Backend_Up (NCDModuleInst *n)
  279. {
  280. DebugObject_Access(&n->d_obj);
  281. switch (n->state) {
  282. case STATE_DOWN_CLEAN:
  283. case STATE_DOWN_UNCLEAN: {
  284. n->state = STATE_UP;
  285. frontend_event(n, NCDMODULE_EVENT_UP);
  286. } break;
  287. case STATE_DOWN_PCLEAN: {
  288. n->state = STATE_UP;
  289. BPending_Unset(&n->job);
  290. frontend_event(n, NCDMODULE_EVENT_UP);
  291. } break;
  292. case STATE_DOWN_DIE: {
  293. n->state = STATE_UP_DIE;
  294. } break;
  295. default: ASSERT(0);
  296. }
  297. }
  298. void NCDModuleInst_Backend_Down (NCDModuleInst *n)
  299. {
  300. DebugObject_Access(&n->d_obj);
  301. switch (n->state) {
  302. case STATE_UP: {
  303. n->state = STATE_DOWN_UNCLEAN;
  304. frontend_event(n, NCDMODULE_EVENT_DOWN);
  305. } break;
  306. case STATE_UP_DIE: {
  307. n->state = STATE_DOWN_DIE;
  308. } break;
  309. default: ASSERT(0);
  310. }
  311. }
  312. void NCDModuleInst_Backend_Dead (NCDModuleInst *n)
  313. {
  314. DebugObject_Access(&n->d_obj);
  315. switch (n->state) {
  316. case STATE_DOWN_DIE:
  317. case STATE_UP_DIE: {
  318. n->state = STATE_DEAD;
  319. BPending_Unset(&n->job);
  320. } break;
  321. case STATE_DOWN_CLEAN:
  322. case STATE_DOWN_UNCLEAN:
  323. case STATE_UP:
  324. case STATE_DYING: {
  325. n->state = STATE_DEAD;
  326. } break;
  327. case STATE_DOWN_PCLEAN: {
  328. n->state = STATE_DEAD;
  329. BPending_Unset(&n->job);
  330. } break;
  331. default: ASSERT(0);
  332. }
  333. frontend_event(n, NCDMODULE_EVENT_DEAD);
  334. return;
  335. }
  336. int NCDModuleInst_Backend_GetObj (NCDModuleInst *n, const char *name, NCDObject *out_object)
  337. {
  338. DebugObject_Access(&n->d_obj);
  339. ASSERT(n->state == STATE_DOWN_PCLEAN || n->state == STATE_DOWN_UNCLEAN || n->state == STATE_DOWN_CLEAN ||
  340. n->state == STATE_UP || n->state == STATE_DOWN_DIE || n->state == STATE_UP_DIE ||
  341. n->state == STATE_DYING)
  342. ASSERT(name)
  343. ASSERT(out_object)
  344. int res = n->params->func_getobj(n->user, name, out_object);
  345. ASSERT(res == 0 || res == 1)
  346. return res;
  347. }
  348. void NCDModuleInst_Backend_Log (NCDModuleInst *n, int channel, int level, const char *fmt, ...)
  349. {
  350. DebugObject_Access(&n->d_obj);
  351. va_list vl;
  352. va_start(vl, fmt);
  353. BLog_LogViaFuncVarArg(n->params->logfunc, n->user, channel, level, fmt, vl);
  354. va_end(vl);
  355. }
  356. void NCDModuleInst_Backend_SetError (NCDModuleInst *n)
  357. {
  358. DebugObject_Access(&n->d_obj);
  359. ASSERT(n->state == STATE_DOWN_PCLEAN || n->state == STATE_DOWN_UNCLEAN || n->state == STATE_DOWN_CLEAN ||
  360. n->state == STATE_UP || n->state == STATE_DOWN_DIE || n->state == STATE_UP_DIE ||
  361. n->state == STATE_DYING)
  362. ASSERT(!n->is_error)
  363. n->is_error = 1;
  364. }
  365. void NCDModuleInst_Backend_InterpExit (NCDModuleInst *n, int exit_code)
  366. {
  367. DebugObject_Access(&n->d_obj);
  368. inst_assert_backend(n);
  369. n->iparams->func_interp_exit(n->user, exit_code);
  370. }
  371. int NCDModuleInst_Backend_InterpGetArgs (NCDModuleInst *n, NCDValMem *mem, NCDValRef *out_value)
  372. {
  373. DebugObject_Access(&n->d_obj);
  374. inst_assert_backend(n);
  375. ASSERT(mem)
  376. ASSERT(out_value)
  377. int res = n->iparams->func_interp_getargs(n->user, mem, out_value);
  378. ASSERT(res == 0 || res == 1)
  379. ASSERT(res == 0 || (NCDVal_Assert(*out_value), 1))
  380. return res;
  381. }
  382. btime_t NCDModuleInst_Backend_InterpGetRetryTime (NCDModuleInst *n)
  383. {
  384. DebugObject_Access(&n->d_obj);
  385. inst_assert_backend(n);
  386. return n->iparams->func_interp_getretrytime(n->user);
  387. }
  388. int NCDModuleProcess_Init (NCDModuleProcess *o, NCDModuleInst *n, const char *template_name, NCDValRef args, void *user, NCDModuleProcess_handler_event handler_event)
  389. {
  390. DebugObject_Access(&n->d_obj);
  391. ASSERT(n->state == STATE_DOWN_PCLEAN || n->state == STATE_DOWN_UNCLEAN || n->state == STATE_DOWN_CLEAN ||
  392. n->state == STATE_UP || n->state == STATE_DOWN_DIE || n->state == STATE_UP_DIE ||
  393. n->state == STATE_DYING)
  394. ASSERT(template_name)
  395. ASSERT(NCDVal_IsInvalid(args) || NCDVal_IsList(args))
  396. ASSERT(handler_event)
  397. // init arguments
  398. o->args = args;
  399. o->user = user;
  400. o->handler_event = handler_event;
  401. // set no special functions
  402. o->func_getspecialobj = NULL;
  403. // init event job
  404. BPending_Init(&o->event_job, BReactor_PendingGroup(n->iparams->reactor), (BPending_handler)process_event_job_handler, o);
  405. // set state
  406. o->state = PROCESS_STATE_INIT;
  407. // clear interp functions so we can assert they were set
  408. o->interp_func_event = NULL;
  409. o->interp_func_getobj = NULL;
  410. // init interpreter part
  411. if (!(n->iparams->func_initprocess(n->user, o, template_name))) {
  412. goto fail1;
  413. }
  414. ASSERT(o->interp_func_event)
  415. ASSERT(o->interp_func_getobj)
  416. // set state
  417. o->state = PROCESS_STATE_DOWN;
  418. DebugObject_Init(&o->d_obj);
  419. return 1;
  420. fail1:
  421. BPending_Free(&o->event_job);
  422. return 0;
  423. }
  424. void NCDModuleProcess_Free (NCDModuleProcess *o)
  425. {
  426. DebugObject_Free(&o->d_obj);
  427. ASSERT(o->state == PROCESS_STATE_TERMINATED)
  428. // free event job
  429. BPending_Free(&o->event_job);
  430. }
  431. void NCDModuleProcess_AssertFree (NCDModuleProcess *o)
  432. {
  433. DebugObject_Access(&o->d_obj);
  434. ASSERT(o->state == PROCESS_STATE_TERMINATED)
  435. }
  436. void NCDModuleProcess_SetSpecialFuncs (NCDModuleProcess *o, NCDModuleProcess_func_getspecialobj func_getspecialobj)
  437. {
  438. DebugObject_Access(&o->d_obj);
  439. o->func_getspecialobj = func_getspecialobj;
  440. }
  441. void NCDModuleProcess_Continue (NCDModuleProcess *o)
  442. {
  443. DebugObject_Access(&o->d_obj);
  444. ASSERT(o->state == PROCESS_STATE_DOWN_WAITING)
  445. o->state = PROCESS_STATE_DOWN;
  446. o->interp_func_event(o->interp_user, NCDMODULEPROCESS_INTERP_EVENT_CONTINUE);
  447. }
  448. void NCDModuleProcess_Terminate (NCDModuleProcess *o)
  449. {
  450. DebugObject_Access(&o->d_obj);
  451. ASSERT(o->state == PROCESS_STATE_DOWN || o->state == PROCESS_STATE_UP_PENDING ||
  452. o->state == PROCESS_STATE_DOWN_CONTINUE_PENDING || o->state == PROCESS_STATE_UP ||
  453. o->state == PROCESS_STATE_DOWN_PENDING || o->state == PROCESS_STATE_DOWN_WAITING)
  454. BPending_Unset(&o->event_job);
  455. o->state = PROCESS_STATE_TERMINATING;
  456. o->interp_func_event(o->interp_user, NCDMODULEPROCESS_INTERP_EVENT_TERMINATE);
  457. }
  458. int NCDModuleProcess_GetObj (NCDModuleProcess *o, const char *name, NCDObject *out_object)
  459. {
  460. DebugObject_Access(&o->d_obj);
  461. ASSERT(o->state != PROCESS_STATE_INIT)
  462. ASSERT(name)
  463. ASSERT(out_object)
  464. // interpreter gone?
  465. if (o->state == PROCESS_STATE_TERMINATED_PENDING || o->state == PROCESS_STATE_TERMINATED) {
  466. return 0;
  467. }
  468. int res = o->interp_func_getobj(o->interp_user, name, out_object);
  469. ASSERT(res == 0 || res == 1)
  470. return res;
  471. }
  472. static void process_assert_interp (NCDModuleProcess *o)
  473. {
  474. // assert that the interpreter knows about the object, and we're not in init
  475. ASSERT(o->state == PROCESS_STATE_DOWN || o->state == PROCESS_STATE_UP_PENDING ||
  476. o->state == PROCESS_STATE_DOWN_CONTINUE_PENDING || o->state == PROCESS_STATE_UP ||
  477. o->state == PROCESS_STATE_DOWN_PENDING || o->state == PROCESS_STATE_DOWN_WAITING ||
  478. o->state == PROCESS_STATE_TERMINATING)
  479. }
  480. void NCDModuleProcess_Interp_SetHandlers (NCDModuleProcess *o, void *interp_user,
  481. NCDModuleProcess_interp_func_event interp_func_event,
  482. NCDModuleProcess_interp_func_getobj interp_func_getobj)
  483. {
  484. ASSERT(o->state == PROCESS_STATE_INIT)
  485. ASSERT(interp_func_event)
  486. ASSERT(interp_func_getobj)
  487. o->interp_user = interp_user;
  488. o->interp_func_event = interp_func_event;
  489. o->interp_func_getobj = interp_func_getobj;
  490. }
  491. void NCDModuleProcess_Interp_Up (NCDModuleProcess *o)
  492. {
  493. DebugObject_Access(&o->d_obj);
  494. process_assert_interp(o);
  495. ASSERT(o->state == PROCESS_STATE_DOWN)
  496. BPending_Set(&o->event_job);
  497. o->state = PROCESS_STATE_UP_PENDING;
  498. }
  499. void NCDModuleProcess_Interp_Down (NCDModuleProcess *o)
  500. {
  501. DebugObject_Access(&o->d_obj);
  502. process_assert_interp(o);
  503. switch (o->state) {
  504. case PROCESS_STATE_UP_PENDING: {
  505. BPending_Unset(&o->event_job);
  506. BPending_Set(&o->event_job);
  507. o->state = PROCESS_STATE_DOWN_CONTINUE_PENDING;
  508. } break;
  509. case PROCESS_STATE_UP: {
  510. BPending_Set(&o->event_job);
  511. o->state = PROCESS_STATE_DOWN_PENDING;
  512. } break;
  513. default: ASSERT(0);
  514. }
  515. }
  516. void NCDModuleProcess_Interp_Terminated (NCDModuleProcess *o)
  517. {
  518. DebugObject_Access(&o->d_obj);
  519. process_assert_interp(o);
  520. ASSERT(o->state == PROCESS_STATE_TERMINATING)
  521. BPending_Set(&o->event_job);
  522. o->state = PROCESS_STATE_TERMINATED_PENDING;
  523. }
  524. int NCDModuleProcess_Interp_GetSpecialObj (NCDModuleProcess *o, const char *name, NCDObject *out_object)
  525. {
  526. DebugObject_Access(&o->d_obj);
  527. process_assert_interp(o);
  528. ASSERT(name)
  529. ASSERT(out_object)
  530. if (!NCDVal_IsInvalid(o->args)) {
  531. if (!strcmp(name, "_args")) {
  532. *out_object = NCDObject_Build(NULL, o, (NCDObject_func_getvar)process_args_object_func_getvar, NULL);
  533. return 1;
  534. }
  535. size_t len;
  536. uintmax_t n;
  537. if ((len = string_begins_with(name, "_arg")) && parse_unsigned_integer(name + len, &n) && n < NCDVal_ListCount(o->args) && n < UINTPTR_MAX) {
  538. *out_object = NCDObject_Build2(NULL, o, (void *)((uintptr_t)(n + 1)), (NCDObject_func_getvar2)process_arg_object_func_getvar2, NULL);
  539. return 1;
  540. }
  541. }
  542. if (!o->func_getspecialobj) {
  543. return 0;
  544. }
  545. int res = o->func_getspecialobj(o->user, name, out_object);
  546. ASSERT(res == 0 || res == 1)
  547. return res;
  548. }
  549. static int process_args_object_func_getvar (NCDModuleProcess *o, const char *name, NCDValMem *mem, NCDValRef *out_value)
  550. {
  551. DebugObject_Access(&o->d_obj);
  552. process_assert_interp(o);
  553. ASSERT(!NCDVal_IsInvalid(o->args))
  554. if (strcmp(name, "")) {
  555. return 0;
  556. }
  557. *out_value = NCDVal_NewCopy(mem, o->args);
  558. if (NCDVal_IsInvalid(*out_value)) {
  559. BLog_LogToChannel(BLOG_CHANNEL_NCDModuleProcess, BLOG_ERROR, "NCDVal_NewCopy failed");
  560. }
  561. return 1;
  562. }
  563. static int process_arg_object_func_getvar2 (NCDModuleProcess *o, void *n_ptr, const char *name, NCDValMem *mem, NCDValRef *out_value)
  564. {
  565. DebugObject_Access(&o->d_obj);
  566. process_assert_interp(o);
  567. ASSERT(!NCDVal_IsInvalid(o->args))
  568. if (strcmp(name, "")) {
  569. return 0;
  570. }
  571. uintmax_t n = (uintmax_t)n_ptr - 1;
  572. *out_value = NCDVal_NewCopy(mem, NCDVal_ListGet(o->args, n));
  573. if (NCDVal_IsInvalid(*out_value)) {
  574. BLog_LogToChannel(BLOG_CHANNEL_NCDModuleProcess, BLOG_ERROR, "NCDVal_NewCopy failed");
  575. }
  576. return 1;
  577. }