ktpd_session.c 22 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884
  1. #include <stdlib.h>
  2. #include <stdio.h>
  3. #include <string.h>
  4. #include <assert.h>
  5. #include <unistd.h>
  6. #include <errno.h>
  7. #include <sys/types.h>
  8. #include <sys/stat.h>
  9. #include <fcntl.h>
  10. #include <sys/socket.h>
  11. #include <sys/un.h>
  12. #include <syslog.h>
  13. #include <poll.h>
  14. #include <sys/wait.h>
  15. #include <faux/str.h>
  16. #include <faux/async.h>
  17. #include <faux/msg.h>
  18. #include <faux/eloop.h>
  19. #include <klish/ksession.h>
  20. #include <klish/ksession_parse.h>
  21. #include <klish/ktp.h>
  22. #include <klish/ktp_session.h>
  23. typedef enum {
  24. KTPD_SESSION_STATE_DISCONNECTED = 'd',
  25. KTPD_SESSION_STATE_UNAUTHORIZED = 'a',
  26. KTPD_SESSION_STATE_IDLE = 'i',
  27. KTPD_SESSION_STATE_WAIT_FOR_PROCESS = 'p',
  28. } ktpd_session_state_e;
  29. struct ktpd_session_s {
  30. ksession_t *session;
  31. ktpd_session_state_e state;
  32. uid_t uid;
  33. gid_t gid;
  34. char *user;
  35. faux_async_t *async;
  36. faux_hdr_t *hdr; // Engine will receive header and then msg
  37. faux_eloop_t *eloop; // External link, dont's free()
  38. kexec_t *exec;
  39. bool_t exit;
  40. };
  41. // Static declarations
  42. static bool_t ktpd_session_read_cb(faux_async_t *async,
  43. faux_buf_t *buf, size_t len, void *user_data);
  44. static bool_t wait_for_actions_ev(faux_eloop_t *eloop, faux_eloop_type_e type,
  45. void *associated_data, void *user_data);
  46. bool_t client_ev(faux_eloop_t *eloop, faux_eloop_type_e type,
  47. void *associated_data, void *user_data);
  48. static bool_t ktpd_session_exec(ktpd_session_t *ktpd, const char *line,
  49. int *retcode, faux_error_t *error, bool_t dry_run);
  50. static bool_t action_stdout_ev(faux_eloop_t *eloop, faux_eloop_type_e type,
  51. void *associated_data, void *user_data);
  52. static bool_t action_stderr_ev(faux_eloop_t *eloop, faux_eloop_type_e type,
  53. void *associated_data, void *user_data);
  54. ktpd_session_t *ktpd_session_new(int sock, kscheme_t *scheme,
  55. const char *start_entry, faux_eloop_t *eloop)
  56. {
  57. ktpd_session_t *ktpd = NULL;
  58. if (sock < 0)
  59. return NULL;
  60. if (!eloop)
  61. return NULL;
  62. ktpd = faux_zmalloc(sizeof(*ktpd));
  63. assert(ktpd);
  64. if (!ktpd)
  65. return NULL;
  66. // Init
  67. ktpd->state = KTPD_SESSION_STATE_IDLE;
  68. ktpd->eloop = eloop;
  69. ktpd->session = ksession_new(scheme, start_entry);
  70. assert(ktpd->session);
  71. ktpd->exec = NULL;
  72. // Exit flag. It differs from ksession done flag because KTPD session
  73. // can't exit immediately. It must finish current command processing
  74. // before really stop the event loop. Note: User defined plugin
  75. // function must use ksession done flag. This exit flag is internal
  76. // feature of KTPD session.
  77. ktpd->exit = BOOL_FALSE;
  78. // Async object
  79. ktpd->async = faux_async_new(sock);
  80. assert(ktpd->async);
  81. // Receive message header first
  82. faux_async_set_read_limits(ktpd->async,
  83. sizeof(faux_hdr_t), sizeof(faux_hdr_t));
  84. faux_async_set_read_cb(ktpd->async, ktpd_session_read_cb, ktpd);
  85. ktpd->hdr = NULL;
  86. faux_async_set_stall_cb(ktpd->async, ktp_stall_cb, ktpd->eloop);
  87. // Eloop callbacks
  88. faux_eloop_add_fd(ktpd->eloop, ktpd_session_fd(ktpd), POLLIN,
  89. client_ev, ktpd);
  90. faux_eloop_add_signal(ktpd->eloop, SIGCHLD, wait_for_actions_ev, ktpd);
  91. return ktpd;
  92. }
  93. void ktpd_session_free(ktpd_session_t *ktpd)
  94. {
  95. if (!ktpd)
  96. return;
  97. kexec_free(ktpd->exec);
  98. ksession_free(ktpd->session);
  99. faux_free(ktpd->hdr);
  100. close(ktpd_session_fd(ktpd));
  101. faux_async_free(ktpd->async);
  102. faux_free(ktpd);
  103. }
  104. static bool_t ktpd_session_process_cmd(ktpd_session_t *ktpd, faux_msg_t *msg)
  105. {
  106. char *line = NULL;
  107. int retcode = -1;
  108. ktp_cmd_e cmd = KTP_CMD_ACK;
  109. faux_error_t *error = NULL;
  110. bool_t rc = BOOL_FALSE;
  111. bool_t dry_run = BOOL_FALSE;
  112. uint32_t status = KTP_STATUS_NONE;
  113. bool_t ret = BOOL_TRUE;
  114. assert(ktpd);
  115. assert(msg);
  116. // Get line from message
  117. if (!(line = faux_msg_get_str_param_by_type(msg, KTP_PARAM_LINE))) {
  118. ktp_send_error(ktpd->async, cmd, "The line is not specified");
  119. return BOOL_FALSE;
  120. }
  121. // Get dry-run flag from message
  122. if (KTP_STATUS_IS_DRY_RUN(faux_msg_get_status(msg)))
  123. dry_run = BOOL_TRUE;
  124. error = faux_error_new();
  125. ktpd->exec = NULL;
  126. rc = ktpd_session_exec(ktpd, line, &retcode, error, dry_run);
  127. faux_str_free(line);
  128. // Command is scheduled. Eloop will wait for ACTION completion.
  129. // So inform client about it and about command features like
  130. // interactive/non-interactive.
  131. if (ktpd->exec) {
  132. faux_msg_t *ack = NULL;
  133. ktp_status_e status = KTP_STATUS_INCOMPLETED;
  134. ack = ktp_msg_preform(cmd, status);
  135. faux_msg_send_async(ack, ktpd->async);
  136. faux_msg_free(ack);
  137. faux_error_free(error);
  138. return BOOL_TRUE; // Continue and wait for ACTION
  139. }
  140. // Here we don't need to wait for the action. We have retcode already.
  141. if (ksession_done(ktpd->session)) {
  142. ktpd->exit = BOOL_TRUE;
  143. status |= KTP_STATUS_EXIT;
  144. }
  145. if (rc) {
  146. uint8_t retcode8bit = 0;
  147. faux_msg_t *ack = ktp_msg_preform(cmd, status);
  148. retcode8bit = (uint8_t)(retcode & 0xff);
  149. faux_msg_add_param(ack, KTP_PARAM_RETCODE, &retcode8bit, 1);
  150. faux_msg_send_async(ack, ktpd->async);
  151. faux_msg_free(ack);
  152. } else {
  153. char *err = faux_error_cstr(error);
  154. ktp_send_error(ktpd->async, cmd, err);
  155. faux_str_free(err);
  156. ret = BOOL_FALSE;
  157. }
  158. faux_error_free(error);
  159. return ret;
  160. }
  161. static bool_t ktpd_session_exec(ktpd_session_t *ktpd, const char *line,
  162. int *retcode, faux_error_t *error, bool_t dry_run)
  163. {
  164. kexec_t *exec = NULL;
  165. assert(ktpd);
  166. if (!ktpd)
  167. return BOOL_FALSE;
  168. // Parsing
  169. exec = ksession_parse_for_exec(ktpd->session, line, error);
  170. if (!exec)
  171. return BOOL_FALSE;
  172. // Set dry-run flag
  173. kexec_set_dry_run(exec, dry_run);
  174. // Session status can be changed while parsing
  175. // NOTE: kexec_t is atomic now
  176. // if (ksession_done(ktpd->session)) {
  177. // kexec_free(exec);
  178. // return BOOL_FALSE; // Because action is not completed
  179. // }
  180. // Execute kexec and then wait for completion using global Eloop
  181. if (!kexec_exec(exec)) {
  182. kexec_free(exec);
  183. return BOOL_FALSE; // Something went wrong
  184. }
  185. // If kexec contains only non-exec (for example dry-run) ACTIONs then
  186. // we don't need event loop and can return here.
  187. if (kexec_retcode(exec, retcode)) {
  188. kexec_free(exec);
  189. return BOOL_TRUE;
  190. }
  191. // Save kexec pointer to use later
  192. ktpd->state = KTPD_SESSION_STATE_WAIT_FOR_PROCESS;
  193. ktpd->exec = exec;
  194. faux_eloop_add_fd(ktpd->eloop, kexec_stdout(exec), POLLIN,
  195. action_stdout_ev, ktpd);
  196. faux_eloop_add_fd(ktpd->eloop, kexec_stderr(exec), POLLIN,
  197. action_stderr_ev, ktpd);
  198. return BOOL_TRUE;
  199. }
  200. static bool_t wait_for_actions_ev(faux_eloop_t *eloop, faux_eloop_type_e type,
  201. void *associated_data, void *user_data)
  202. {
  203. int wstatus = 0;
  204. pid_t child_pid = -1;
  205. ktpd_session_t *ktpd = (ktpd_session_t *)user_data;
  206. int retcode = -1;
  207. uint8_t retcode8bit = 0;
  208. faux_msg_t *ack = NULL;
  209. ktp_cmd_e cmd = KTP_CMD_ACK;
  210. uint32_t status = KTP_STATUS_NONE;
  211. if (!ktpd)
  212. return BOOL_FALSE;
  213. // Wait for any child process. Doesn't block.
  214. while ((child_pid = waitpid(-1, &wstatus, WNOHANG)) > 0) {
  215. if (ktpd->exec)
  216. kexec_continue_command_execution(ktpd->exec, child_pid,
  217. wstatus);
  218. }
  219. if (!ktpd->exec)
  220. return BOOL_TRUE;
  221. // Check if kexec is done now
  222. if (!kexec_retcode(ktpd->exec, &retcode))
  223. return BOOL_TRUE; // Continue
  224. faux_eloop_del_fd(eloop, kexec_stdout(ktpd->exec));
  225. faux_eloop_del_fd(eloop, kexec_stderr(ktpd->exec));
  226. kexec_free(ktpd->exec);
  227. ktpd->exec = NULL;
  228. ktpd->state = KTPD_SESSION_STATE_IDLE;
  229. // All kexec_t actions are done so can break the loop if needed.
  230. if (ksession_done(ktpd->session)) {
  231. ktpd->exit = BOOL_TRUE;
  232. status |= KTP_STATUS_EXIT; // Notify client about exiting
  233. }
  234. // Send ACK message
  235. ack = ktp_msg_preform(cmd, status);
  236. retcode8bit = (uint8_t)(retcode & 0xff);
  237. faux_msg_add_param(ack, KTP_PARAM_RETCODE, &retcode8bit, 1);
  238. faux_msg_send_async(ack, ktpd->async);
  239. faux_msg_free(ack);
  240. type = type; // Happy compiler
  241. associated_data = associated_data; // Happy compiler
  242. if (ktpd->exit)
  243. return BOOL_FALSE;
  244. return BOOL_TRUE;
  245. }
  246. static int compl_compare(const void *first, const void *second)
  247. {
  248. const char *f = (const char *)first;
  249. const char *s = (const char *)second;
  250. return strcmp(f, s);
  251. }
  252. static int compl_kcompare(const void *key, const void *list_item)
  253. {
  254. const char *f = (const char *)key;
  255. const char *s = (const char *)list_item;
  256. return strcmp(f, s);
  257. }
  258. static bool_t ktpd_session_process_completion(ktpd_session_t *ktpd, faux_msg_t *msg)
  259. {
  260. char *line = NULL;
  261. faux_msg_t *ack = NULL;
  262. kpargv_t *pargv = NULL;
  263. ktp_cmd_e cmd = KTP_COMPLETION_ACK;
  264. uint32_t status = KTP_STATUS_NONE;
  265. const char *prefix = NULL;
  266. size_t prefix_len = 0;
  267. assert(ktpd);
  268. assert(msg);
  269. // Get line from message
  270. if (!(line = faux_msg_get_str_param_by_type(msg, KTP_PARAM_LINE))) {
  271. ktp_send_error(ktpd->async, cmd, NULL);
  272. return BOOL_FALSE;
  273. }
  274. // Parsing
  275. pargv = ksession_parse_for_completion(ktpd->session, line);
  276. faux_str_free(line);
  277. if (!pargv) {
  278. ktp_send_error(ktpd->async, cmd, NULL);
  279. return BOOL_FALSE;
  280. }
  281. kpargv_debug(pargv);
  282. if (ksession_done(ktpd->session)) {
  283. ktpd->exit = BOOL_TRUE;
  284. status |= KTP_STATUS_EXIT; // Notify client about exiting
  285. }
  286. // Prepare ACK message
  287. ack = ktp_msg_preform(cmd, status);
  288. // Last unfinished word. Common prefix for all completions
  289. prefix = kpargv_last_arg(pargv);
  290. if (!faux_str_is_empty(prefix)) {
  291. prefix_len = strlen(prefix);
  292. faux_msg_add_param(ack, KTP_PARAM_PREFIX, prefix, prefix_len);
  293. }
  294. // Fill msg with possible completions
  295. if (!kpargv_completions_is_empty(pargv)) {
  296. const kentry_t *candidate = NULL;
  297. kpargv_completions_node_t *citer = kpargv_completions_iter(pargv);
  298. faux_list_node_t *compl_iter = NULL;
  299. faux_list_t *completions = NULL;
  300. char *compl_str = NULL;
  301. completions = faux_list_new(FAUX_LIST_SORTED, FAUX_LIST_UNIQUE,
  302. compl_compare, compl_kcompare,
  303. (void (*)(void *))faux_str_free);
  304. while ((candidate = kpargv_completions_each(&citer))) {
  305. const kentry_t *completion = NULL;
  306. kparg_t *parg = NULL;
  307. int rc = -1;
  308. char *out = NULL;
  309. bool_t res = BOOL_FALSE;
  310. char *l = NULL; // One line of completion
  311. const char *str = NULL;
  312. // Get completion entry from candidate entry
  313. completion = kentry_nested_by_purpose(candidate,
  314. KENTRY_PURPOSE_COMPLETION);
  315. // If candidate entry doesn't contain completion then try
  316. // to get completion from entry's PTYPE
  317. if (!completion) {
  318. const kentry_t *ptype = NULL;
  319. ptype = kentry_nested_by_purpose(candidate,
  320. KENTRY_PURPOSE_PTYPE);
  321. if (!ptype)
  322. continue;
  323. completion = kentry_nested_by_purpose(ptype,
  324. KENTRY_PURPOSE_COMPLETION);
  325. }
  326. if (!completion)
  327. continue;
  328. parg = kparg_new(candidate, prefix);
  329. kpargv_set_candidate_parg(pargv, parg);
  330. res = ksession_exec_locally(ktpd->session, completion,
  331. pargv, &rc, &out);
  332. kparg_free(parg);
  333. if (!res || (rc < 0) || !out) {
  334. if (out)
  335. faux_str_free(out);
  336. continue;
  337. }
  338. // Get all completions one by one
  339. str = out;
  340. while ((l = faux_str_getline(str, &str))) {
  341. // Compare prefix
  342. if ((prefix_len > 0) &&
  343. (faux_str_cmpn(prefix, l, prefix_len) != 0)) {
  344. faux_str_free(l);
  345. continue;
  346. }
  347. compl_str = l + prefix_len;
  348. faux_list_add(completions, faux_str_dup(compl_str));
  349. faux_str_free(l);
  350. }
  351. faux_str_free(out);
  352. }
  353. // Put completion list to message
  354. compl_iter = faux_list_head(completions);
  355. while ((compl_str = faux_list_each(&compl_iter))) {
  356. faux_msg_add_param(ack, KTP_PARAM_LINE,
  357. compl_str, strlen(compl_str));
  358. }
  359. faux_list_free(completions);
  360. }
  361. faux_msg_send_async(ack, ktpd->async);
  362. faux_msg_free(ack);
  363. kpargv_free(pargv);
  364. return BOOL_TRUE;
  365. }
  366. // Now help generation is simple. The 'prefix' (first help field) is generated
  367. // by PTYPE's help function. It can be something like 'ip', 'filter' i.e.
  368. // subcommand or '3..89', '<STRING>' i.e. description of type. The second
  369. // field is description of current parameter. For example 'Interface IP
  370. // address'. So the full help can be:
  371. // AAA.BBB.CCC.DDD Interface IP address
  372. // [ first field ] [ second field ]
  373. //
  374. // Not all possible parameters can conform currently partly-typed line but it's
  375. // not clear how to filter them. Completions can be solution but completions are
  376. // not mandatory so parameter with non completed completion list can be filtered
  377. // out.
  378. static bool_t ktpd_session_process_help(ktpd_session_t *ktpd, faux_msg_t *msg)
  379. {
  380. char *line = NULL;
  381. faux_msg_t *ack = NULL;
  382. kpargv_t *pargv = NULL;
  383. ktp_cmd_e cmd = KTP_HELP_ACK;
  384. uint32_t status = KTP_STATUS_NONE;
  385. const char *prefix = NULL;
  386. assert(ktpd);
  387. assert(msg);
  388. // Get line from message
  389. if (!(line = faux_msg_get_str_param_by_type(msg, KTP_PARAM_LINE))) {
  390. ktp_send_error(ktpd->async, cmd, NULL);
  391. return BOOL_FALSE;
  392. }
  393. // Parsing
  394. pargv = ksession_parse_for_completion(ktpd->session, line);
  395. faux_str_free(line);
  396. if (!pargv) {
  397. ktp_send_error(ktpd->async, cmd, NULL);
  398. return BOOL_FALSE;
  399. }
  400. if (ksession_done(ktpd->session)) {
  401. ktpd->exit = BOOL_TRUE;
  402. status |= KTP_STATUS_EXIT; // Notify client about exiting
  403. }
  404. // Prepare ACK message
  405. ack = ktp_msg_preform(cmd, status);
  406. // Last unfinished word. Common prefix for all entries
  407. prefix = kpargv_last_arg(pargv);
  408. // Fill msg with possible completions
  409. if (!kpargv_completions_is_empty(pargv)) {
  410. const kentry_t *candidate = NULL;
  411. kpargv_completions_node_t *citer = kpargv_completions_iter(pargv);
  412. faux_list_node_t *help_iter = NULL;
  413. faux_list_t *help_list = NULL;
  414. help_t *help_struct = NULL;
  415. help_list = faux_list_new(FAUX_LIST_SORTED, FAUX_LIST_UNIQUE,
  416. help_compare, help_kcompare, help_free);
  417. while ((candidate = kpargv_completions_each(&citer))) {
  418. const kentry_t *help = NULL;
  419. const kentry_t *ptype = NULL;
  420. char *prefix_str = NULL;
  421. char *line_str = NULL;
  422. // Get help from PTYPE for 'prefix'
  423. ptype = kentry_nested_by_purpose(candidate,
  424. KENTRY_PURPOSE_PTYPE);
  425. if (!ptype) // Can't get help for ENTRY w/o PTYPE
  426. continue;
  427. help = kentry_nested_by_purpose(ptype,
  428. KENTRY_PURPOSE_HELP);
  429. if (help) {
  430. kparg_t *parg = NULL;
  431. int rc = -1;
  432. parg = kparg_new(candidate, prefix);
  433. kpargv_set_candidate_parg(pargv, parg);
  434. ksession_exec_locally(ktpd->session,
  435. help, pargv, &rc, &prefix_str);
  436. kparg_free(parg);
  437. }
  438. if (!prefix_str) {
  439. // If help is not defined use name of PTYPE.
  440. // It can be informative enough.
  441. prefix_str = faux_str_dup(kentry_name(ptype));
  442. }
  443. // Get completion entry from candidate entry for 'line'
  444. help = kentry_nested_by_purpose(candidate,
  445. KENTRY_PURPOSE_HELP);
  446. if (help) {
  447. kparg_t *parg = NULL;
  448. int rc = -1;
  449. parg = kparg_new(candidate, prefix);
  450. kpargv_set_candidate_parg(pargv, parg);
  451. ksession_exec_locally(ktpd->session,
  452. help, pargv, &rc, &line_str);
  453. kparg_free(parg);
  454. }
  455. if (!line_str) {
  456. // If help is not defined use name of ENTRY.
  457. // It can be informative enough.
  458. line_str = faux_str_dup(kentry_name(candidate));
  459. }
  460. help_struct = help_new(prefix_str, line_str);
  461. faux_list_add(help_list, help_struct);
  462. }
  463. // Put help list to message
  464. help_iter = faux_list_head(help_list);
  465. while ((help_struct = (help_t *)faux_list_each(&help_iter))) {
  466. faux_msg_add_param(ack, KTP_PARAM_PREFIX,
  467. help_struct->prefix, strlen(help_struct->prefix));
  468. faux_msg_add_param(ack, KTP_PARAM_LINE,
  469. help_struct->line, strlen(help_struct->line));
  470. }
  471. faux_list_free(help_list);
  472. }
  473. faux_msg_send_async(ack, ktpd->async);
  474. faux_msg_free(ack);
  475. kpargv_free(pargv);
  476. return BOOL_TRUE;
  477. }
  478. static bool_t ktpd_session_dispatch(ktpd_session_t *ktpd, faux_msg_t *msg)
  479. {
  480. uint16_t cmd = 0;
  481. assert(ktpd);
  482. if (!ktpd)
  483. return BOOL_FALSE;
  484. assert(msg);
  485. if (!msg)
  486. return BOOL_FALSE;
  487. cmd = faux_msg_get_cmd(msg);
  488. switch (cmd) {
  489. case KTP_CMD:
  490. ktpd_session_process_cmd(ktpd, msg);
  491. break;
  492. case KTP_COMPLETION:
  493. ktpd_session_process_completion(ktpd, msg);
  494. break;
  495. case KTP_HELP:
  496. ktpd_session_process_help(ktpd, msg);
  497. break;
  498. default:
  499. syslog(LOG_WARNING, "Unsupported command: 0x%04u\n", cmd);
  500. break;
  501. }
  502. return BOOL_TRUE;
  503. }
  504. /** @brief Low-level function to receive KTP message.
  505. *
  506. * Firstly function gets the header of message. Then it checks and parses
  507. * header and find out the length of whole message. Then it receives the rest
  508. * of message.
  509. */
  510. static bool_t ktpd_session_read_cb(faux_async_t *async,
  511. faux_buf_t *buf, size_t len, void *user_data)
  512. {
  513. ktpd_session_t *ktpd = (ktpd_session_t *)user_data;
  514. faux_msg_t *completed_msg = NULL;
  515. char *data = NULL;
  516. assert(async);
  517. assert(buf);
  518. assert(ktpd);
  519. // Linearize buffer
  520. data = malloc(len);
  521. faux_buf_read(buf, data, len);
  522. // Receive header
  523. if (!ktpd->hdr) {
  524. size_t whole_len = 0;
  525. size_t msg_wo_hdr = 0;
  526. ktpd->hdr = (faux_hdr_t *)data;
  527. // Check for broken header
  528. if (!ktp_check_header(ktpd->hdr)) {
  529. faux_free(ktpd->hdr);
  530. ktpd->hdr = NULL;
  531. return BOOL_FALSE;
  532. }
  533. whole_len = faux_hdr_len(ktpd->hdr);
  534. // msg_wo_hdr >= 0 because ktp_check_header() validates whole_len
  535. msg_wo_hdr = whole_len - sizeof(faux_hdr_t);
  536. // Plan to receive message body
  537. if (msg_wo_hdr > 0) {
  538. faux_async_set_read_limits(async,
  539. msg_wo_hdr, msg_wo_hdr);
  540. return BOOL_TRUE;
  541. }
  542. // Here message is completed (msg body has zero length)
  543. completed_msg = faux_msg_deserialize_parts(ktpd->hdr, NULL, 0);
  544. // Receive message body
  545. } else {
  546. completed_msg = faux_msg_deserialize_parts(ktpd->hdr, data, len);
  547. faux_free(data);
  548. }
  549. // Plan to receive msg header
  550. faux_async_set_read_limits(ktpd->async,
  551. sizeof(faux_hdr_t), sizeof(faux_hdr_t));
  552. faux_free(ktpd->hdr);
  553. ktpd->hdr = NULL; // Ready to recv new header
  554. // Here message is completed
  555. ktpd_session_dispatch(ktpd, completed_msg);
  556. faux_msg_free(completed_msg);
  557. return BOOL_TRUE;
  558. }
  559. bool_t ktpd_session_connected(ktpd_session_t *ktpd)
  560. {
  561. assert(ktpd);
  562. if (!ktpd)
  563. return BOOL_FALSE;
  564. if (KTPD_SESSION_STATE_DISCONNECTED == ktpd->state)
  565. return BOOL_FALSE;
  566. return BOOL_TRUE;
  567. }
  568. int ktpd_session_fd(const ktpd_session_t *ktpd)
  569. {
  570. assert(ktpd);
  571. if (!ktpd)
  572. return BOOL_FALSE;
  573. return faux_async_fd(ktpd->async);
  574. }
  575. static bool_t action_stdout_ev(faux_eloop_t *eloop, faux_eloop_type_e type,
  576. void *associated_data, void *user_data)
  577. {
  578. faux_eloop_info_fd_t *info = (faux_eloop_info_fd_t *)associated_data;
  579. ktpd_session_t *ktpd = (ktpd_session_t *)user_data;
  580. ssize_t r = -1;
  581. faux_buf_t *faux_buf = NULL;
  582. char *buf = NULL;
  583. ssize_t len = 0;
  584. faux_msg_t *ack = NULL;
  585. // Some errors or fd is closed so remove it from polling
  586. if (!(info->revents & POLLIN)) {
  587. faux_eloop_del_fd(eloop, info->fd);
  588. return BOOL_TRUE;
  589. }
  590. if (!ktpd)
  591. return BOOL_TRUE;
  592. if (!ktpd->exec)
  593. return BOOL_TRUE;
  594. faux_buf = kexec_bufout(ktpd->exec);
  595. assert(faux_buf);
  596. do {
  597. void *linear_buf = NULL;
  598. ssize_t really_readed = 0;
  599. ssize_t linear_len =
  600. faux_buf_dwrite_lock_easy(faux_buf, &linear_buf);
  601. // Non-blocked read. The fd became non-blocked while
  602. // kexec_prepare().
  603. r = read(info->fd, linear_buf, linear_len);
  604. if (r > 0)
  605. really_readed = r;
  606. faux_buf_dwrite_unlock_easy(faux_buf, really_readed);
  607. } while (r > 0);
  608. len = faux_buf_len(faux_buf);
  609. if (0 == len)
  610. return BOOL_TRUE;
  611. buf = malloc(len);
  612. faux_buf_read(faux_buf, buf, len);
  613. // Create KTP_STDOUT message to send to client
  614. ack = ktp_msg_preform(KTP_STDOUT, KTP_STATUS_NONE);
  615. faux_msg_add_param(ack, KTP_PARAM_LINE, buf, len);
  616. faux_msg_send_async(ack, ktpd->async);
  617. faux_msg_free(ack);
  618. free(buf);
  619. // Happy compiler
  620. eloop = eloop;
  621. type = type;
  622. return BOOL_TRUE;
  623. }
  624. static bool_t action_stderr_ev(faux_eloop_t *eloop, faux_eloop_type_e type,
  625. void *associated_data, void *user_data)
  626. {
  627. faux_eloop_info_fd_t *info = (faux_eloop_info_fd_t *)associated_data;
  628. ktpd_session_t *ktpd = (ktpd_session_t *)user_data;
  629. ssize_t r = -1;
  630. faux_buf_t *faux_buf = NULL;
  631. char *buf = NULL;
  632. ssize_t len = 0;
  633. faux_msg_t *ack = NULL;
  634. // Some errors or fd is closed so remove it from polling
  635. if (!(info->revents & POLLIN)) {
  636. faux_eloop_del_fd(eloop, info->fd);
  637. return BOOL_TRUE;
  638. }
  639. if (!ktpd)
  640. return BOOL_TRUE;
  641. if (!ktpd->exec)
  642. return BOOL_TRUE;
  643. faux_buf = kexec_buferr(ktpd->exec);
  644. assert(faux_buf);
  645. do {
  646. void *linear_buf = NULL;
  647. ssize_t really_readed = 0;
  648. ssize_t linear_len =
  649. faux_buf_dwrite_lock_easy(faux_buf, &linear_buf);
  650. // Non-blocked read. The fd became non-blocked while
  651. // kexec_prepare().
  652. r = read(info->fd, linear_buf, linear_len);
  653. if (r > 0)
  654. really_readed = r;
  655. faux_buf_dwrite_unlock_easy(faux_buf, really_readed);
  656. } while (r > 0);
  657. len = faux_buf_len(faux_buf);
  658. if (0 == len)
  659. return BOOL_TRUE;
  660. buf = malloc(len);
  661. faux_buf_read(faux_buf, buf, len);
  662. // Create KTP_STDERR message to send to client
  663. ack = ktp_msg_preform(KTP_STDERR, KTP_STATUS_NONE);
  664. faux_msg_add_param(ack, KTP_PARAM_LINE, buf, len);
  665. faux_msg_send_async(ack, ktpd->async);
  666. faux_msg_free(ack);
  667. free(buf);
  668. // Happy compiler
  669. eloop = eloop;
  670. type = type;
  671. return BOOL_TRUE;
  672. }
  673. bool_t client_ev(faux_eloop_t *eloop, faux_eloop_type_e type,
  674. void *associated_data, void *user_data)
  675. {
  676. faux_eloop_info_fd_t *info = (faux_eloop_info_fd_t *)associated_data;
  677. ktpd_session_t *ktpd = (ktpd_session_t *)user_data;
  678. faux_async_t *async = ktpd->async;
  679. assert(async);
  680. // Write data
  681. if (info->revents & POLLOUT) {
  682. faux_eloop_exclude_fd_event(eloop, info->fd, POLLOUT);
  683. if (faux_async_out(async) < 0) {
  684. // Someting went wrong
  685. faux_eloop_del_fd(eloop, info->fd);
  686. syslog(LOG_ERR, "Problem with async output");
  687. return BOOL_FALSE; // Stop event loop
  688. }
  689. }
  690. // Read data
  691. if (info->revents & POLLIN) {
  692. if (faux_async_in(async) < 0) {
  693. // Someting went wrong
  694. faux_eloop_del_fd(eloop, info->fd);
  695. syslog(LOG_ERR, "Problem with async input");
  696. return BOOL_FALSE; // Stop event loop
  697. }
  698. }
  699. // EOF
  700. if (info->revents & POLLHUP) {
  701. faux_eloop_del_fd(eloop, info->fd);
  702. syslog(LOG_DEBUG, "Close connection %d", info->fd);
  703. return BOOL_FALSE; // Stop event loop
  704. }
  705. // POLLERR
  706. if (info->revents & POLLERR) {
  707. faux_eloop_del_fd(eloop, info->fd);
  708. syslog(LOG_DEBUG, "POLLERR received %d", info->fd);
  709. return BOOL_FALSE; // Stop event loop
  710. }
  711. // POLLNVAL
  712. if (info->revents & POLLNVAL) {
  713. faux_eloop_del_fd(eloop, info->fd);
  714. syslog(LOG_DEBUG, "POLLNVAL received %d", info->fd);
  715. return BOOL_FALSE; // Stop event loop
  716. }
  717. type = type; // Happy compiler
  718. // Session can be really finished here. Note KTPD session can't be
  719. // stopped immediately so it's only two places within code to really
  720. // break the loop. This one and within wait_for_action_ev().
  721. if (ktpd->exit)
  722. return BOOL_FALSE;
  723. return BOOL_TRUE;
  724. }
  725. #if 0
  726. static void ktpd_session_bad_socket(ktpd_session_t *ktpd)
  727. {
  728. assert(ktpd);
  729. if (!ktpd)
  730. return;
  731. ktpd->state = KTPD_SESSION_STATE_DISCONNECTED;
  732. }
  733. #endif