NCDModule.c 20 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710
  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 <misc/string_begins_with.h>
  33. #include <misc/parse_number.h>
  34. #include <ncd/NCDModule.h>
  35. #define STATE_INIT 1
  36. #define STATE_UNINIT 2
  37. #define STATE_DEAD 3
  38. #define STATE_DOWN_CLEAN 4
  39. #define STATE_UP 5
  40. #define STATE_DOWN_UNCLEAN 6
  41. #define STATE_DOWN_PCLEAN 7
  42. #define STATE_DOWN_DIE 8
  43. #define STATE_UP_DIE 9
  44. #define STATE_DYING 10
  45. #define STATE_UNDEAD 11
  46. #define PROCESS_STATE_INIT 1
  47. #define PROCESS_STATE_DOWN 2
  48. #define PROCESS_STATE_UP_PENDING 3
  49. #define PROCESS_STATE_UP 4
  50. #define PROCESS_STATE_DOWN_PENDING 5
  51. #define PROCESS_STATE_DOWN_WAITING 6
  52. #define PROCESS_STATE_DOWN_CONTINUE_PENDING 7
  53. #define PROCESS_STATE_TERMINATING 8
  54. #define PROCESS_STATE_TERMINATED_PENDING 9
  55. #define PROCESS_STATE_TERMINATED 10
  56. static int object_func_getvar (NCDModuleInst *n, const char *name, NCDValue *out_value);
  57. static int object_func_getobj (NCDModuleInst *n, const char *name, NCDObject *out_object);
  58. static int process_args_object_func_getvar (NCDModuleProcess *o, const char *name, NCDValue *out_value);
  59. static int process_arg_object_func_getvar2 (NCDModuleProcess *o, NCDValue *arg, const char *name, NCDValue *out_value);
  60. static void frontend_event (NCDModuleInst *n, int event)
  61. {
  62. n->params->func_event(n->user, event);
  63. }
  64. static void init_job_handler (NCDModuleInst *n)
  65. {
  66. DebugObject_Access(&n->d_obj);
  67. ASSERT(n->state == STATE_INIT)
  68. n->state = STATE_DOWN_CLEAN;
  69. n->m->func_new(n);
  70. return;
  71. }
  72. static void uninit_job_handler (NCDModuleInst *n)
  73. {
  74. DebugObject_Access(&n->d_obj);
  75. ASSERT(n->state == STATE_UNINIT)
  76. n->state = STATE_UNDEAD;
  77. frontend_event(n, NCDMODULE_EVENT_DEAD);
  78. return;
  79. }
  80. static void die_job_handler (NCDModuleInst *n)
  81. {
  82. DebugObject_Access(&n->d_obj);
  83. ASSERT(n->state == STATE_DOWN_DIE || n->state == STATE_UP_DIE)
  84. n->state = STATE_DYING;
  85. if (!n->m->func_die) {
  86. NCDModuleInst_Backend_Dead(n);
  87. return;
  88. }
  89. n->m->func_die(n->inst_user);
  90. return;
  91. }
  92. static void clean_job_handler (NCDModuleInst *n)
  93. {
  94. DebugObject_Access(&n->d_obj);
  95. ASSERT(n->state == STATE_DOWN_PCLEAN)
  96. n->state = STATE_DOWN_CLEAN;
  97. if (n->m->func_clean) {
  98. n->m->func_clean(n->inst_user);
  99. return;
  100. }
  101. }
  102. static void process_event_job_handler (NCDModuleProcess *o)
  103. {
  104. DebugObject_Access(&o->d_obj);
  105. switch (o->state) {
  106. case PROCESS_STATE_DOWN_CONTINUE_PENDING: {
  107. o->state = PROCESS_STATE_DOWN;
  108. o->interp_func_event(o->interp_user, NCDMODULEPROCESS_INTERP_EVENT_CONTINUE);
  109. } break;
  110. case PROCESS_STATE_UP_PENDING: {
  111. o->state = PROCESS_STATE_UP;
  112. o->handler_event(o->user, NCDMODULEPROCESS_EVENT_UP);
  113. return;
  114. } break;
  115. case PROCESS_STATE_DOWN_PENDING: {
  116. o->state = PROCESS_STATE_DOWN_WAITING;
  117. o->handler_event(o->user, NCDMODULEPROCESS_EVENT_DOWN);
  118. return;
  119. } break;
  120. case PROCESS_STATE_TERMINATED_PENDING: {
  121. o->state = PROCESS_STATE_TERMINATED;
  122. o->handler_event(o->user, NCDMODULEPROCESS_EVENT_TERMINATED);
  123. return;
  124. } break;
  125. default: ASSERT(0);
  126. }
  127. }
  128. static void inst_assert_backend (NCDModuleInst *n)
  129. {
  130. ASSERT(n->state == STATE_DOWN_PCLEAN || n->state == STATE_DOWN_UNCLEAN || n->state == STATE_DOWN_CLEAN ||
  131. n->state == STATE_UP || n->state == STATE_DOWN_DIE || n->state == STATE_UP_DIE ||
  132. n->state == STATE_DYING)
  133. }
  134. void NCDModuleInst_Init (NCDModuleInst *n, const struct NCDModule *m, const NCDObject *method_object, NCDValue *args, void *user, const struct NCDModuleInst_params *params)
  135. {
  136. ASSERT(m)
  137. ASSERT(args)
  138. ASSERT(NCDValue_Type(args) == NCDVALUE_LIST)
  139. ASSERT(params)
  140. ASSERT(params->func_event)
  141. ASSERT(params->func_getobj)
  142. ASSERT(params->func_initprocess)
  143. ASSERT(params->logfunc)
  144. // init arguments
  145. n->m = m;
  146. n->method_user = (method_object ? method_object->user : NULL);
  147. n->args = args;
  148. n->user = user;
  149. n->params = params;
  150. // init jobs
  151. BPending_Init(&n->init_job, BReactor_PendingGroup(params->reactor), (BPending_handler)init_job_handler, n);
  152. BPending_Init(&n->uninit_job, BReactor_PendingGroup(params->reactor), (BPending_handler)uninit_job_handler, n);
  153. BPending_Init(&n->die_job, BReactor_PendingGroup(params->reactor), (BPending_handler)die_job_handler, n);
  154. BPending_Init(&n->clean_job, BReactor_PendingGroup(params->reactor), (BPending_handler)clean_job_handler, n);
  155. // set initial state
  156. n->state = STATE_INIT;
  157. BPending_Set(&n->init_job);
  158. // set initial instance argument
  159. n->inst_user = NULL;
  160. // clear error flag
  161. n->is_error = 0;
  162. DebugObject_Init(&n->d_obj);
  163. }
  164. void NCDModuleInst_Free (NCDModuleInst *n)
  165. {
  166. DebugObject_Free(&n->d_obj);
  167. ASSERT(n->state == STATE_DEAD || n->state == STATE_UNDEAD)
  168. // free jobs
  169. BPending_Free(&n->clean_job);
  170. BPending_Free(&n->die_job);
  171. BPending_Free(&n->uninit_job);
  172. BPending_Free(&n->init_job);
  173. }
  174. void NCDModuleInst_Die (NCDModuleInst *n)
  175. {
  176. DebugObject_Access(&n->d_obj);
  177. switch (n->state) {
  178. case STATE_INIT: {
  179. n->state = STATE_UNINIT;
  180. BPending_Unset(&n->init_job);
  181. BPending_Set(&n->uninit_job);
  182. } break;
  183. case STATE_DOWN_CLEAN:
  184. case STATE_DOWN_UNCLEAN: {
  185. n->state = STATE_DOWN_DIE;
  186. BPending_Set(&n->die_job);
  187. } break;
  188. case STATE_DOWN_PCLEAN: {
  189. n->state = STATE_DOWN_DIE;
  190. BPending_Unset(&n->clean_job);
  191. BPending_Set(&n->die_job);
  192. } break;
  193. case STATE_UP: {
  194. n->state = STATE_UP_DIE;
  195. BPending_Set(&n->die_job);
  196. } break;
  197. default: ASSERT(0);
  198. }
  199. }
  200. void NCDModuleInst_Clean (NCDModuleInst *n)
  201. {
  202. DebugObject_Access(&n->d_obj);
  203. switch (n->state) {
  204. case STATE_INIT:
  205. case STATE_DOWN_CLEAN:
  206. case STATE_DOWN_PCLEAN: {
  207. } break;
  208. case STATE_DOWN_UNCLEAN: {
  209. n->state = STATE_DOWN_PCLEAN;
  210. BPending_Set(&n->clean_job);
  211. } break;
  212. default: ASSERT(0);
  213. }
  214. }
  215. NCDObject NCDModuleInst_Object (NCDModuleInst *n)
  216. {
  217. DebugObject_Access(&n->d_obj);
  218. const char *type = (n->m->base_type ? n->m->base_type : n->m->type);
  219. return NCDObject_Build(type, n, (NCDObject_func_getvar)object_func_getvar, (NCDObject_func_getobj)object_func_getobj);
  220. }
  221. static int can_resolve (NCDModuleInst *n)
  222. {
  223. switch (n->state) {
  224. case STATE_UP:
  225. case STATE_UP_DIE:
  226. return 1;
  227. case STATE_DOWN_CLEAN:
  228. case STATE_DOWN_UNCLEAN:
  229. case STATE_DOWN_PCLEAN:
  230. case STATE_DOWN_DIE:
  231. return n->m->can_resolve_when_down;
  232. default:
  233. return 0;
  234. }
  235. }
  236. static int object_func_getvar (NCDModuleInst *n, const char *name, NCDValue *out_value)
  237. {
  238. DebugObject_Access(&n->d_obj);
  239. if (!n->m->func_getvar || !can_resolve(n)) {
  240. return 0;
  241. }
  242. int res = n->m->func_getvar(n->inst_user, name, out_value);
  243. ASSERT(res == 0 || res == 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 || n->state == STATE_UNDEAD)
  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->clean_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->die_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->clean_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->params->func_interp_exit(n->user, exit_code);
  370. }
  371. int NCDModuleInst_Backend_InterpGetArgs (NCDModuleInst *n, NCDValue *out_value)
  372. {
  373. DebugObject_Access(&n->d_obj);
  374. inst_assert_backend(n);
  375. ASSERT(out_value)
  376. int res = n->params->func_interp_getargs(n->user, out_value);
  377. ASSERT(res == 0 || res == 1)
  378. ASSERT(!res || (NCDValue_Type(out_value), 1))
  379. return res;
  380. }
  381. int NCDModuleProcess_Init (NCDModuleProcess *o, NCDModuleInst *n, const char *template_name, NCDValue args, void *user, NCDModuleProcess_handler_event handler_event)
  382. {
  383. DebugObject_Access(&n->d_obj);
  384. ASSERT(n->state == STATE_DOWN_PCLEAN || n->state == STATE_DOWN_UNCLEAN || n->state == STATE_DOWN_CLEAN ||
  385. n->state == STATE_UP || n->state == STATE_DOWN_DIE || n->state == STATE_UP_DIE ||
  386. n->state == STATE_DYING)
  387. ASSERT(template_name)
  388. ASSERT(NCDValue_Type(&args) == NCDVALUE_LIST)
  389. ASSERT(handler_event)
  390. // init arguments
  391. o->args = args;
  392. o->user = user;
  393. o->handler_event = handler_event;
  394. // set no special functions
  395. o->func_getspecialobj = NULL;
  396. // init event job
  397. BPending_Init(&o->event_job, BReactor_PendingGroup(n->params->reactor), (BPending_handler)process_event_job_handler, o);
  398. // set state
  399. o->state = PROCESS_STATE_INIT;
  400. // clear interp functions so we can assert they were set
  401. o->interp_func_event = NULL;
  402. o->interp_func_getobj = NULL;
  403. // init interpreter part
  404. if (!(n->params->func_initprocess(n->user, o, template_name))) {
  405. goto fail1;
  406. }
  407. ASSERT(o->interp_func_event)
  408. ASSERT(o->interp_func_getobj)
  409. // set state
  410. o->state = PROCESS_STATE_DOWN;
  411. DebugObject_Init(&o->d_obj);
  412. return 1;
  413. fail1:
  414. BPending_Free(&o->event_job);
  415. return 0;
  416. }
  417. void NCDModuleProcess_Free (NCDModuleProcess *o)
  418. {
  419. DebugObject_Free(&o->d_obj);
  420. ASSERT(o->state == PROCESS_STATE_TERMINATED)
  421. // free event job
  422. BPending_Free(&o->event_job);
  423. // free arguments
  424. NCDValue_Free(&o->args);
  425. }
  426. void NCDModuleProcess_AssertFree (NCDModuleProcess *o)
  427. {
  428. DebugObject_Access(&o->d_obj);
  429. ASSERT(o->state == PROCESS_STATE_TERMINATED)
  430. }
  431. void NCDModuleProcess_SetSpecialFuncs (NCDModuleProcess *o, NCDModuleProcess_func_getspecialobj func_getspecialobj)
  432. {
  433. DebugObject_Access(&o->d_obj);
  434. o->func_getspecialobj = func_getspecialobj;
  435. }
  436. void NCDModuleProcess_Continue (NCDModuleProcess *o)
  437. {
  438. DebugObject_Access(&o->d_obj);
  439. ASSERT(o->state == PROCESS_STATE_DOWN_WAITING)
  440. o->state = PROCESS_STATE_DOWN;
  441. o->interp_func_event(o->interp_user, NCDMODULEPROCESS_INTERP_EVENT_CONTINUE);
  442. }
  443. void NCDModuleProcess_Terminate (NCDModuleProcess *o)
  444. {
  445. DebugObject_Access(&o->d_obj);
  446. ASSERT(o->state == PROCESS_STATE_DOWN || o->state == PROCESS_STATE_UP_PENDING ||
  447. o->state == PROCESS_STATE_DOWN_CONTINUE_PENDING || o->state == PROCESS_STATE_UP ||
  448. o->state == PROCESS_STATE_DOWN_PENDING || o->state == PROCESS_STATE_DOWN_WAITING)
  449. BPending_Unset(&o->event_job);
  450. o->state = PROCESS_STATE_TERMINATING;
  451. o->interp_func_event(o->interp_user, NCDMODULEPROCESS_INTERP_EVENT_TERMINATE);
  452. }
  453. int NCDModuleProcess_GetObj (NCDModuleProcess *o, const char *name, NCDObject *out_object)
  454. {
  455. DebugObject_Access(&o->d_obj);
  456. ASSERT(o->state != PROCESS_STATE_INIT)
  457. ASSERT(name)
  458. ASSERT(out_object)
  459. // interpreter gone?
  460. if (o->state == PROCESS_STATE_TERMINATED_PENDING || o->state == PROCESS_STATE_TERMINATED) {
  461. return 0;
  462. }
  463. int res = o->interp_func_getobj(o->interp_user, name, out_object);
  464. ASSERT(res == 0 || res == 1)
  465. return res;
  466. }
  467. static void process_assert_interp (NCDModuleProcess *o)
  468. {
  469. // assert that the interpreter knows about the object, and we're not in init
  470. ASSERT(o->state == PROCESS_STATE_DOWN || o->state == PROCESS_STATE_UP_PENDING ||
  471. o->state == PROCESS_STATE_DOWN_CONTINUE_PENDING || o->state == PROCESS_STATE_UP ||
  472. o->state == PROCESS_STATE_DOWN_PENDING || o->state == PROCESS_STATE_DOWN_WAITING ||
  473. o->state == PROCESS_STATE_TERMINATING)
  474. }
  475. void NCDModuleProcess_Interp_SetHandlers (NCDModuleProcess *o, void *interp_user,
  476. NCDModuleProcess_interp_func_event interp_func_event,
  477. NCDModuleProcess_interp_func_getobj interp_func_getobj)
  478. {
  479. ASSERT(o->state == PROCESS_STATE_INIT)
  480. ASSERT(interp_func_event)
  481. ASSERT(interp_func_getobj)
  482. o->interp_user = interp_user;
  483. o->interp_func_event = interp_func_event;
  484. o->interp_func_getobj = interp_func_getobj;
  485. }
  486. void NCDModuleProcess_Interp_Up (NCDModuleProcess *o)
  487. {
  488. DebugObject_Access(&o->d_obj);
  489. process_assert_interp(o);
  490. ASSERT(o->state == PROCESS_STATE_DOWN)
  491. BPending_Set(&o->event_job);
  492. o->state = PROCESS_STATE_UP_PENDING;
  493. }
  494. void NCDModuleProcess_Interp_Down (NCDModuleProcess *o)
  495. {
  496. DebugObject_Access(&o->d_obj);
  497. process_assert_interp(o);
  498. switch (o->state) {
  499. case PROCESS_STATE_UP_PENDING: {
  500. BPending_Unset(&o->event_job);
  501. BPending_Set(&o->event_job);
  502. o->state = PROCESS_STATE_DOWN_CONTINUE_PENDING;
  503. } break;
  504. case PROCESS_STATE_UP: {
  505. BPending_Set(&o->event_job);
  506. o->state = PROCESS_STATE_DOWN_PENDING;
  507. } break;
  508. default: ASSERT(0);
  509. }
  510. }
  511. void NCDModuleProcess_Interp_Terminated (NCDModuleProcess *o)
  512. {
  513. DebugObject_Access(&o->d_obj);
  514. process_assert_interp(o);
  515. ASSERT(o->state == PROCESS_STATE_TERMINATING)
  516. BPending_Set(&o->event_job);
  517. o->state = PROCESS_STATE_TERMINATED_PENDING;
  518. }
  519. int NCDModuleProcess_Interp_GetSpecialObj (NCDModuleProcess *o, const char *name, NCDObject *out_object)
  520. {
  521. DebugObject_Access(&o->d_obj);
  522. process_assert_interp(o);
  523. ASSERT(name)
  524. ASSERT(out_object)
  525. if (!strcmp(name, "_args")) {
  526. *out_object = NCDObject_Build(NULL, o, (NCDObject_func_getvar)process_args_object_func_getvar, NULL);
  527. return 1;
  528. }
  529. size_t len;
  530. uintmax_t n;
  531. if ((len = string_begins_with(name, "_arg")) && parse_unsigned_integer(name + len, &n) && n < NCDValue_ListCount(&o->args)) {
  532. *out_object = NCDObject_Build2(NULL, o, NCDValue_ListGet(&o->args, n), (NCDObject_func_getvar2)process_arg_object_func_getvar2, NULL);
  533. return 1;
  534. }
  535. if (!o->func_getspecialobj) {
  536. return 0;
  537. }
  538. int res = o->func_getspecialobj(o->user, name, out_object);
  539. ASSERT(res == 0 || res == 1)
  540. return res;
  541. }
  542. static int process_args_object_func_getvar (NCDModuleProcess *o, const char *name, NCDValue *out_value)
  543. {
  544. DebugObject_Access(&o->d_obj);
  545. process_assert_interp(o);
  546. if (strcmp(name, "")) {
  547. return 0;
  548. }
  549. if (!NCDValue_InitCopy(out_value, &o->args)) {
  550. BLog_LogToChannel(BLOG_CHANNEL_NCDModuleProcess, BLOG_ERROR, "NCDValue_InitCopy failed");
  551. return 0;
  552. }
  553. return 1;
  554. }
  555. static int process_arg_object_func_getvar2 (NCDModuleProcess *o, NCDValue *arg, const char *name, NCDValue *out_value)
  556. {
  557. DebugObject_Access(&o->d_obj);
  558. process_assert_interp(o);
  559. if (!NCDValue_InitCopy(out_value, arg)) {
  560. BLog_LogToChannel(BLOG_CHANNEL_NCDModuleProcess, BLOG_ERROR, "NCDValue_InitCopy failed");
  561. return 0;
  562. }
  563. return 1;
  564. }