1 #include "freetdm.h"
2 #include <signal.h>
3 #include <stdlib.h>
4
5 static volatile int running = 0;
6 static ftdm_mutex_t *the_mutex = NULL;
7 static ftdm_channel_t *fchan = NULL;
8 static ftdm_channel_indication_t indication = FTDM_CHANNEL_INDICATE_NONE;
9
FIO_SIGNAL_CB_FUNCTION(on_r2_signal)10 static FIO_SIGNAL_CB_FUNCTION(on_r2_signal)
11 {
12 int chanid = ftdm_channel_get_ph_id(sigmsg->channel);
13 ftdm_log(FTDM_LOG_DEBUG, "Got R2 channel sig [%s] in channel %d\n", ftdm_signal_event2str(sigmsg->event_id), chanid);
14 switch (sigmsg->event_id) {
15 case FTDM_SIGEVENT_START:
16 {
17 ftdm_mutex_lock(the_mutex);
18 if (!fchan) {
19 fchan = sigmsg->channel;
20 indication = FTDM_CHANNEL_INDICATE_PROCEED;
21 }
22 ftdm_mutex_unlock(the_mutex);
23 }
24 break;
25 case FTDM_SIGEVENT_INDICATION_COMPLETED:
26 {
27 ftdm_channel_indication_t ind = FTDM_CHANNEL_INDICATE_NONE;
28 if (sigmsg->ev_data.indication_completed.indication == FTDM_CHANNEL_INDICATE_PROCEED) {
29 ftdm_log(FTDM_LOG_DEBUG, "Proceed indication result = %d\n", sigmsg->ev_data.indication_completed.status);
30 ind = FTDM_CHANNEL_INDICATE_PROGRESS;
31 } else if (sigmsg->ev_data.indication_completed.indication == FTDM_CHANNEL_INDICATE_PROGRESS) {
32 ftdm_log(FTDM_LOG_DEBUG, "Progress indication result = %d\n", sigmsg->ev_data.indication_completed.status);
33 ind = FTDM_CHANNEL_INDICATE_PROGRESS_MEDIA;
34 } else if (sigmsg->ev_data.indication_completed.indication == FTDM_CHANNEL_INDICATE_PROGRESS_MEDIA) {
35 ftdm_log(FTDM_LOG_DEBUG, "Progress media indication result = %d\n", sigmsg->ev_data.indication_completed.status);
36 ind = FTDM_CHANNEL_INDICATE_ANSWER;
37 } else if (sigmsg->ev_data.indication_completed.indication == FTDM_CHANNEL_INDICATE_ANSWER) {
38 ftdm_log(FTDM_LOG_DEBUG, "Answer indication result = %d\n", sigmsg->ev_data.indication_completed.status);
39 } else {
40 ftdm_log(FTDM_LOG_DEBUG, "Unexpected indication, result = %d\n", sigmsg->ev_data.indication_completed.status);
41 exit(1);
42 }
43 ftdm_mutex_lock(the_mutex);
44 if (fchan) {
45 indication = ind;
46 }
47 ftdm_mutex_unlock(the_mutex);
48 }
49 break;
50 case FTDM_SIGEVENT_STOP:
51 {
52 ftdm_channel_call_hangup(sigmsg->channel);
53 }
54 break;
55 case FTDM_SIGEVENT_RELEASED:
56 {
57 ftdm_mutex_lock(the_mutex);
58 if (fchan && fchan == sigmsg->channel) {
59 fchan = NULL;
60 }
61 ftdm_mutex_unlock(the_mutex);
62 }
63 break;
64 default:
65 break;
66 }
67 return FTDM_SUCCESS;
68 }
69
stop_test(int sig)70 static void stop_test(int sig)
71 {
72 ftdm_unused_arg(sig);
73 running = 0;
74 }
75
main(int argc,char * argv[])76 int main(int argc, char *argv[])
77 {
78 ftdm_span_t *span;
79 ftdm_conf_parameter_t parameters[20];
80
81 ftdm_mutex_create(&the_mutex);
82
83 if (argc < 2) {
84 printf("umm no\n");
85 exit(1);
86 }
87
88 ftdm_global_set_default_logger(FTDM_LOG_LEVEL_DEBUG);
89
90 if (ftdm_global_init() != FTDM_SUCCESS) {
91 fprintf(stderr, "Error loading FreeTDM\n");
92 exit(1);
93 }
94
95 ftdm_global_configuration();
96
97 printf("FreeTDM loaded\n");
98
99 if (ftdm_span_find_by_name(argv[1], &span) != FTDM_SUCCESS) {
100 fprintf(stderr, "Error finding FreeTDM span %s\n", argv[1]);
101 goto done;
102 }
103
104 /* testing non-blocking operation */
105 //ftdm_span_set_blocking_mode(span, FTDM_FALSE);
106
107 parameters[0].var = "variant";
108 parameters[0].val = "br";
109
110 parameters[1].var = "max_ani";
111 parameters[1].val = "4";
112
113 parameters[2].var = "max_dnis";
114 parameters[2].val = "4";
115
116 parameters[3].var = "logging";
117 parameters[3].val = "all";
118
119 parameters[4].var = NULL;
120 parameters[4].val = NULL;
121
122 if (ftdm_configure_span_signaling(span, "r2", on_r2_signal, parameters) == FTDM_SUCCESS) {
123 ftdm_span_start(span);
124 } else {
125 fprintf(stderr, "Error starting R2 span\n");
126 goto done;
127 }
128
129 running = 1;
130 signal(SIGINT, stop_test);
131 while(running) {
132 ftdm_sleep(20);
133 if (fchan && indication != FTDM_CHANNEL_INDICATE_NONE) {
134 ftdm_channel_t *lchan = NULL;
135 ftdm_channel_indication_t ind = FTDM_CHANNEL_INDICATE_NONE;
136 ftdm_time_t start, stop, diff;
137
138 ftdm_mutex_lock(the_mutex);
139 ind = indication;
140 indication = FTDM_CHANNEL_INDICATE_NONE;
141 lchan = fchan;
142 ftdm_mutex_unlock(the_mutex);
143
144 start = ftdm_current_time_in_ms();
145 ftdm_channel_call_indicate(lchan, ind);
146 stop = ftdm_current_time_in_ms();
147 diff = stop - start;
148 ftdm_log(FTDM_LOG_DEBUG, "Setting indication %s took %"FTDM_TIME_FMT" ms\n",
149 ftdm_channel_indication2str(ind), diff);
150 }
151 }
152
153 done:
154
155 ftdm_global_destroy();
156
157 return 0;
158 }
159
160 /* For Emacs:
161 * Local Variables:
162 * mode:c
163 * indent-tabs-mode:t
164 * tab-width:4
165 * c-basic-offset:4
166 * End:
167 * For VIM:
168 * vim:set softtabstop=4 shiftwidth=4 tabstop=4 noet:
169 */
170