开通博客赚积分
发布资源赚积分
分类

源码开发语言/平台
当前位置：首页 > 源码/资料 > 通讯/手机编程 > 传真(Fax)编程 > 查看源码
trigtest.c++
资源名称：hylafax-5.3.0.tar.gz　[点击查看]
上传用户：weiyuanprp
上传日期：2020-05-20
资源大小：1169k
文件大小：10k
源码类别：

传真(Fax)编程

开发平台：

C/C++

trigtest.c++：源码内容
  1. #include "Sys.h"
  2. #include "Trigger.h"
  3. #include "ModemExt.h"
  4. #include "JobExt.h"
  5. #include "FaxRecvInfo.h"
  6. #include "FaxSendInfo.h"
  7. #include "Socket.h"
  9. #include <stdio.h>
  10. #include <sys/types.h>
  11. #include <sys/select.h>
  12. #include <fcntl.h>
  13. #include <errno.h>
  14. #include <ctype.h>
  15. extern "C" {
  16. #include <netinet/in.h>
  17. }
  19. #include "config.h"
  21. bool verbose = false;
  23. static int
  24. openFIFO(const char* name, int mode)
  25. {
  26.     int fd = open(name, mode|O_NDELAY, 0);
  27.     if (fd == -1) {
  28. perror(name);
  29. return (-1);
  30.     }
  31.     if (fcntl(fd, F_SETFL, fcntl(fd, F_GETFL, 0) | O_NDELAY) < 0) {
  32. perror("fcntl");
  33. return (-1);
  34.     }
  35.     return (fd);
  36. }
  38. static void
  39. send(const char* msg, int msgLen)
  40. {
  41.     int fifo = openFIFO("FIFO", O_WRONLY);
  42.     if (fifo > 0) {
  43. if (write(fifo, msg, msgLen) != msgLen)
  44.     perror("write");
  45. close(fifo);
  46.     }
  47. }
  49. static void
  50. printTime(time_t t)
  51. {
  52.     char buf[80];
  53.     strftime(buf, sizeof (buf), "%h %d %T", localtime(&t));
  54.     printf("%s ", buf);
  55. }
  57. static void
  58. printHeader(const TriggerMsgHeader& h)
  59. {
  60.     printTime(h.tstamp);
  61.     if (verbose)
  62. printf("[ev=%2u, seq#%-3u, len=%3u> ", h.event, h.seqnum, h.length);
  63.     
  64. }
  66. static void
  67. printParams(const Class2Params& params)
  68. {
  69.     printf("<%s, %s, %s, %s, %s>"
  70. , (params.ln == LN_A4 ? "A4" : params.ln == LN_B4 ? "B4" : "INF")
  71. , params.verticalResName()
  72. , params.dataFormatName()
  73. , params.bitRateName()
  74. , params.scanlineTimeName()
  75.     );
  76. }
  78. extern const char* fmtTime(time_t);
  79. static fxStr strTime(time_t t) { return fxStr(fmtTime(t)); }
  81. static const char*
  82. printJob(const TriggerMsgHeader& h, const char* data)
  83. {
  84.     printHeader(h);
  85.     JobExt job;
  86.     data = job.decode(data);
  87.     if (verbose) {
  88. time_t now = Sys::now();
  89. printf(
  90.       "JOB " | job.jobid
  91.     | " (dest " | job.dest
  92.     | (const char*)fxStr::format(" pri %u", job.pri)
  93.     | " tts " | strTime(job.tts - now)
  94.     | " killtime " | strTime(job.killtime - now)
  95.     | "): ");
  96.     } else {
  97. printf(
  98.       "JOB " | job.jobid
  99.     | " (dest " | job.dest
  100.     | fxStr::format(" pri %u", job.pri)
  101.     | "): ");
  102.     }
  103.     return (data);
  104. }
  106. static void
  107. printJobEvent(const TriggerMsgHeader& h, const char* data)
  108. {
  109.     (void) printJob(h, data);
  110.     static const char* jobNames[16] = {
  111. "created",
  112. "suspended",
  113. "ready to send",
  114. "sleeping awaiting time-to-send",
  115. "marked dead",
  116. "being processed by scheduler",
  117. "corpus reaped",
  118. "activated",
  119. "rejected",
  120. "killed",
  121. "blocked by another job",
  122. "delayed by time-of-day restriction or similar",
  123. "parameters altered",
  124. "timed out",
  125. "preparation started",
  126. "preparation finished",
  127.     };
  128.     printf(jobNames[h.event&15]);
  129. }
  131. static void
  132. printSendEvent(const TriggerMsgHeader& h, const char* data)
  133. {
  134.     data = printJob(h, data);
  135.     if (h.event != Trigger::SEND_POLLRCVD) {
  136. static const char* sendNames[16] = {
  137.     "SEND FAX: begin attempt",
  138.     "SEND FAX: call placed (off-hook)",
  139.     "SEND FAX: connected to remote device",
  140.     "#%u",
  141.     "#%u",
  142.     "#%u",
  143.     "#%u",
  144.     "SEND FAX: finished attempt",
  145.     "SEND FAX: reformat documents because of capabilities mismatch",
  146.     "SEND FAX: requeue job",
  147.     "SEND FAX: job completed successfully",
  148.     "unknown event #11",
  149.     "unknown event #12",
  150.     "unknown event #13",
  151.     "unknown event #14",
  152.     "unknown event #15"
  153. };
  154. FaxSendInfo si;
  155. si.decode(data);
  156. switch (h.event) {
  157. case Trigger::SEND_PAGE: // page sent
  158.     printf("SEND FAX: page %u sent in %s (file %s) "
  159. , si.npages
  160. , fmtTime(si.time)
  161. , (const char*) si.qfile
  162.     );
  163.     printParams(si.params);
  164.     break;
  165. case Trigger::SEND_DOC: // document sent
  166.     si.decode(data);
  167.     printf("SEND FAX: document sent in %s (file %s)"
  168. , fmtTime(si.time)
  169. , (const char*) si.qfile
  170.     );
  171.     break;
  172. case Trigger::SEND_POLLDONE: // polling operation done
  173.     si.decode(data);
  174.     printf("SEND FAX: poll op done in %s (file %s)"
  175. , fmtTime(si.time)
  176. , (const char*) si.qfile
  177.     );
  178.     break;
  179. default:
  180.     printf(sendNames[h.event&15], h.event);
  181.     break;
  182. }
  183.     } else {
  184. FaxRecvInfo ri;
  185. ri.decode(data);
  186. printf("SEND FAX: recv polled document from %s, %u pages in %s, file %s"
  187.     , (const char*) ri.sender
  188.     , ri.npages
  189.     , fmtTime((time_t) ri.time)
  190.     , (const char*) ri.qfile
  191. );
  192.     }
  193. }
  195. static void
  196. printModemEvent(const TriggerMsgHeader& h, const char* data)
  197. {
  198.     printHeader(h);
  199.     ModemExt modem;
  200.     data = modem.decode(data);
  201.     static const char* modemNames[16] = {
  202. "MODEM %s, assigned to job",
  203. "MODEM %s, released by job",
  204. "MODEM %s, marked down",
  205. "MODEM %s, marked ready",
  206. "MODEM %s, marked busy",
  207. "MODEM %s, considered wedged",
  208. "MODEM %s, in-use by an outbound job",
  209. "MODEM %s, inbound data call begin",
  210. "MODEM %s, inbound data call completed",
  211. "MODEM %s, inbound voice call begin",
  212. "MODEM %s, inbound voice call completed",
  213. "#11",
  214. "unknown event #12",
  215. "unknown event #13",
  216. "unknown event #14",
  217. "unknown event #15"
  218.     };
  219.     switch (h.event) {
  220.     case Trigger::MODEM_CID:
  221. printf("MODEM %s, caller-id information: %s",
  222.     (const char*) modem.devID, data);
  223. break;
  224.     default:
  225. printf(modemNames[h.event&15], (const char*) modem.devID);
  226. break;
  227.     }
  228. }
  230. static void
  231. printRecvEvent(const TriggerMsgHeader& h, const char* data)
  232. {
  233.     printHeader(h);
  234.     FaxRecvInfo ri;
  235.     ri.decode(data);
  236.     switch (h.event) {
  237.     case Trigger::RECV_BEGIN:
  238. printf("RECV FAX: begin call");
  239. break;
  240.     case Trigger::RECV_END:
  241. printf("RECV FAX: end call");
  242. break;
  243.     case Trigger::RECV_START:
  244. printf("RECV FAX: session started, TSI "%s" "
  245.     , (const char*) ri.sender
  246. );
  247. printParams(ri.params);
  248. break;
  249.     case Trigger::RECV_PAGE:
  250. printf("RECV FAX: from %s, page %u in %s "
  251.     , (const char*) ri.sender
  252.     , ri.npages
  253.     , fmtTime((time_t) ri.time)
  254. );
  255. printParams(ri.params);
  256. break;
  257.     case Trigger::RECV_DOC:
  258. printf("RECV FAX: from %s, %u pages in %s, file %s"
  259.     , (const char*) ri.sender
  260.     , ri.npages
  261.     , fmtTime((time_t) ri.time)
  262.     , (const char*) ri.qfile
  263. );
  264. break;
  265.     default:
  266. printf("unknown event #%u", h.event);
  267. break;
  268.     }
  269. }
  271. #define MAX 5
  273. static char fifoName[80];
  275. void
  276. sigINT(...)
  277. {
  278.     unlink(fifoName);
  279.     exit(-1);
  280. }
  282. static void
  283. reapChildren(...)
  284. {
  285.     int s;
  286.     while (waitpid(-1, &s, WNOHANG) != -1)
  287. ;
  288.     signal(SIGCHLD, reapChildren);
  289. }
  291. void
  292. doProtocol(const char* trigger)
  293. {
  294.     fd_set rd, wr, ex;
  295.     int fd, n;
  297.     fxStr fn = fxStr::format("client/%u", getpid());
  298.     fxAssert(fn.length() >= sizeof(fifoName), "trigtest::doProtocol overrun!");
  299.     strcpy(fifoName, (const char*) fn);
  300.     if (Sys::mkfifo(fifoName, 0666) < 0 && errno != EEXIST) {
  301.         perror("mkfifo");
  302.         exit(-1);
  303.     }
  304.     signal(SIGINT, sigINT);
  305.     signal(SIGTERM, sigINT);
  306.     signal(SIGPIPE, SIG_IGN);
  307.     fd = openFIFO(fifoName, CONFIG_OPENFIFO);
  308.     if (fd < 0) {
  309.         unlink(fifoName);
  310.         exit(-1);
  311.     }
  312.     fxStr msg = fxStr::format("T%s:N%s", fifoName, trigger);
  313.     send((const char*)msg, msg.length() + 1);
  314.     for (;;) {
  315.         FD_ZERO(&rd);
  316.     FD_SET(fd, &rd);
  317.     FD_SET(fileno(stdin), &rd);
  318.         FD_ZERO(&wr);
  319.         FD_ZERO(&ex);
  320.         n = select(FD_SETSIZE, &rd, &wr, &ex, 0);
  321. if (n < 0) {
  322.     perror("select");
  323.     break;
  324. }
  325. if (n == 0) {
  326.     printf("timeoutn");
  327. } else if (n > 0) {
  328.     char buf[16*1024];
  329.     int cc;
  331.     if (FD_ISSET(fd, &rd)) {
  332. while ((cc = read(fd, buf, sizeof (buf)-1)) > 0) {
  333.     buf[cc] = '';
  334.     char* bp = &buf[0];
  335.     do {
  336. char* cp;
  337. switch (bp[0]) {
  338. case 'H': // HELLO
  339. case 'T': // create trigger response
  340.     cp = strchr(bp, '');
  341.     if (cp > bp) {
  342. if (cp[-1] == 'n')
  343.     cp[-1] = '';
  344. if (strncmp(bp, "HELLO", 5) == 0) {
  345.     printTime(Sys::now());
  346.     printf(" HELLO: (Server startup)n");
  347.     send((const char*)msg, msg.length() + 1);
  348. } else if (bp[0] == 'T') {
  349.     printTime(Sys::now());
  350.     if (bp[1] == '!')
  351. printf("TRIGGER: Syntax errorn");
  352.     else
  353. printf("TRIGGER: new trigger #%sn",
  354.     bp+1);
  355. } else {
  356. }
  357.     }
  358.     bp = cp+1;
  359.     break;
  360. case '!': // trigger event message
  361.     TriggerMsgHeader h;
  362.     memcpy(&h, bp, sizeof (h));
  363.     if (h.length > (&buf[cc] - bp)) {
  364. // need more data to complete message
  365.     }
  366.     switch (h.event>>4) {
  367.     case JOB_BASE>>4:
  368. printJobEvent(h, bp+sizeof (h));
  369. break;
  370.     case SEND_BASE>>4:
  371. printSendEvent(h, bp+sizeof (h));
  372. break;
  373.     case RECV_BASE>>4:
  374. printRecvEvent(h, bp+sizeof (h));
  375. break;
  376.     case MODEM_BASE>>4:
  377. printModemEvent(h, bp+sizeof (h));
  378. break;
  379.     default:
  380. printf("Unrecognzied message");
  381.     }
  382.     putc('n', stdout);
  383.     bp += h.length;
  384.     break;
  385. default:
  386.     printf("Unknown trigger messagen");
  387.     break;
  388. }
  389.     } while (bp < &buf[cc]);
  390. }
  391.     }
  392.     if (FD_ISSET(fileno(stdin), &rd)) {
  393. if (fgets(buf, sizeof (buf)-1, stdin) == NULL)
  394.     break; // connection closed
  395. char* cp = strchr(buf, 'n');
  396. if (cp)
  397.     *cp = '';
  398. if (strcmp(buf, "verbose") == 0) {
  399.     verbose = !verbose;
  400.     printf("Verbose %sn", verbose ? "enabled" : "disabled");
  401. }
  402.     }
  403. } else
  404.     printf("(n == 0)n");
  405. fflush(stdout);
  406.     }
  407.     unlink(fifoName);
  408. }
  410. void
  411. main(int argc, char* argv[])
  412. {
  414.     if (argc != 2 && argc != 3) {
  415. fprintf(stderr, "usage: %s [-v] trigger-specn", argv[0]);
  416. exit(-1);
  417.     }
  418.     if (argc == 3) {
  419. verbose = true;
  420. argc--, argv++;
  421.     }
  422.     if (chdir(FAX_SPOOLDIR) == -1) {
  423. perror(FAX_SPOOLDIR);
  424. exit(-1);
  425.     }
  426.     umask(0);
  428.     int s = socket(AF_INET, SOCK_STREAM, 0);
  429.     if (s < 0) {
  430. perror("socket:");
  431. exit(-1);
  432.     }
  433.     struct sockaddr_in sin;
  434.     memset(&sin, 0, sizeof (sin));
  435.     sin.sin_family = AF_INET;
  436.     sin.sin_addr.s_addr = INADDR_ANY;
  437.     sin.sin_port = 4554;
  438.     if (Socket::bind(s, &sin, sizeof (sin)) < 0) {
  439. perror("bind:");
  440. exit(-1);
  441.     }
  442.     signal(SIGCHLD, reapChildren);
  443.     listen(s, 5);
  444.     for (;;) {
  445. Socket::socklen_t sinlen = sizeof (sin);
  446. int c = Socket::accept(s, &sin, &sinlen);
  447. if (c < 0) {
  448.     if (errno == EINTR)
  449. continue;
  450.     perror("accept:");
  451.     exit(-1);
  452. }
  453. switch (fork()) {
  454. case 0: /* child, process protocol */
  455.     close(s);
  456.     if (dup2(c, fileno(stdin)) < 0 || dup2(c, fileno(stdout)) < 0) {
  457. perror("dup2:");
  458. exit(-1);
  459.     }
  460.     doProtocol(argv[1]);
  461.     exit(0);
  462.     /*NOTREACHED*/
  463. case -1: /* fork failure */
  464.     perror("fork:");
  465.     break;
  466. default: /* parent */
  467.     close(c);
  468.     break;
  469. }
  470.     }
  471. }