blob: 2662fc12a332eb8b4097d9cbf8fc0c0ea7fd28c7 [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 Hofmeyre9920f22017-07-10 15:07:22 +020080 int conn_id, const char *params)
81{
82 static char compose[4096 - 128];
83 int len;
84
85 len = snprintf(compose, sizeof(compose),
86 "%d %u %s\r\nI: %d\n\n%s",
87 code, trans_id, comment, conn_id, params);
88 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);
105 printf(" head.comment = %s\n", response->head.comment);
106 printf(" audio_port = %u\n", response->audio_port);
107 printf(" audio_ip = %s\n", response->audio_ip);
108 printf(" ptime = %u\n", response->ptime);
109 printf(" codecs_len = %u\n", response->codecs_len);
110 for(i=0;i<response->codecs_len;i++)
111 printf(" codecs[%u] = %u\n", i, response->codecs[i]);
112 printf(" ptmap_len = %u\n", response->ptmap_len);
113 for(i=0;i<response->ptmap_len;i++) {
114 printf(" ptmap[%u].codec = %u\n", i, response->ptmap[i].codec);
115 printf(" ptmap[%u].pt = %u\n", i, response->ptmap[i].pt);
116 }
117
Neels Hofmeyre9920f22017-07-10 15:07:22 +0200118}
119
120mgcp_trans_id_t dummy_mgcp_send(struct msgb *msg)
121{
122 mgcp_trans_id_t trans_id;
123 trans_id = msg->cb[MSGB_CB_MGCP_TRANS_ID];
124 char *end;
125
Neels Hofmeyr3a8e7232017-09-04 01:02:56 +0200126 OSMO_ASSERT(mgcp_client_pending_add(mgcp, trans_id, test_response_cb, mgcp));
Neels Hofmeyre9920f22017-07-10 15:07:22 +0200127
128 end = (char*)msgb_put(msg, 1);
129 *end = '\0';
130 printf("composed:\n-----\n%s\n-----\n",
131 (char*)msgb_l2(msg));
132
133 talloc_free(msg);
134 return trans_id;
135}
136
137void test_crcx(void)
138{
139 struct msgb *msg;
140 mgcp_trans_id_t trans_id;
141
142 printf("\n===== %s =====\n", __func__);
143
144 if (mgcp)
145 talloc_free(mgcp);
Neels Hofmeyr3a8e7232017-09-04 01:02:56 +0200146 mgcp = mgcp_client_init(ctx, &conf);
Neels Hofmeyre9920f22017-07-10 15:07:22 +0200147
148 msg = mgcp_msg_crcx(mgcp, 23, 42, MGCP_CONN_LOOPBACK);
149 trans_id = dummy_mgcp_send(msg);
150
151 reply_to(trans_id, 200, "OK", 1,
152 "v=0\r\n"
153 "o=- 1 23 IN IP4 10.9.1.120\r\n"
154 "s=-\r\n"
155 "c=IN IP4 10.9.1.120\r\n"
156 "t=0 0\r\n"
Philipp Maier704c4f02018-06-07 18:51:31 +0200157 "m=audio 16002 RTP/AVP 110 96\r\n"
158 "a=rtpmap:110 AMR/8000\r\n"
159 "a=rtpmap:96 GSM-EFR/8000\r\n"
Neels Hofmeyre9920f22017-07-10 15:07:22 +0200160 "a=ptime:20\r\n");
161}
162
Philipp Maier1dc6be62017-10-05 18:25:37 +0200163void test_mgcp_msg(void)
164{
165 struct msgb *msg;
166 char audio_ip_overflow[5000];
167
168 /* A message struct prefilled with some arbitary values */
169 struct mgcp_msg mgcp_msg = {
170 .audio_ip = "192.168.100.23",
171 .endpoint = "23@mgw",
172 .audio_port = 1234,
173 .call_id = 47,
Philipp Maier01d24a32017-11-21 17:26:09 +0100174 .conn_id = "11",
Philipp Maier704c4f02018-06-07 18:51:31 +0200175 .conn_mode = MGCP_CONN_RECV_SEND,
176 .ptime = 20,
177 .codecs[0] = CODEC_GSM_8000_1,
178 .codecs[1] = CODEC_AMR_8000_1,
179 .codecs[2] = CODEC_GSMEFR_8000_1,
180 .codecs_len = 1,
181 .ptmap[0].codec = CODEC_GSMEFR_8000_1,
182 .ptmap[0].pt = 96,
Neels Hofmeyre6d8e912018-08-23 16:36:48 +0200183 .ptmap_len = 1,
184 .x_osmo_ign = MGCP_X_OSMO_IGN_CALLID,
Philipp Maier1dc6be62017-10-05 18:25:37 +0200185 };
186
187 if (mgcp)
188 talloc_free(mgcp);
189 mgcp = mgcp_client_init(ctx, &conf);
190
191 printf("\n");
192
193 printf("Generated CRCX message:\n");
194 mgcp_msg.verb = MGCP_VERB_CRCX;
195 mgcp_msg.presence =
196 (MGCP_MSG_PRESENCE_ENDPOINT | MGCP_MSG_PRESENCE_CALL_ID |
197 MGCP_MSG_PRESENCE_CONN_ID | MGCP_MSG_PRESENCE_CONN_MODE);
198 msg = mgcp_msg_gen(mgcp, &mgcp_msg);
199 printf("%s\n", (char *)msg->data);
200
Philipp Maier704c4f02018-06-07 18:51:31 +0200201 printf("Generated CRCX message (two codecs):\n");
202 mgcp_msg.verb = MGCP_VERB_CRCX;
203 mgcp_msg.presence =
204 (MGCP_MSG_PRESENCE_ENDPOINT | MGCP_MSG_PRESENCE_CALL_ID |
205 MGCP_MSG_PRESENCE_CONN_ID | MGCP_MSG_PRESENCE_CONN_MODE);
206 mgcp_msg.codecs_len = 2;
207 msg = mgcp_msg_gen(mgcp, &mgcp_msg);
208 mgcp_msg.codecs_len = 1;
209 printf("%s\n", (char *)msg->data);
210
211 printf("Generated CRCX message (three codecs, one with custom pt):\n");
212 mgcp_msg.verb = MGCP_VERB_CRCX;
213 mgcp_msg.presence =
214 (MGCP_MSG_PRESENCE_ENDPOINT | MGCP_MSG_PRESENCE_CALL_ID |
215 MGCP_MSG_PRESENCE_CONN_ID | MGCP_MSG_PRESENCE_CONN_MODE);
216 mgcp_msg.codecs_len = 3;
217 msg = mgcp_msg_gen(mgcp, &mgcp_msg);
218 mgcp_msg.codecs_len = 1;
219 printf("%s\n", (char *)msg->data);
220
Philipp Maier1dc6be62017-10-05 18:25:37 +0200221 printf("Generated MDCX message:\n");
222 mgcp_msg.verb = MGCP_VERB_MDCX;
223 mgcp_msg.presence =
224 (MGCP_MSG_PRESENCE_ENDPOINT | MGCP_MSG_PRESENCE_CALL_ID |
225 MGCP_MSG_PRESENCE_CONN_ID | MGCP_MSG_PRESENCE_CONN_MODE |
226 MGCP_MSG_PRESENCE_AUDIO_IP | MGCP_MSG_PRESENCE_AUDIO_PORT);
227 msg = mgcp_msg_gen(mgcp, &mgcp_msg);
228 printf("%s\n", (char *)msg->data);
229
Philipp Maier704c4f02018-06-07 18:51:31 +0200230 printf("Generated MDCX message (two codecs):\n");
231 mgcp_msg.verb = MGCP_VERB_MDCX;
232 mgcp_msg.presence =
233 (MGCP_MSG_PRESENCE_ENDPOINT | MGCP_MSG_PRESENCE_CALL_ID |
234 MGCP_MSG_PRESENCE_CONN_ID | MGCP_MSG_PRESENCE_CONN_MODE |
235 MGCP_MSG_PRESENCE_AUDIO_IP | MGCP_MSG_PRESENCE_AUDIO_PORT);
236 mgcp_msg.codecs_len = 2;
237 msg = mgcp_msg_gen(mgcp, &mgcp_msg);
238 mgcp_msg.codecs_len = 1;
239 printf("%s\n", (char *)msg->data);
240
241 printf("Generated MDCX message (three codecs, one with custom pt):\n");
242 mgcp_msg.verb = MGCP_VERB_MDCX;
243 mgcp_msg.presence =
244 (MGCP_MSG_PRESENCE_ENDPOINT | MGCP_MSG_PRESENCE_CALL_ID |
245 MGCP_MSG_PRESENCE_CONN_ID | MGCP_MSG_PRESENCE_CONN_MODE |
246 MGCP_MSG_PRESENCE_AUDIO_IP | MGCP_MSG_PRESENCE_AUDIO_PORT);
247 mgcp_msg.codecs_len = 3;
248 msg = mgcp_msg_gen(mgcp, &mgcp_msg);
249 mgcp_msg.codecs_len = 1;
250 printf("%s\n", (char *)msg->data);
251
Philipp Maier1dc6be62017-10-05 18:25:37 +0200252 printf("Generated DLCX message:\n");
253 mgcp_msg.verb = MGCP_VERB_DLCX;
254 mgcp_msg.presence =
255 (MGCP_MSG_PRESENCE_ENDPOINT | MGCP_MSG_PRESENCE_CALL_ID |
256 MGCP_MSG_PRESENCE_CONN_ID);
257 msg = mgcp_msg_gen(mgcp, &mgcp_msg);
258 printf("%s\n", (char *)msg->data);
259
260 printf("Generated AUEP message:\n");
261 mgcp_msg.verb = MGCP_VERB_AUEP;
262 mgcp_msg.presence = (MGCP_MSG_PRESENCE_ENDPOINT);
263 msg = mgcp_msg_gen(mgcp, &mgcp_msg);
264 printf("%s\n", msg->data);
265
266 printf("Generated RSIP message:\n");
267 mgcp_msg.verb = MGCP_VERB_RSIP;
268 mgcp_msg.presence = (MGCP_MSG_PRESENCE_ENDPOINT);
269 msg = mgcp_msg_gen(mgcp, &mgcp_msg);
270 printf("%s\n", (char *)msg->data);
271
Neels Hofmeyre6d8e912018-08-23 16:36:48 +0200272 printf("Generate X-Osmo-IGN message:\n");
273 msg = mgcp_msg_gen(mgcp, &mgcp_msg);
274 mgcp_msg.verb = MGCP_VERB_CRCX;
275 mgcp_msg.presence =
276 (MGCP_MSG_PRESENCE_ENDPOINT | MGCP_MSG_PRESENCE_CALL_ID |
277 MGCP_MSG_PRESENCE_CONN_ID | MGCP_MSG_PRESENCE_CONN_MODE
278 | MGCP_MSG_PRESENCE_X_OSMO_IGN);
279 msg = mgcp_msg_gen(mgcp, &mgcp_msg);
280 printf("%s\n", (char *)msg->data);
281
Philipp Maier1dc6be62017-10-05 18:25:37 +0200282 printf("Overfolow test:\n");
283 mgcp_msg.verb = MGCP_VERB_MDCX;
284 mgcp_msg.presence =
285 (MGCP_MSG_PRESENCE_ENDPOINT | MGCP_MSG_PRESENCE_CALL_ID |
286 MGCP_MSG_PRESENCE_CONN_ID | MGCP_MSG_PRESENCE_CONN_MODE |
287 MGCP_MSG_PRESENCE_AUDIO_IP | MGCP_MSG_PRESENCE_AUDIO_PORT);
288 memset(audio_ip_overflow, 'X', sizeof(audio_ip_overflow));
289 audio_ip_overflow[sizeof(audio_ip_overflow) - 1] = '\0';
290 mgcp_msg.audio_ip = audio_ip_overflow;
291 msg = mgcp_msg_gen(mgcp, &mgcp_msg);
292 OSMO_ASSERT(msg == NULL);
293
294 printf("\n");
295 msgb_free(msg);
296}
297
Neels Hofmeyrc8f37cb2017-11-30 13:43:11 +0100298void test_mgcp_client_cancel()
299{
300 mgcp_trans_id_t trans_id;
301 struct msgb *msg;
302 struct mgcp_msg mgcp_msg = {
303 .verb = MGCP_VERB_CRCX,
304 .audio_ip = "192.168.100.23",
305 .endpoint = "23@mgw",
306 .audio_port = 1234,
307 .call_id = 47,
Philipp Maier922ae9a2017-12-04 15:53:37 +0100308 .conn_id = "11",
Neels Hofmeyrc8f37cb2017-11-30 13:43:11 +0100309 .conn_mode = MGCP_CONN_RECV_SEND,
310 .presence = (MGCP_MSG_PRESENCE_ENDPOINT | MGCP_MSG_PRESENCE_CALL_ID
311 | MGCP_MSG_PRESENCE_CONN_ID | MGCP_MSG_PRESENCE_CONN_MODE),
Philipp Maier704c4f02018-06-07 18:51:31 +0200312 .ptime = 20,
313 .codecs[0] = CODEC_AMR_8000_1,
314 .codecs_len = 1
Neels Hofmeyrc8f37cb2017-11-30 13:43:11 +0100315 };
316
317 printf("\n%s():\n", __func__);
318 fprintf(stderr, "\n%s():\n", __func__);
319
320 if (mgcp)
321 talloc_free(mgcp);
322 mgcp = mgcp_client_init(ctx, &conf);
323
324 msg = mgcp_msg_gen(mgcp, &mgcp_msg);
325 trans_id = mgcp_msg_trans_id(msg);
326 fprintf(stderr, "- composed msg with trans_id=%u\n", trans_id);
327
328 fprintf(stderr, "- not in queue yet, cannot cancel yet\n");
329 OSMO_ASSERT(mgcp_client_cancel(mgcp, trans_id) == -ENOENT);
330
331 fprintf(stderr, "- enqueue\n");
332 dummy_mgcp_send(msg);
333
334 fprintf(stderr, "- cancel succeeds\n");
335 OSMO_ASSERT(mgcp_client_cancel(mgcp, trans_id) == 0);
336
337 fprintf(stderr, "- late response gets discarded\n");
338 OSMO_ASSERT(reply_to(trans_id, 200, "OK", 1, "v=0\r\n") == -ENOENT);
339
340 fprintf(stderr, "- canceling again does nothing\n");
341 OSMO_ASSERT(mgcp_client_cancel(mgcp, trans_id) == -ENOENT);
342
343 fprintf(stderr, "%s() done\n", __func__);
344}
345
Neels Hofmeyra8c6a9c2018-02-21 15:36:45 +0100346struct sdp_section_start_test {
347 const char *body;
348 int expect_rc;
349 struct mgcp_response expect_params;
350};
351
352static struct sdp_section_start_test sdp_section_start_tests[] = {
353 {
354 .body = "",
355 .expect_rc = -EINVAL,
356 },
357 {
358 .body = "\n\n",
359 },
360 {
361 .body = "\r\n\r\n",
362 },
363 {
364 .body = "\n\r\n\r",
365 },
366 {
367 .body = "some mgcp header data\r\nand header params"
368 "\n\n"
369 "m=audio 23\r\n",
370 .expect_params = {
371 .audio_port = 23,
372 },
373 },
374 {
375 .body = "some mgcp header data\r\nand header params"
376 "\r\n\r\n"
377 "m=audio 23\r\n",
378 .expect_params = {
379 .audio_port = 23,
380 },
381 },
382 {
383 .body = "some mgcp header data\r\nand header params"
384 "\n\r\n\r"
385 "m=audio 23\r\n",
386 .expect_params = {
387 .audio_port = 23,
388 },
389 },
390 {
391 .body = "some mgcp header data\r\nand header params"
392 "\n\r\n"
393 "m=audio 23\r\n",
394 .expect_rc = -EINVAL,
395 },
396 {
397 .body = "some mgcp header data\r\nand header params"
398 "\r\n\r"
399 "m=audio 23\r\n",
400 .expect_rc = -EINVAL,
401 },
402 {
403 .body = "some mgcp header data\r\nand header params"
404 "\n\r\r"
405 "m=audio 23\r\n",
406 .expect_rc = -EINVAL,
407 },
408};
409
410void test_sdp_section_start()
411{
412 int i;
413 int failures = 0;
414
415 for (i = 0; i < ARRAY_SIZE(sdp_section_start_tests); i++) {
416 int rc;
417 struct sdp_section_start_test *t = &sdp_section_start_tests[i];
418 struct mgcp_response *r = talloc_zero(ctx, struct mgcp_response);
419
420 r->body = talloc_strdup(r, t->body);
421
422 printf("\n%s() test [%d]:\n", __func__, i);
423 fprintf(stderr, "\n%s() test [%d]:\n", __func__, i);
424 fprintf(stderr, "body: \"%s\"\n", osmo_escape_str(r->body, -1));
425
426 rc = mgcp_response_parse_params(r);
427
428 fprintf(stderr, "got rc=%d\n", rc);
429 if (rc != t->expect_rc) {
430 fprintf(stderr, "FAIL: Expected rc=%d\n", t->expect_rc);
431 failures++;
432 }
433 if (rc) {
434 talloc_free(r);
435 continue;
436 }
437
438 fprintf(stderr, "got audio_port=%u\n", t->expect_params.audio_port);
439 if (r->audio_port != t->expect_params.audio_port) {
440 fprintf(stderr, "FAIL: Expected audio_port=%u\n", t->expect_params.audio_port);
441 failures++;
442 }
443 talloc_free(r);
444 }
445
Neels Hofmeyra8c6a9c2018-02-21 15:36:45 +0100446 OSMO_ASSERT(!failures);
Neels Hofmeyra8c6a9c2018-02-21 15:36:45 +0100447}
448
Philipp Maier704c4f02018-06-07 18:51:31 +0200449static void test_map_pt_to_codec(void)
450{
451 /* Full form */
452 OSMO_ASSERT(map_str_to_codec("PCMU/8000/1") == CODEC_PCMU_8000_1);
453 OSMO_ASSERT(map_str_to_codec("GSM/8000/1") == CODEC_GSM_8000_1);
454 OSMO_ASSERT(map_str_to_codec("PCMA/8000/1") == CODEC_PCMA_8000_1);
455 OSMO_ASSERT(map_str_to_codec("G729/8000/1") == CODEC_G729_8000_1);
456 OSMO_ASSERT(map_str_to_codec("GSM-EFR/8000/1") == CODEC_GSMEFR_8000_1);
457 OSMO_ASSERT(map_str_to_codec("GSM-HR-08/8000/1") == CODEC_GSMHR_8000_1);
458 OSMO_ASSERT(map_str_to_codec("AMR/8000/1") == CODEC_AMR_8000_1);
459 OSMO_ASSERT(map_str_to_codec("AMR-WB/16000/1") == CODEC_AMRWB_16000_1);
460
461 /* Short form */
462 OSMO_ASSERT(map_str_to_codec("GSM-EFR") == CODEC_GSMEFR_8000_1);
463 OSMO_ASSERT(map_str_to_codec("G729") == CODEC_G729_8000_1);
464 OSMO_ASSERT(map_str_to_codec("GSM-HR-08") == CODEC_GSMHR_8000_1);
465
466 /* We do not care about what is after the first delimiter */
467 OSMO_ASSERT(map_str_to_codec("AMR-WB/123///456") == CODEC_AMRWB_16000_1);
468 OSMO_ASSERT(map_str_to_codec("PCMA/asdf") == CODEC_PCMA_8000_1);
469 OSMO_ASSERT(map_str_to_codec("GSM/qwertz") == CODEC_GSM_8000_1);
470
471 /* A trailing delimiter should not hurt */
472 OSMO_ASSERT(map_str_to_codec("AMR/") == CODEC_AMR_8000_1);
473 OSMO_ASSERT(map_str_to_codec("G729/") == CODEC_G729_8000_1);
474 OSMO_ASSERT(map_str_to_codec("GSM/") == CODEC_GSM_8000_1);
475
476 /* This is expected to fail */
477 OSMO_ASSERT(map_str_to_codec("INVALID/1234/7") == -1);
478 OSMO_ASSERT(map_str_to_codec(NULL) == -1);
479 OSMO_ASSERT(map_str_to_codec("") == -1);
480 OSMO_ASSERT(map_str_to_codec("/////") == -1);
481
482 /* The buffers are 64 bytes long, check what happens with overlong
483 * strings as input (This schould still work.) */
484 OSMO_ASSERT(map_str_to_codec("AMR-WB/16000/1############################################################################################################") == CODEC_AMRWB_16000_1);
485
486 /* This should not work, as there is no delimiter after the codec
487 * name */
488 OSMO_ASSERT(map_str_to_codec("AMR-WB####################################################################################################################") == -1);
489}
490
491static void test_map_codec_to_pt_and_map_pt_to_codec(void)
492{
493 struct ptmap ptmap[10];
494 unsigned int ptmap_len;
495 unsigned int i;
496
497 ptmap[0].codec = CODEC_GSMEFR_8000_1;
498 ptmap[0].pt = 96;
499 ptmap[1].codec = CODEC_GSMHR_8000_1;
500 ptmap[1].pt = 97;
501 ptmap[2].codec = CODEC_AMR_8000_1;
502 ptmap[2].pt = 98;
503 ptmap[3].codec = CODEC_AMRWB_16000_1;
504 ptmap[3].pt = 99;
505 ptmap_len = 4;
506
507 /* Mappings that are covered by the table */
508 for (i = 0; i < ptmap_len; i++)
509 printf(" %u => %u\n", ptmap[i].codec, map_codec_to_pt(ptmap, ptmap_len, ptmap[i].codec));
510 for (i = 0; i < ptmap_len; i++)
511 printf(" %u <= %u\n", ptmap[i].pt, map_pt_to_codec(ptmap, ptmap_len, ptmap[i].pt));
512 printf("\n");
513
514 /* Map some codecs/payload types from the static range, result must
515 * always be a 1:1 mapping */
516 printf(" %u => %u\n", CODEC_PCMU_8000_1, map_codec_to_pt(ptmap, ptmap_len, CODEC_PCMU_8000_1));
517 printf(" %u => %u\n", CODEC_GSM_8000_1, map_codec_to_pt(ptmap, ptmap_len, CODEC_GSM_8000_1));
518 printf(" %u => %u\n", CODEC_PCMA_8000_1, map_codec_to_pt(ptmap, ptmap_len, CODEC_PCMA_8000_1));
519 printf(" %u => %u\n", CODEC_G729_8000_1, map_codec_to_pt(ptmap, ptmap_len, CODEC_G729_8000_1));
520 printf(" %u <= %u\n", CODEC_PCMU_8000_1, map_pt_to_codec(ptmap, ptmap_len, CODEC_PCMU_8000_1));
521 printf(" %u <= %u\n", CODEC_GSM_8000_1, map_pt_to_codec(ptmap, ptmap_len, CODEC_GSM_8000_1));
522 printf(" %u <= %u\n", CODEC_PCMA_8000_1, map_pt_to_codec(ptmap, ptmap_len, CODEC_PCMA_8000_1));
523 printf(" %u <= %u\n", CODEC_G729_8000_1, map_pt_to_codec(ptmap, ptmap_len, CODEC_G729_8000_1));
524 printf("\n");
525
526 /* Try to do mappings from statically defined range to danymic range and vice versa. This
527 * is illegal and should result into a 1:1 mapping */
528 ptmap[3].codec = CODEC_AMRWB_16000_1;
529 ptmap[3].pt = 2;
530 ptmap[4].codec = CODEC_PCMU_8000_1;
531 ptmap[4].pt = 100;
532 ptmap_len = 5;
533
534 /* Apply all mappings again, the illegal ones we defined should result into 1:1 mappings */
535 for (i = 0; i < ptmap_len; i++)
536 printf(" %u => %u\n", ptmap[i].codec, map_codec_to_pt(ptmap, ptmap_len, ptmap[i].codec));
537 for (i = 0; i < ptmap_len; i++)
538 printf(" %u <= %u\n", ptmap[i].pt, map_pt_to_codec(ptmap, ptmap_len, ptmap[i].pt));
539 printf("\n");
540}
541
Neels Hofmeyre9920f22017-07-10 15:07:22 +0200542static const struct log_info_cat log_categories[] = {
543};
544
545const struct log_info log_info = {
546 .cat = log_categories,
547 .num_cat = ARRAY_SIZE(log_categories),
548};
549
550
551int main(int argc, char **argv)
552{
Neels Hofmeyr3a8e7232017-09-04 01:02:56 +0200553 ctx = talloc_named_const(NULL, 1, "mgcp_client_test");
Neels Hofmeyre9920f22017-07-10 15:07:22 +0200554 msgb_talloc_ctx_init(ctx, 0);
Neels Hofmeyr60f8e312018-03-30 23:01:07 +0200555 osmo_init_logging2(ctx, &log_info);
Philipp Maier8348abb2017-10-25 12:14:13 +0200556 log_set_print_filename(osmo_stderr_target, 0);
557 log_set_print_timestamp(osmo_stderr_target, 0);
558 log_set_use_color(osmo_stderr_target, 0);
559 log_set_print_category(osmo_stderr_target, 1);
Neels Hofmeyre9920f22017-07-10 15:07:22 +0200560
Neels Hofmeyrc8f37cb2017-11-30 13:43:11 +0100561 log_set_category_filter(osmo_stderr_target, DLMGCP, 1, LOGL_DEBUG);
562
Neels Hofmeyr3a8e7232017-09-04 01:02:56 +0200563 mgcp_client_conf_init(&conf);
Neels Hofmeyre9920f22017-07-10 15:07:22 +0200564
565 test_crcx();
Philipp Maier1dc6be62017-10-05 18:25:37 +0200566 test_mgcp_msg();
Neels Hofmeyrc8f37cb2017-11-30 13:43:11 +0100567 test_mgcp_client_cancel();
Neels Hofmeyra8c6a9c2018-02-21 15:36:45 +0100568 test_sdp_section_start();
Philipp Maier704c4f02018-06-07 18:51:31 +0200569 test_map_codec_to_pt_and_map_pt_to_codec();
570 test_map_pt_to_codec();
Neels Hofmeyre9920f22017-07-10 15:07:22 +0200571
572 printf("Done\n");
573 fprintf(stderr, "Done\n");
574 return EXIT_SUCCESS;
575}