blob: 74ed53e1e1fe3920622ec29a071dc2d9c6f38c03 [file] [log] [blame]
Neels Hofmeyre9920f22017-07-10 15:07:22 +02001/*
2 * (C) 2016 by sysmocom s.f.m.c. GmbH <info@sysmocom.de>
3 * All Rights Reserved
4 *
5 * Author: Neels Hofmeyr
6 *
7 * This program is free software; you can redistribute it and/or modify
8 * it under the terms of the GNU Affero General Public License as published by
9 * the Free Software Foundation; either version 3 of the License, or
10 * (at your option) any later version.
11 *
12 * This program is distributed in the hope that it will be useful,
13 * but WITHOUT ANY WARRANTY; without even the implied warranty of
14 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
15 * GNU Affero General Public License for more details.
16 *
17 * You should have received a copy of the GNU Affero General Public License
18 * along with this program. If not, see <http://www.gnu.org/licenses/>.
19 */
20
Neels Hofmeyrbd86f942018-02-21 16:45:38 +010021#pragma GCC diagnostic ignored "-Wdeprecated-declarations"
22
Neels Hofmeyre9920f22017-07-10 15:07:22 +020023#include <string.h>
24
25#include <osmocom/core/msgb.h>
26#include <osmocom/core/application.h>
Neels Hofmeyr3a8e7232017-09-04 01:02:56 +020027#include <osmocom/mgcp_client/mgcp_client.h>
28#include <osmocom/mgcp_client/mgcp_client_internal.h>
Neels Hofmeyrc8f37cb2017-11-30 13:43:11 +010029#include <errno.h>
Neels Hofmeyre9920f22017-07-10 15:07:22 +020030
31void *ctx;
32
33#define buf_len 4096
34
35#if 0
36static struct msgb *from_hex(const char *hex)
37{
38 struct msgb *msg = msgb_alloc(buf_len, "mgcpgw_test_from_hex");
39 unsigned int l = osmo_hexparse(hex, msg->data, buf_len);
40 msg->l2h = msgb_put(msg, l);
41 return msg;
42}
43
44static struct msgb *mgcp_from_str(const char *head, const char *params)
45{
46 struct msgb *msg = msgb_alloc(buf_len, "mgcp_from_str");
47 unsigned int l;
48 char *data;
49 l = strlen(head);
50 msg->l2h = msgb_put(msg, l);
51 data = (char*)msgb_l2(msg);
Philipp Maierf8bfbe82017-11-23 19:32:31 +010052 osmo_strlcpy(data, head, l);
Neels Hofmeyre9920f22017-07-10 15:07:22 +020053
54 data = (char*)msgb_put(msg, 1);
55 *data = '\n';
56
57 l = strlen(params);
58 data = (char*)msgb_put(msg, l);
Philipp Maierf8bfbe82017-11-23 19:32:31 +010059 osmo_strlcpy(data, params, l);
Neels Hofmeyre9920f22017-07-10 15:07:22 +020060
61 return msg;
62}
63#endif
64
65static struct msgb *from_str(const char *str)
66{
67 struct msgb *msg = msgb_alloc(buf_len, "from_str");
68 unsigned int l = strlen(str);
69 char *data;
70 msg->l2h = msgb_put(msg, l);
71 data = (char*)msgb_l2(msg);
Philipp Maierf8bfbe82017-11-23 19:32:31 +010072 osmo_strlcpy(data, str, l);
Neels Hofmeyre9920f22017-07-10 15:07:22 +020073 return msg;
74}
75
Neels Hofmeyr3a8e7232017-09-04 01:02:56 +020076static struct mgcp_client_conf conf;
77struct mgcp_client *mgcp = NULL;
Neels Hofmeyre9920f22017-07-10 15:07:22 +020078
Neels Hofmeyrc8f37cb2017-11-30 13:43:11 +010079static int reply_to(mgcp_trans_id_t trans_id, int code, const char *comment,
Neels Hofmeyr1d121482018-09-03 21:05:13 +020080 const char *params)
Neels Hofmeyre9920f22017-07-10 15:07:22 +020081{
82 static char compose[4096 - 128];
83 int len;
84
85 len = snprintf(compose, sizeof(compose),
Neels Hofmeyr1d121482018-09-03 21:05:13 +020086 "%d %u %s\r\n%s",
87 code, trans_id, comment, params);
Neels Hofmeyre9920f22017-07-10 15:07:22 +020088 OSMO_ASSERT(len < sizeof(compose));
89 OSMO_ASSERT(len > 0);
90
91 printf("composed response:\n-----\n%s\n-----\n",
92 compose);
Neels Hofmeyrc8f37cb2017-11-30 13:43:11 +010093 return mgcp_client_rx(mgcp, from_str(compose));
Neels Hofmeyre9920f22017-07-10 15:07:22 +020094}
95
96void test_response_cb(struct mgcp_response *response, void *priv)
97{
Philipp Maier704c4f02018-06-07 18:51:31 +020098 unsigned int i;
Neels Hofmeyre9920f22017-07-10 15:07:22 +020099 OSMO_ASSERT(priv == mgcp);
100 mgcp_response_parse_params(response);
101
Philipp Maier704c4f02018-06-07 18:51:31 +0200102 printf("response cb received:\n");
103 printf(" head.response_code = %d\n", response->head.response_code);
104 printf(" head.trans_id = %u\n", response->head.trans_id);
Neels Hofmeyr40f50332018-09-03 21:12:48 +0200105 printf(" head.conn_id = %s\n", response->head.conn_id);
Philipp Maier704c4f02018-06-07 18:51:31 +0200106 printf(" head.comment = %s\n", response->head.comment);
107 printf(" audio_port = %u\n", response->audio_port);
108 printf(" audio_ip = %s\n", response->audio_ip);
109 printf(" ptime = %u\n", response->ptime);
110 printf(" codecs_len = %u\n", response->codecs_len);
111 for(i=0;i<response->codecs_len;i++)
112 printf(" codecs[%u] = %u\n", i, response->codecs[i]);
113 printf(" ptmap_len = %u\n", response->ptmap_len);
114 for(i=0;i<response->ptmap_len;i++) {
115 printf(" ptmap[%u].codec = %u\n", i, response->ptmap[i].codec);
116 printf(" ptmap[%u].pt = %u\n", i, response->ptmap[i].pt);
117 }
118
Neels Hofmeyre9920f22017-07-10 15:07:22 +0200119}
120
121mgcp_trans_id_t dummy_mgcp_send(struct msgb *msg)
122{
123 mgcp_trans_id_t trans_id;
124 trans_id = msg->cb[MSGB_CB_MGCP_TRANS_ID];
125 char *end;
126
Neels Hofmeyr3a8e7232017-09-04 01:02:56 +0200127 OSMO_ASSERT(mgcp_client_pending_add(mgcp, trans_id, test_response_cb, mgcp));
Neels Hofmeyre9920f22017-07-10 15:07:22 +0200128
129 end = (char*)msgb_put(msg, 1);
130 *end = '\0';
131 printf("composed:\n-----\n%s\n-----\n",
132 (char*)msgb_l2(msg));
133
134 talloc_free(msg);
135 return trans_id;
136}
137
138void test_crcx(void)
139{
140 struct msgb *msg;
141 mgcp_trans_id_t trans_id;
142
143 printf("\n===== %s =====\n", __func__);
144
145 if (mgcp)
146 talloc_free(mgcp);
Neels Hofmeyr3a8e7232017-09-04 01:02:56 +0200147 mgcp = mgcp_client_init(ctx, &conf);
Neels Hofmeyre9920f22017-07-10 15:07:22 +0200148
149 msg = mgcp_msg_crcx(mgcp, 23, 42, MGCP_CONN_LOOPBACK);
150 trans_id = dummy_mgcp_send(msg);
151
Neels Hofmeyr1d121482018-09-03 21:05:13 +0200152 reply_to(trans_id, 200, "OK",
Neels Hofmeyrb1bb1fa2018-09-03 21:07:26 +0200153 "I: 1\r\n\r\n"
Neels Hofmeyre9920f22017-07-10 15:07:22 +0200154 "v=0\r\n"
155 "o=- 1 23 IN IP4 10.9.1.120\r\n"
156 "s=-\r\n"
157 "c=IN IP4 10.9.1.120\r\n"
158 "t=0 0\r\n"
Philipp Maier704c4f02018-06-07 18:51:31 +0200159 "m=audio 16002 RTP/AVP 110 96\r\n"
160 "a=rtpmap:110 AMR/8000\r\n"
161 "a=rtpmap:96 GSM-EFR/8000\r\n"
Neels Hofmeyre9920f22017-07-10 15:07:22 +0200162 "a=ptime:20\r\n");
163}
164
Philipp Maier1dc6be62017-10-05 18:25:37 +0200165void test_mgcp_msg(void)
166{
167 struct msgb *msg;
168 char audio_ip_overflow[5000];
169
170 /* A message struct prefilled with some arbitary values */
171 struct mgcp_msg mgcp_msg = {
172 .audio_ip = "192.168.100.23",
173 .endpoint = "23@mgw",
174 .audio_port = 1234,
175 .call_id = 47,
Philipp Maier01d24a32017-11-21 17:26:09 +0100176 .conn_id = "11",
Philipp Maier704c4f02018-06-07 18:51:31 +0200177 .conn_mode = MGCP_CONN_RECV_SEND,
178 .ptime = 20,
179 .codecs[0] = CODEC_GSM_8000_1,
180 .codecs[1] = CODEC_AMR_8000_1,
181 .codecs[2] = CODEC_GSMEFR_8000_1,
182 .codecs_len = 1,
183 .ptmap[0].codec = CODEC_GSMEFR_8000_1,
184 .ptmap[0].pt = 96,
Neels Hofmeyre6d8e912018-08-23 16:36:48 +0200185 .ptmap_len = 1,
186 .x_osmo_ign = MGCP_X_OSMO_IGN_CALLID,
Philipp Maier1dc6be62017-10-05 18:25:37 +0200187 };
188
189 if (mgcp)
190 talloc_free(mgcp);
191 mgcp = mgcp_client_init(ctx, &conf);
192
193 printf("\n");
194
195 printf("Generated CRCX message:\n");
196 mgcp_msg.verb = MGCP_VERB_CRCX;
197 mgcp_msg.presence =
198 (MGCP_MSG_PRESENCE_ENDPOINT | MGCP_MSG_PRESENCE_CALL_ID |
199 MGCP_MSG_PRESENCE_CONN_ID | MGCP_MSG_PRESENCE_CONN_MODE);
200 msg = mgcp_msg_gen(mgcp, &mgcp_msg);
201 printf("%s\n", (char *)msg->data);
202
Philipp Maier704c4f02018-06-07 18:51:31 +0200203 printf("Generated CRCX message (two codecs):\n");
204 mgcp_msg.verb = MGCP_VERB_CRCX;
205 mgcp_msg.presence =
206 (MGCP_MSG_PRESENCE_ENDPOINT | MGCP_MSG_PRESENCE_CALL_ID |
207 MGCP_MSG_PRESENCE_CONN_ID | MGCP_MSG_PRESENCE_CONN_MODE);
208 mgcp_msg.codecs_len = 2;
209 msg = mgcp_msg_gen(mgcp, &mgcp_msg);
210 mgcp_msg.codecs_len = 1;
211 printf("%s\n", (char *)msg->data);
212
213 printf("Generated CRCX message (three codecs, one with custom pt):\n");
214 mgcp_msg.verb = MGCP_VERB_CRCX;
215 mgcp_msg.presence =
216 (MGCP_MSG_PRESENCE_ENDPOINT | MGCP_MSG_PRESENCE_CALL_ID |
217 MGCP_MSG_PRESENCE_CONN_ID | MGCP_MSG_PRESENCE_CONN_MODE);
218 mgcp_msg.codecs_len = 3;
219 msg = mgcp_msg_gen(mgcp, &mgcp_msg);
220 mgcp_msg.codecs_len = 1;
221 printf("%s\n", (char *)msg->data);
222
Philipp Maier1dc6be62017-10-05 18:25:37 +0200223 printf("Generated MDCX message:\n");
224 mgcp_msg.verb = MGCP_VERB_MDCX;
225 mgcp_msg.presence =
226 (MGCP_MSG_PRESENCE_ENDPOINT | MGCP_MSG_PRESENCE_CALL_ID |
227 MGCP_MSG_PRESENCE_CONN_ID | MGCP_MSG_PRESENCE_CONN_MODE |
228 MGCP_MSG_PRESENCE_AUDIO_IP | MGCP_MSG_PRESENCE_AUDIO_PORT);
229 msg = mgcp_msg_gen(mgcp, &mgcp_msg);
230 printf("%s\n", (char *)msg->data);
231
Philipp Maier704c4f02018-06-07 18:51:31 +0200232 printf("Generated MDCX message (two codecs):\n");
233 mgcp_msg.verb = MGCP_VERB_MDCX;
234 mgcp_msg.presence =
235 (MGCP_MSG_PRESENCE_ENDPOINT | MGCP_MSG_PRESENCE_CALL_ID |
236 MGCP_MSG_PRESENCE_CONN_ID | MGCP_MSG_PRESENCE_CONN_MODE |
237 MGCP_MSG_PRESENCE_AUDIO_IP | MGCP_MSG_PRESENCE_AUDIO_PORT);
238 mgcp_msg.codecs_len = 2;
239 msg = mgcp_msg_gen(mgcp, &mgcp_msg);
240 mgcp_msg.codecs_len = 1;
241 printf("%s\n", (char *)msg->data);
242
243 printf("Generated MDCX message (three codecs, one with custom pt):\n");
244 mgcp_msg.verb = MGCP_VERB_MDCX;
245 mgcp_msg.presence =
246 (MGCP_MSG_PRESENCE_ENDPOINT | MGCP_MSG_PRESENCE_CALL_ID |
247 MGCP_MSG_PRESENCE_CONN_ID | MGCP_MSG_PRESENCE_CONN_MODE |
248 MGCP_MSG_PRESENCE_AUDIO_IP | MGCP_MSG_PRESENCE_AUDIO_PORT);
249 mgcp_msg.codecs_len = 3;
250 msg = mgcp_msg_gen(mgcp, &mgcp_msg);
251 mgcp_msg.codecs_len = 1;
252 printf("%s\n", (char *)msg->data);
253
Philipp Maier1dc6be62017-10-05 18:25:37 +0200254 printf("Generated DLCX message:\n");
255 mgcp_msg.verb = MGCP_VERB_DLCX;
256 mgcp_msg.presence =
257 (MGCP_MSG_PRESENCE_ENDPOINT | MGCP_MSG_PRESENCE_CALL_ID |
258 MGCP_MSG_PRESENCE_CONN_ID);
259 msg = mgcp_msg_gen(mgcp, &mgcp_msg);
260 printf("%s\n", (char *)msg->data);
261
262 printf("Generated AUEP message:\n");
263 mgcp_msg.verb = MGCP_VERB_AUEP;
264 mgcp_msg.presence = (MGCP_MSG_PRESENCE_ENDPOINT);
265 msg = mgcp_msg_gen(mgcp, &mgcp_msg);
266 printf("%s\n", msg->data);
267
268 printf("Generated RSIP message:\n");
269 mgcp_msg.verb = MGCP_VERB_RSIP;
270 mgcp_msg.presence = (MGCP_MSG_PRESENCE_ENDPOINT);
271 msg = mgcp_msg_gen(mgcp, &mgcp_msg);
272 printf("%s\n", (char *)msg->data);
273
Neels Hofmeyre6d8e912018-08-23 16:36:48 +0200274 printf("Generate X-Osmo-IGN message:\n");
275 msg = mgcp_msg_gen(mgcp, &mgcp_msg);
276 mgcp_msg.verb = MGCP_VERB_CRCX;
277 mgcp_msg.presence =
278 (MGCP_MSG_PRESENCE_ENDPOINT | MGCP_MSG_PRESENCE_CALL_ID |
279 MGCP_MSG_PRESENCE_CONN_ID | MGCP_MSG_PRESENCE_CONN_MODE
280 | MGCP_MSG_PRESENCE_X_OSMO_IGN);
281 msg = mgcp_msg_gen(mgcp, &mgcp_msg);
282 printf("%s\n", (char *)msg->data);
283
Philipp Maier1dc6be62017-10-05 18:25:37 +0200284 printf("Overfolow test:\n");
285 mgcp_msg.verb = MGCP_VERB_MDCX;
286 mgcp_msg.presence =
287 (MGCP_MSG_PRESENCE_ENDPOINT | MGCP_MSG_PRESENCE_CALL_ID |
288 MGCP_MSG_PRESENCE_CONN_ID | MGCP_MSG_PRESENCE_CONN_MODE |
289 MGCP_MSG_PRESENCE_AUDIO_IP | MGCP_MSG_PRESENCE_AUDIO_PORT);
290 memset(audio_ip_overflow, 'X', sizeof(audio_ip_overflow));
291 audio_ip_overflow[sizeof(audio_ip_overflow) - 1] = '\0';
292 mgcp_msg.audio_ip = audio_ip_overflow;
293 msg = mgcp_msg_gen(mgcp, &mgcp_msg);
294 OSMO_ASSERT(msg == NULL);
295
296 printf("\n");
297 msgb_free(msg);
298}
299
Neels Hofmeyrc8f37cb2017-11-30 13:43:11 +0100300void test_mgcp_client_cancel()
301{
302 mgcp_trans_id_t trans_id;
303 struct msgb *msg;
304 struct mgcp_msg mgcp_msg = {
305 .verb = MGCP_VERB_CRCX,
306 .audio_ip = "192.168.100.23",
307 .endpoint = "23@mgw",
308 .audio_port = 1234,
309 .call_id = 47,
Philipp Maier922ae9a2017-12-04 15:53:37 +0100310 .conn_id = "11",
Neels Hofmeyrc8f37cb2017-11-30 13:43:11 +0100311 .conn_mode = MGCP_CONN_RECV_SEND,
312 .presence = (MGCP_MSG_PRESENCE_ENDPOINT | MGCP_MSG_PRESENCE_CALL_ID
313 | MGCP_MSG_PRESENCE_CONN_ID | MGCP_MSG_PRESENCE_CONN_MODE),
Philipp Maier704c4f02018-06-07 18:51:31 +0200314 .ptime = 20,
315 .codecs[0] = CODEC_AMR_8000_1,
316 .codecs_len = 1
Neels Hofmeyrc8f37cb2017-11-30 13:43:11 +0100317 };
318
319 printf("\n%s():\n", __func__);
320 fprintf(stderr, "\n%s():\n", __func__);
321
322 if (mgcp)
323 talloc_free(mgcp);
324 mgcp = mgcp_client_init(ctx, &conf);
325
326 msg = mgcp_msg_gen(mgcp, &mgcp_msg);
327 trans_id = mgcp_msg_trans_id(msg);
328 fprintf(stderr, "- composed msg with trans_id=%u\n", trans_id);
329
330 fprintf(stderr, "- not in queue yet, cannot cancel yet\n");
331 OSMO_ASSERT(mgcp_client_cancel(mgcp, trans_id) == -ENOENT);
332
333 fprintf(stderr, "- enqueue\n");
334 dummy_mgcp_send(msg);
335
336 fprintf(stderr, "- cancel succeeds\n");
337 OSMO_ASSERT(mgcp_client_cancel(mgcp, trans_id) == 0);
338
339 fprintf(stderr, "- late response gets discarded\n");
Neels Hofmeyrb1bb1fa2018-09-03 21:07:26 +0200340 OSMO_ASSERT(reply_to(trans_id, 200, "OK", "I: 1\r\n\r\nv=0\r\n") == -ENOENT);
Neels Hofmeyrc8f37cb2017-11-30 13:43:11 +0100341
342 fprintf(stderr, "- canceling again does nothing\n");
343 OSMO_ASSERT(mgcp_client_cancel(mgcp, trans_id) == -ENOENT);
344
345 fprintf(stderr, "%s() done\n", __func__);
346}
347
Neels Hofmeyra8c6a9c2018-02-21 15:36:45 +0100348struct sdp_section_start_test {
349 const char *body;
350 int expect_rc;
351 struct mgcp_response expect_params;
352};
353
354static struct sdp_section_start_test sdp_section_start_tests[] = {
355 {
356 .body = "",
357 .expect_rc = -EINVAL,
358 },
359 {
360 .body = "\n\n",
361 },
362 {
363 .body = "\r\n\r\n",
364 },
365 {
366 .body = "\n\r\n\r",
367 },
368 {
369 .body = "some mgcp header data\r\nand header params"
370 "\n\n"
371 "m=audio 23\r\n",
372 .expect_params = {
373 .audio_port = 23,
374 },
375 },
376 {
377 .body = "some mgcp header data\r\nand header params"
378 "\r\n\r\n"
379 "m=audio 23\r\n",
380 .expect_params = {
381 .audio_port = 23,
382 },
383 },
384 {
385 .body = "some mgcp header data\r\nand header params"
386 "\n\r\n\r"
387 "m=audio 23\r\n",
388 .expect_params = {
389 .audio_port = 23,
390 },
391 },
392 {
393 .body = "some mgcp header data\r\nand header params"
394 "\n\r\n"
395 "m=audio 23\r\n",
396 .expect_rc = -EINVAL,
397 },
398 {
399 .body = "some mgcp header data\r\nand header params"
400 "\r\n\r"
401 "m=audio 23\r\n",
402 .expect_rc = -EINVAL,
403 },
404 {
405 .body = "some mgcp header data\r\nand header params"
406 "\n\r\r"
407 "m=audio 23\r\n",
408 .expect_rc = -EINVAL,
409 },
410};
411
412void test_sdp_section_start()
413{
414 int i;
415 int failures = 0;
416
417 for (i = 0; i < ARRAY_SIZE(sdp_section_start_tests); i++) {
418 int rc;
419 struct sdp_section_start_test *t = &sdp_section_start_tests[i];
420 struct mgcp_response *r = talloc_zero(ctx, struct mgcp_response);
421
422 r->body = talloc_strdup(r, t->body);
423
424 printf("\n%s() test [%d]:\n", __func__, i);
425 fprintf(stderr, "\n%s() test [%d]:\n", __func__, i);
426 fprintf(stderr, "body: \"%s\"\n", osmo_escape_str(r->body, -1));
427
428 rc = mgcp_response_parse_params(r);
429
430 fprintf(stderr, "got rc=%d\n", rc);
431 if (rc != t->expect_rc) {
432 fprintf(stderr, "FAIL: Expected rc=%d\n", t->expect_rc);
433 failures++;
434 }
435 if (rc) {
436 talloc_free(r);
437 continue;
438 }
439
440 fprintf(stderr, "got audio_port=%u\n", t->expect_params.audio_port);
441 if (r->audio_port != t->expect_params.audio_port) {
442 fprintf(stderr, "FAIL: Expected audio_port=%u\n", t->expect_params.audio_port);
443 failures++;
444 }
445 talloc_free(r);
446 }
447
Neels Hofmeyra8c6a9c2018-02-21 15:36:45 +0100448 OSMO_ASSERT(!failures);
Neels Hofmeyra8c6a9c2018-02-21 15:36:45 +0100449}
450
Philipp Maier704c4f02018-06-07 18:51:31 +0200451static void test_map_pt_to_codec(void)
452{
453 /* Full form */
454 OSMO_ASSERT(map_str_to_codec("PCMU/8000/1") == CODEC_PCMU_8000_1);
455 OSMO_ASSERT(map_str_to_codec("GSM/8000/1") == CODEC_GSM_8000_1);
456 OSMO_ASSERT(map_str_to_codec("PCMA/8000/1") == CODEC_PCMA_8000_1);
457 OSMO_ASSERT(map_str_to_codec("G729/8000/1") == CODEC_G729_8000_1);
458 OSMO_ASSERT(map_str_to_codec("GSM-EFR/8000/1") == CODEC_GSMEFR_8000_1);
459 OSMO_ASSERT(map_str_to_codec("GSM-HR-08/8000/1") == CODEC_GSMHR_8000_1);
460 OSMO_ASSERT(map_str_to_codec("AMR/8000/1") == CODEC_AMR_8000_1);
461 OSMO_ASSERT(map_str_to_codec("AMR-WB/16000/1") == CODEC_AMRWB_16000_1);
462
463 /* Short form */
464 OSMO_ASSERT(map_str_to_codec("GSM-EFR") == CODEC_GSMEFR_8000_1);
465 OSMO_ASSERT(map_str_to_codec("G729") == CODEC_G729_8000_1);
466 OSMO_ASSERT(map_str_to_codec("GSM-HR-08") == CODEC_GSMHR_8000_1);
467
468 /* We do not care about what is after the first delimiter */
469 OSMO_ASSERT(map_str_to_codec("AMR-WB/123///456") == CODEC_AMRWB_16000_1);
470 OSMO_ASSERT(map_str_to_codec("PCMA/asdf") == CODEC_PCMA_8000_1);
471 OSMO_ASSERT(map_str_to_codec("GSM/qwertz") == CODEC_GSM_8000_1);
472
473 /* A trailing delimiter should not hurt */
474 OSMO_ASSERT(map_str_to_codec("AMR/") == CODEC_AMR_8000_1);
475 OSMO_ASSERT(map_str_to_codec("G729/") == CODEC_G729_8000_1);
476 OSMO_ASSERT(map_str_to_codec("GSM/") == CODEC_GSM_8000_1);
477
478 /* This is expected to fail */
479 OSMO_ASSERT(map_str_to_codec("INVALID/1234/7") == -1);
480 OSMO_ASSERT(map_str_to_codec(NULL) == -1);
481 OSMO_ASSERT(map_str_to_codec("") == -1);
482 OSMO_ASSERT(map_str_to_codec("/////") == -1);
483
484 /* The buffers are 64 bytes long, check what happens with overlong
485 * strings as input (This schould still work.) */
486 OSMO_ASSERT(map_str_to_codec("AMR-WB/16000/1############################################################################################################") == CODEC_AMRWB_16000_1);
487
488 /* This should not work, as there is no delimiter after the codec
489 * name */
490 OSMO_ASSERT(map_str_to_codec("AMR-WB####################################################################################################################") == -1);
491}
492
493static void test_map_codec_to_pt_and_map_pt_to_codec(void)
494{
495 struct ptmap ptmap[10];
496 unsigned int ptmap_len;
497 unsigned int i;
498
499 ptmap[0].codec = CODEC_GSMEFR_8000_1;
500 ptmap[0].pt = 96;
501 ptmap[1].codec = CODEC_GSMHR_8000_1;
502 ptmap[1].pt = 97;
503 ptmap[2].codec = CODEC_AMR_8000_1;
504 ptmap[2].pt = 98;
505 ptmap[3].codec = CODEC_AMRWB_16000_1;
506 ptmap[3].pt = 99;
507 ptmap_len = 4;
508
509 /* Mappings that are covered by the table */
510 for (i = 0; i < ptmap_len; i++)
511 printf(" %u => %u\n", ptmap[i].codec, map_codec_to_pt(ptmap, ptmap_len, ptmap[i].codec));
512 for (i = 0; i < ptmap_len; i++)
513 printf(" %u <= %u\n", ptmap[i].pt, map_pt_to_codec(ptmap, ptmap_len, ptmap[i].pt));
514 printf("\n");
515
516 /* Map some codecs/payload types from the static range, result must
517 * always be a 1:1 mapping */
518 printf(" %u => %u\n", CODEC_PCMU_8000_1, map_codec_to_pt(ptmap, ptmap_len, CODEC_PCMU_8000_1));
519 printf(" %u => %u\n", CODEC_GSM_8000_1, map_codec_to_pt(ptmap, ptmap_len, CODEC_GSM_8000_1));
520 printf(" %u => %u\n", CODEC_PCMA_8000_1, map_codec_to_pt(ptmap, ptmap_len, CODEC_PCMA_8000_1));
521 printf(" %u => %u\n", CODEC_G729_8000_1, map_codec_to_pt(ptmap, ptmap_len, CODEC_G729_8000_1));
522 printf(" %u <= %u\n", CODEC_PCMU_8000_1, map_pt_to_codec(ptmap, ptmap_len, CODEC_PCMU_8000_1));
523 printf(" %u <= %u\n", CODEC_GSM_8000_1, map_pt_to_codec(ptmap, ptmap_len, CODEC_GSM_8000_1));
524 printf(" %u <= %u\n", CODEC_PCMA_8000_1, map_pt_to_codec(ptmap, ptmap_len, CODEC_PCMA_8000_1));
525 printf(" %u <= %u\n", CODEC_G729_8000_1, map_pt_to_codec(ptmap, ptmap_len, CODEC_G729_8000_1));
526 printf("\n");
527
528 /* Try to do mappings from statically defined range to danymic range and vice versa. This
529 * is illegal and should result into a 1:1 mapping */
530 ptmap[3].codec = CODEC_AMRWB_16000_1;
531 ptmap[3].pt = 2;
532 ptmap[4].codec = CODEC_PCMU_8000_1;
533 ptmap[4].pt = 100;
534 ptmap_len = 5;
535
536 /* Apply all mappings again, the illegal ones we defined should result into 1:1 mappings */
537 for (i = 0; i < ptmap_len; i++)
538 printf(" %u => %u\n", ptmap[i].codec, map_codec_to_pt(ptmap, ptmap_len, ptmap[i].codec));
539 for (i = 0; i < ptmap_len; i++)
540 printf(" %u <= %u\n", ptmap[i].pt, map_pt_to_codec(ptmap, ptmap_len, ptmap[i].pt));
541 printf("\n");
542}
543
Neels Hofmeyre9920f22017-07-10 15:07:22 +0200544static const struct log_info_cat log_categories[] = {
545};
546
547const struct log_info log_info = {
548 .cat = log_categories,
549 .num_cat = ARRAY_SIZE(log_categories),
550};
551
552
553int main(int argc, char **argv)
554{
Neels Hofmeyr3a8e7232017-09-04 01:02:56 +0200555 ctx = talloc_named_const(NULL, 1, "mgcp_client_test");
Neels Hofmeyre9920f22017-07-10 15:07:22 +0200556 msgb_talloc_ctx_init(ctx, 0);
Neels Hofmeyr60f8e312018-03-30 23:01:07 +0200557 osmo_init_logging2(ctx, &log_info);
Philipp Maier8348abb2017-10-25 12:14:13 +0200558 log_set_print_filename(osmo_stderr_target, 0);
559 log_set_print_timestamp(osmo_stderr_target, 0);
560 log_set_use_color(osmo_stderr_target, 0);
561 log_set_print_category(osmo_stderr_target, 1);
Neels Hofmeyre9920f22017-07-10 15:07:22 +0200562
Neels Hofmeyrc8f37cb2017-11-30 13:43:11 +0100563 log_set_category_filter(osmo_stderr_target, DLMGCP, 1, LOGL_DEBUG);
564
Neels Hofmeyr3a8e7232017-09-04 01:02:56 +0200565 mgcp_client_conf_init(&conf);
Neels Hofmeyre9920f22017-07-10 15:07:22 +0200566
567 test_crcx();
Philipp Maier1dc6be62017-10-05 18:25:37 +0200568 test_mgcp_msg();
Neels Hofmeyrc8f37cb2017-11-30 13:43:11 +0100569 test_mgcp_client_cancel();
Neels Hofmeyra8c6a9c2018-02-21 15:36:45 +0100570 test_sdp_section_start();
Philipp Maier704c4f02018-06-07 18:51:31 +0200571 test_map_codec_to_pt_and_map_pt_to_codec();
572 test_map_pt_to_codec();
Neels Hofmeyre9920f22017-07-10 15:07:22 +0200573
574 printf("Done\n");
575 fprintf(stderr, "Done\n");
576 return EXIT_SUCCESS;
577}