FreeCalypso > hg > themwi-system-sw

comparison mgw/main.c @ 127:f062c32a5116

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
mgw: implement DTMF
author Mychaela Falconia <falcon@freecalypso.org>
date Sat, 01 Oct 2022 20:31:15 -0800
parents 815e4c59162e
children a6eb2de277f6
comparison
equal deleted inserted replaced
126:815e4c59162e 127:f062c32a5116
1 /* 1 /*
2 * Main module for themwi-mgw. 2 * Main module for themwi-mgw.
3 */ 3 */
4 4
5 #include <sys/types.h> 5 #include <sys/types.h>
6 #include <sys/time.h>
6 #include <sys/errno.h> 7 #include <sys/errno.h>
7 #include <stdio.h> 8 #include <stdio.h>
8 #include <stdint.h> 9 #include <stdint.h>
9 #include <stdlib.h> 10 #include <stdlib.h>
10 #include <string.h> 11 #include <string.h>
11 #include <strings.h> 12 #include <strings.h>
12 #include <signal.h> 13 #include <signal.h>
13 #include <syslog.h> 14 #include <syslog.h>
14 #include <unistd.h> 15 #include <unistd.h>
15 16
17 extern int dtmf_timer_running;
18 extern struct timeval dtmf_next_time;
19
16 fd_set select_for_read; 20 fd_set select_for_read;
17 void (*select_handlers[FD_SETSIZE])(); 21 void (*select_handlers[FD_SETSIZE])();
18 void *select_data[FD_SETSIZE]; 22 void *select_data[FD_SETSIZE];
23 struct timeval cur_event_time;
19 24
20 static int max_fd; 25 static int max_fd;
21 26
22 update_max_fd(newfd) 27 update_max_fd(newfd)
23 { 28 {
32 37
33 main(argc, argv) 38 main(argc, argv)
34 char **argv; 39 char **argv;
35 { 40 {
36 fd_set fds; 41 fd_set fds;
42 struct timeval timeout;
37 int cc, i; 43 int cc, i;
38 44
39 openlog("themwi-mgw", 0, LOG_LOCAL5); 45 openlog("themwi-mgw", 0, LOG_LOCAL5);
40 read_config_file(); 46 read_config_file();
41 dtmf_init_sample_arrays(); 47 dtmf_init_sample_arrays();
45 } 51 }
46 signal(SIGPIPE, SIG_IGN); 52 signal(SIGPIPE, SIG_IGN);
47 /* main select loop */ 53 /* main select loop */
48 for (;;) { 54 for (;;) {
49 bcopy(&select_for_read, &fds, sizeof(fd_set)); 55 bcopy(&select_for_read, &fds, sizeof(fd_set));
50 cc = select(max_fd+1, &fds, 0, 0, 0); 56 if (dtmf_timer_running) {
57 if (timercmp(&dtmf_next_time, &cur_event_time, >))
58 timersub(&dtmf_next_time, &cur_event_time,
59 &timeout);
60 else
61 timerclear(&timeout);
62 cc = select(max_fd+1, &fds, 0, 0, &timeout);
63 } else
64 cc = select(max_fd+1, &fds, 0, 0, 0);
51 if (cc < 0) { 65 if (cc < 0) {
52 if (errno == EINTR) 66 if (errno == EINTR)
53 continue; 67 continue;
54 syslog(LOG_CRIT, "select: %m"); 68 syslog(LOG_CRIT, "select: %m");
55 exit(1); 69 exit(1);
56 } 70 }
71 gettimeofday(&cur_event_time, 0);
57 for (i = 0; cc && i <= max_fd; i++) { 72 for (i = 0; cc && i <= max_fd; i++) {
58 if (FD_ISSET(i, &fds)) { 73 if (FD_ISSET(i, &fds)) {
59 select_handlers[i](i, select_data[i]); 74 select_handlers[i](i, select_data[i]);
60 cc--; 75 cc--;
61 } 76 }
62 } 77 }
78 if (dtmf_timer_running &&
79 !timercmp(&cur_event_time, &dtmf_next_time, <))
80 dtmf_timer_process();
63 free_deleted_endpoints(); 81 free_deleted_endpoints();
64 } 82 }
65 } 83 }