arehbein has uploaded this change for review. ( 
https://gerrit.osmocom.org/c/libosmo-netif/+/34799?usp=email )


Change subject: stream_test: Improve mem mgmt, fix connection mgmt
......................................................................

stream_test: Improve mem mgmt, fix connection mgmt

 - Use tall_test as root context everywhere, don't create any other contexts
 - change .*_(cli|srv)_run_client() signature by adding talloc context as 
parameter
 - Open and Close server link inside test_recon()
 - Print full talloc report

Related: OS#6222
Change-Id: I9ef02ed113bc049ae430b93d0eb69641e2ee809b
---
M tests/stream/stream_test.c
M tests/stream/stream_test.err
M tests/stream/stream_test.ok
3 files changed, 121 insertions(+), 81 deletions(-)



  git pull ssh://gerrit.osmocom.org:29418/libosmo-netif refs/changes/99/34799/1

diff --git a/tests/stream/stream_test.c b/tests/stream/stream_test.c
index 4830302..383059a 100644
--- a/tests/stream/stream_test.c
+++ b/tests/stream/stream_test.c
@@ -340,10 +340,17 @@
                       bool autoreconnect)
 {
        struct timeval tv;
-       struct osmo_stream_cli *cli = make_client(ctx, host, port, 
autoreconnect);
+       struct osmo_stream_cli *cli;
+       if (osmo_stream_srv_link_open(lnk) < 0) {
+               printf("Unable to open server\n");
+               osmo_stream_srv_link_destroy(lnk);
+               return;
+       }
+       cli = make_client(ctx, host, port, autoreconnect);
        if (!cli)
                return;

+
        printf("=======================================\n");
        printf("Client/Server entering %s event loop...\n", 
ASTR(autoreconnect));
        printf("=======================================\n");
@@ -368,6 +375,7 @@
        }

        osmo_stream_cli_destroy(cli);
+       osmo_stream_srv_link_close(lnk);
        printf("{%lu.%06lu} %s test complete.\n\n", tv.tv_sec, tv.tv_usec, 
ASTR(autoreconnect));
 }

@@ -531,12 +539,10 @@
        return 0;
 }

-struct osmo_stream_cli *test_segm_ipa_stream_srv_run_client(void)
+struct osmo_stream_cli *test_segm_ipa_stream_srv_run_client(void *ctx)
 {
        struct osmo_stream_cli *osc;
-       void *ctx = talloc_named_const(NULL, 0, __func__);
 
-       (void) msgb_talloc_ctx_init(ctx, 0);
        osc = osmo_stream_cli_create(ctx);
        if (osc == NULL) {
                fprintf(stderr, "osmo_stream_cli_create_iofd()\n");
@@ -546,7 +552,6 @@
        osmo_stream_cli_set_local_port(osc, 8977);
        osmo_stream_cli_set_port(osc, 1111);
        osmo_stream_cli_set_connect_cb(osc, 
test_segm_ipa_stream_srv_cli_connect_cb);
-       osmo_stream_cli_set_data(osc, ctx);
        osmo_stream_cli_set_read_cb2(osc, test_segm_ipa_stream_srv_cli_read_cb);
        osmo_stream_cli_set_nodelay(osc, true);
        if (osmo_stream_cli_open(osc) < 0) {
@@ -590,7 +595,7 @@

 static int test_segm_ipa_stream_srv_srv_accept_cb(struct osmo_stream_srv_link 
*srv, int fd)
 {
-       void *ctx = talloc_named_const(NULL, 0, __func__);
+       void *ctx = osmo_stream_srv_link_get_data(srv);
        struct osmo_stream_srv *oss =
                osmo_stream_srv_create2(ctx, srv, fd, NULL);
        if (oss == NULL) {
@@ -613,7 +618,7 @@
                printf("Unable to open server\n");
                exit(1);
        }
-       osc = test_segm_ipa_stream_srv_run_client();
+       osc = test_segm_ipa_stream_srv_run_client(ctx);

        printf("______________________________________Running test 
%s______________________________________\n", testname);
        alarm(2);
@@ -714,7 +719,7 @@

 static int test_segm_ipa_stream_cli_srv_accept_cb(struct osmo_stream_srv_link 
*srv, int fd)
 {
-       void *ctx = talloc_named_const(NULL, 0, __func__);
+       void *ctx = osmo_stream_srv_link_get_data(srv);
        struct osmo_stream_srv *oss =
                osmo_stream_srv_create2(ctx, srv, fd, NULL);
        unsigned char *data;
@@ -781,12 +786,10 @@
        return 0;
 }

-static void *test_segm_ipa_stream_cli_run_client(void)
+static void *test_segm_ipa_stream_cli_run_client(void *ctx)
 {
        struct osmo_stream_cli *osc;
-       void *ctx = talloc_named_const(NULL, 0, __func__);

-       (void) msgb_talloc_ctx_init(ctx, 0);
        osc = osmo_stream_cli_create(ctx);
        if (osc == NULL) {
                fprintf(stderr, "osmo_stream_cli_create_iofd()\n");
@@ -795,7 +798,6 @@
        osmo_stream_cli_set_addr(osc, "127.0.0.11");
        osmo_stream_cli_set_local_port(osc, 8977);
        osmo_stream_cli_set_port(osc, 1112);
-       osmo_stream_cli_set_data(osc, ctx);
        osmo_stream_cli_set_read_cb2(osc, test_segm_ipa_stream_cli_cli_read_cb);
        osmo_stream_cli_set_nodelay(osc, true);
        osmo_stream_cli_set_segmentation_cb(osc, osmo_ipa_segmentation_cb);
@@ -818,7 +820,7 @@
                printf("Unable to open server\n");
                exit(1);
        }
-       test_segm_ipa_stream_cli_run_client();
+       test_segm_ipa_stream_cli_run_client(ctx);

        printf("______________________________________Running test 
%s______________________________________\n", testname);
        alarm(2);
@@ -869,20 +871,17 @@
        osmo_stream_srv_link_set_accept_cb(srv, accept_cb_srv);
        osmo_stream_srv_link_set_nodelay(srv, true);

-       if (osmo_stream_srv_link_open(srv) < 0) {
-               printf("Unable to open server\n");
-               osmo_stream_srv_link_destroy(srv);
-               return EXIT_FAILURE;
-       }
-
        test_recon(tall_test, host, port, 12, srv, true);
        test_recon(tall_test, host, port, 8, srv, false);

+       osmo_stream_srv_link_set_data(srv, tall_test);
        test_segm_ipa_stream_srv_run(tall_test, host, port, srv);
        test_segm_ipa_stream_cli_run(tall_test, host, port, srv);

        printf("Stream tests completed\n");

        osmo_stream_srv_link_destroy(srv);
+       talloc_report_full(tall_test, stderr);
+       talloc_free(tall_test);
        return EXIT_SUCCESS;
 }
diff --git a/tests/stream/stream_test.err b/tests/stream/stream_test.err
index 6c85c43..2847874 100644
--- a/tests/stream/stream_test.err
+++ b/tests/stream/stream_test.err
@@ -51,3 +51,29 @@
 CLICONN(,r=127.0.0.11:1111<->l=127.0.0.1:8977){CONNECTING} connection 
established
 SRV(srv_link_test,127.0.0.11:1112) accept()ed new link from 127.0.0.1:8977
 CLICONN(,r=127.0.0.11:1112<->l=127.0.0.1:8977){CONNECTING} connection 
established
+full talloc report on 'osmo_stream_test' (total  16326 bytes in  26 blocks)
+    struct osmo_stream_srv         contains   1741 bytes in   4 blocks (ref 0) 
0x6130000013e0
+        r=127.0.0.1:8977<->l=127.0.0.11:1112 contains   1288 bytes in   1 
blocks (ref 0) 0x61a0000054e0
+        struct osmo_io_fd              contains    213 bytes in   2 blocks 
(ref 0) 0x612000000520
+            r=127.0.0.1:8977<->l=127.0.0.11:1112 contains     37 bytes in   1 
blocks (ref 0) 0x60d000000240
+    struct osmo_stream_cli         contains  10123 bytes in  10 blocks (ref 0) 
0x6190000019e0
+        iofd_msgb                      contains   1288 bytes in   1 blocks 
(ref 0) 0x61a000004ee0
+        iofd_msgb                      contains   1288 bytes in   1 blocks 
(ref 0) 0x61a0000036e0
+        struct osmo_io_fd              contains   6616 bytes in   6 blocks 
(ref 0) 0x6120000003a0
+            iofd_msgb                      contains   1288 bytes in   1 blocks 
(ref 0) 0x61a0000060e0
+            iofd_msgb                      contains   1288 bytes in   1 blocks 
(ref 0) 0x61a000005ae0
+            iofd_msgb                      contains   1288 bytes in   1 blocks 
(ref 0) 0x61a0000048e0
+            iofd_msgb                      contains   1288 bytes in   1 blocks 
(ref 0) 0x61a0000042e0
+            iofd_msgb                      contains   1288 bytes in   1 blocks 
(ref 0) 0x61a000003ce0
+        127.0.0.11                     contains     11 bytes in   1 blocks 
(ref 0) 0x60b000000af0
+    logging                        contains   1221 bytes in   5 blocks (ref 0) 
0x60b000000360
+        struct log_target              contains    220 bytes in   2 blocks 
(ref 0) 0x6110000001e0
+            struct log_category            contains     60 bytes in   1 blocks 
(ref 0) 0x60e000024ae0
+        struct log_info                contains   1000 bytes in   2 blocks 
(ref 0) 0x60d0000000a0
+            struct log_info_cat            contains    960 bytes in   1 blocks 
(ref 0) 0x6190000005e0
+    msgb                           contains   3240 bytes in   6 blocks (ref 0) 
0x608000000100
+        STREAM test                    contains    648 bytes in   1 blocks 
(ref 0) 0x6170000038e0
+        STREAM test                    contains    648 bytes in   1 blocks 
(ref 0) 0x617000002ae0
+        STREAM test                    contains    648 bytes in   1 blocks 
(ref 0) 0x617000001ce0
+        STREAM test                    contains    648 bytes in   1 blocks 
(ref 0) 0x617000001960
+        STREAM test                    contains    648 bytes in   1 blocks 
(ref 0) 0x617000000b60
diff --git a/tests/stream/stream_test.ok b/tests/stream/stream_test.ok
index fb65aa7..14da5fa 100644
--- a/tests/stream/stream_test.ok
+++ b/tests/stream/stream_test.ok
@@ -49,18 +49,18 @@
 {20.000019} non-reconnecting test complete.

 ______________________________________Running test 
test_segm_ipa_stream_srv______________________________________
-{20.000020} [OK] Client's test_segm_ipa_stream_srv_cli_connect_cb(): [1-cli] 
Appending msg of type IPAC_MSGT_PING into buffer
-{20.000020} [OK] Client's test_segm_ipa_stream_srv_cli_connect_cb():   (msg 
dump: 00 01 fe 00 )
-{20.000020} [OK] Client's test_segm_ipa_stream_srv_cli_connect_cb(): [2-cli] 
Appending msg of type IPAC_MSGT_PONG into buffer
-{20.000020} [OK] Client's test_segm_ipa_stream_srv_cli_connect_cb():   (msg 
dump: 00 01 fe 01 )
-{20.000020} [OK] Client's test_segm_ipa_stream_srv_cli_connect_cb(): [3-cli] 
Appending msg of type IPAC_MSGT_PING into buffer
-{20.000020} [OK] Client's test_segm_ipa_stream_srv_cli_connect_cb():   (msg 
dump: 00 01 fe 00 )
-{20.000020} [OK] Client's test_segm_ipa_stream_srv_cli_connect_cb(): [4-cli] 
Appending msg of type IPAC_MSGT_ID_RESP into buffer
-{20.000020} [OK] Client's test_segm_ipa_stream_srv_cli_connect_cb():   (msg 
dump: 00 07 fe 05 01 01 de ad be ef )
-{20.000020} [OK] Client's test_segm_ipa_stream_srv_cli_connect_cb(): [(04 + 
1/3)-cli] Appending 1st third of msg of type IPAC_MSGT_ID_GET into buffer
-{20.000020} [OK] Client's test_segm_ipa_stream_srv_cli_connect_cb():   (dump: 
00 03 )
-{20.000020} [OK] Client's test_segm_ipa_stream_srv_cli_connect_cb(): Sending 4 
+ 1/3 messages as one:
-{20.000020} [OK] Client's test_segm_ipa_stream_srv_cli_connect_cb():   (msg 
dump: 00 01 fe 00 00 01 fe 01 00 01 fe 00 00 07 fe 05 01 01 de ad be ef 00 03 )
+{20.000020} [NA] Client's test_segm_ipa_stream_srv_cli_connect_cb(): [1-cli] 
Appending msg of type IPAC_MSGT_PING into buffer
+{20.000020} [NA] Client's test_segm_ipa_stream_srv_cli_connect_cb():   (msg 
dump: 00 01 fe 00 )
+{20.000020} [NA] Client's test_segm_ipa_stream_srv_cli_connect_cb(): [2-cli] 
Appending msg of type IPAC_MSGT_PONG into buffer
+{20.000020} [NA] Client's test_segm_ipa_stream_srv_cli_connect_cb():   (msg 
dump: 00 01 fe 01 )
+{20.000020} [NA] Client's test_segm_ipa_stream_srv_cli_connect_cb(): [3-cli] 
Appending msg of type IPAC_MSGT_PING into buffer
+{20.000020} [NA] Client's test_segm_ipa_stream_srv_cli_connect_cb():   (msg 
dump: 00 01 fe 00 )
+{20.000020} [NA] Client's test_segm_ipa_stream_srv_cli_connect_cb(): [4-cli] 
Appending msg of type IPAC_MSGT_ID_RESP into buffer
+{20.000020} [NA] Client's test_segm_ipa_stream_srv_cli_connect_cb():   (msg 
dump: 00 07 fe 05 01 01 de ad be ef )
+{20.000020} [NA] Client's test_segm_ipa_stream_srv_cli_connect_cb(): [(04 + 
1/3)-cli] Appending 1st third of msg of type IPAC_MSGT_ID_GET into buffer
+{20.000020} [NA] Client's test_segm_ipa_stream_srv_cli_connect_cb():   (dump: 
00 03 )
+{20.000020} [NA] Client's test_segm_ipa_stream_srv_cli_connect_cb(): Sending 4 
+ 1/3 messages as one:
+{20.000020} [NA] Client's test_segm_ipa_stream_srv_cli_connect_cb():   (msg 
dump: 00 01 fe 00 00 01 fe 01 00 01 fe 00 00 07 fe 05 01 01 de ad be ef 00 03 )

 {20.000022} [NA|OK] Server's test_segm_ipa_stream_srv_srv_read_cb(): [1-srv] 
Received IPA message from stream (payload len = 1)
 {20.000022} [NA|OK] Server's test_segm_ipa_stream_srv_srv_read_cb():   msg 
buff data (including stripped headers): 00 01 fe 00
@@ -84,21 +84,21 @@
 {20.000022} [NA|OK] Server's test_segm_ipa_stream_srv_srv_read_cb():   (msg 
dump: 00 07 fe 05 01 01 de ad be ef )
 {20.000022} [NA|OK] Server's test_segm_ipa_stream_srv_srv_read_cb(): Send 
IPAC_MSGT_ID_GET to trigger client to send next third

-{20.000024} [OK] Client's test_segm_ipa_stream_srv_cli_read_cb(): Received 
message from stream (payload len = 3)
-{20.000024} [OK] Client's test_segm_ipa_stream_srv_cli_read_cb():      Type: 
IPAC_MSGT_ID_GET
-{20.000024} [OK] Client's test_segm_ipa_stream_srv_cli_read_cb(): Got 
IPAC_MSGT_ID_GET from server
-{20.000024} [OK] Client's test_segm_ipa_stream_srv_cli_read_cb(): [(4 + 2/3) 
-cli] Appending: Second third of IPAC_MSGT_ID_GET
-{20.000024} [OK] Client's test_segm_ipa_stream_srv_cli_read_cb():      
Sending: Second third of IPAC_MSGT_ID_GET
-{20.000024} [OK] Client's test_segm_ipa_stream_srv_cli_read_cb():      (msg 
dump: fe 04 )
+{20.000024} [NA] Client's test_segm_ipa_stream_srv_cli_read_cb(): Received 
message from stream (payload len = 3)
+{20.000024} [NA] Client's test_segm_ipa_stream_srv_cli_read_cb():      Type: 
IPAC_MSGT_ID_GET
+{20.000024} [NA] Client's test_segm_ipa_stream_srv_cli_read_cb(): Got 
IPAC_MSGT_ID_GET from server
+{20.000024} [NA] Client's test_segm_ipa_stream_srv_cli_read_cb(): [(4 + 2/3) 
-cli] Appending: Second third of IPAC_MSGT_ID_GET
+{20.000024} [NA] Client's test_segm_ipa_stream_srv_cli_read_cb():      
Sending: Second third of IPAC_MSGT_ID_GET
+{20.000024} [NA] Client's test_segm_ipa_stream_srv_cli_read_cb():      (msg 
dump: fe 04 )

-{20.500024} [OK] Client's send_last_third(): Delay for sending last third of 
message is over
-{20.500024} [OK] Client's send_last_third(): [5-cli] Appending: Last third of 
IPAC_MSGT_ID_GET
-{20.500024} [OK] Client's send_last_third(): [6-cli] Appending msg of type 
IPAC_MSGT_PONG into buffer
-{20.500024} [OK] Client's send_last_third():   (msg dump: 00 01 fe 01 )
-{20.500024} [OK] Client's send_last_third(): [7-cli] Appending msg of type 
IPAC_MSGT_PONG into buffer
-{20.500024} [OK] Client's send_last_third():   (msg dump: 00 01 fe 01 )
-{20.500024} [OK] Client's send_last_third():   Sending:[ Last third of 
IPAC_MSGT_ID_GET | IPAC_MSGT_PONG | IPAC_MSGT_PONG ]
-{20.500024} [OK] Client's send_last_third():   (msg dump: 01 01 00 01 fe 01 00 
01 fe 01 )
+{20.500024} [NA] Client's send_last_third(): Delay for sending last third of 
message is over
+{20.500024} [NA] Client's send_last_third(): [5-cli] Appending: Last third of 
IPAC_MSGT_ID_GET
+{20.500024} [NA] Client's send_last_third(): [6-cli] Appending msg of type 
IPAC_MSGT_PONG into buffer
+{20.500024} [NA] Client's send_last_third():   (msg dump: 00 01 fe 01 )
+{20.500024} [NA] Client's send_last_third(): [7-cli] Appending msg of type 
IPAC_MSGT_PONG into buffer
+{20.500024} [NA] Client's send_last_third():   (msg dump: 00 01 fe 01 )
+{20.500024} [NA] Client's send_last_third():   Sending:[ Last third of 
IPAC_MSGT_ID_GET | IPAC_MSGT_PONG | IPAC_MSGT_PONG ]
+{20.500024} [NA] Client's send_last_third():   (msg dump: 01 01 00 01 fe 01 00 
01 fe 01 )

 {20.500026} [NA|OK] Server's test_segm_ipa_stream_srv_srv_read_cb(): [5-srv] 
Received IPA message from stream (payload len = 3)
 {20.500026} [NA|OK] Server's test_segm_ipa_stream_srv_srv_read_cb():   msg 
buff data (including stripped headers): 00 03 fe 04 01 01
@@ -131,27 +131,27 @@
 {20.500027} [NA|OK] Server's test_segm_ipa_stream_cli_srv_accept_cb(): Sending 
4 + 1/3 messages as one:
 {20.500027} [NA|OK] Server's test_segm_ipa_stream_cli_srv_accept_cb():         
(msg dump: 00 01 fe 00 00 01 fe 01 00 01 fe 00 00 07 fe 05 01 01 de ad be ef 00 
03 )

-{20.500029} [OK] Client's test_segm_ipa_stream_cli_cli_read_cb(): [1-cli] 
Received message from stream (len = 1)
-{20.500029} [OK] Client's test_segm_ipa_stream_cli_cli_read_cb():      msg 
buff data: 00
-{20.500029} [OK] Client's test_segm_ipa_stream_cli_cli_read_cb():      IPA 
payload: 00
-{20.500029} [OK] Client's test_segm_ipa_stream_cli_cli_read_cb():      Type: 
IPAC_MSGT_PING
-{20.500029} [OK] Client's test_segm_ipa_stream_cli_cli_read_cb():      (msg 
dump (including stripped headers): 00 01 fe 00 )
-{20.500029} [OK] Client's test_segm_ipa_stream_cli_cli_read_cb(): [2-cli] 
Received message from stream (len = 1)
-{20.500029} [OK] Client's test_segm_ipa_stream_cli_cli_read_cb():      msg 
buff data: 01
-{20.500029} [OK] Client's test_segm_ipa_stream_cli_cli_read_cb():      IPA 
payload: 01
-{20.500029} [OK] Client's test_segm_ipa_stream_cli_cli_read_cb():      Type: 
IPAC_MSGT_PONG
-{20.500029} [OK] Client's test_segm_ipa_stream_cli_cli_read_cb():      (msg 
dump (including stripped headers): 00 01 fe 01 )
-{20.500029} [OK] Client's test_segm_ipa_stream_cli_cli_read_cb(): [3-cli] 
Received message from stream (len = 1)
-{20.500029} [OK] Client's test_segm_ipa_stream_cli_cli_read_cb():      msg 
buff data: 00
-{20.500029} [OK] Client's test_segm_ipa_stream_cli_cli_read_cb():      IPA 
payload: 00
-{20.500029} [OK] Client's test_segm_ipa_stream_cli_cli_read_cb():      Type: 
IPAC_MSGT_PING
-{20.500029} [OK] Client's test_segm_ipa_stream_cli_cli_read_cb():      (msg 
dump (including stripped headers): 00 01 fe 00 )
-{20.500029} [OK] Client's test_segm_ipa_stream_cli_cli_read_cb(): [4-cli] 
Received message from stream (len = 7)
-{20.500029} [OK] Client's test_segm_ipa_stream_cli_cli_read_cb():      msg 
buff data: 05 01 01 de ad be ef
-{20.500029} [OK] Client's test_segm_ipa_stream_cli_cli_read_cb():      IPA 
payload: 05 01 01 de ad be ef
-{20.500029} [OK] Client's test_segm_ipa_stream_cli_cli_read_cb():      Type: 
IPAC_MSGT_ID_RESP
-{20.500029} [OK] Client's test_segm_ipa_stream_cli_cli_read_cb():      (msg 
dump (including stripped headers): 00 07 fe 05 01 01 de ad be ef )
-{20.500029} [OK] Client's test_segm_ipa_stream_cli_cli_read_cb(): Send 
IPAC_MSGT_ID_GET to trigger server to send next third
+{20.500029} [NA] Client's test_segm_ipa_stream_cli_cli_read_cb(): [1-cli] 
Received message from stream (len = 1)
+{20.500029} [NA] Client's test_segm_ipa_stream_cli_cli_read_cb():      msg 
buff data: 00
+{20.500029} [NA] Client's test_segm_ipa_stream_cli_cli_read_cb():      IPA 
payload: 00
+{20.500029} [NA] Client's test_segm_ipa_stream_cli_cli_read_cb():      Type: 
IPAC_MSGT_PING
+{20.500029} [NA] Client's test_segm_ipa_stream_cli_cli_read_cb():      (msg 
dump (including stripped headers): 00 01 fe 00 )
+{20.500029} [NA] Client's test_segm_ipa_stream_cli_cli_read_cb(): [2-cli] 
Received message from stream (len = 1)
+{20.500029} [NA] Client's test_segm_ipa_stream_cli_cli_read_cb():      msg 
buff data: 01
+{20.500029} [NA] Client's test_segm_ipa_stream_cli_cli_read_cb():      IPA 
payload: 01
+{20.500029} [NA] Client's test_segm_ipa_stream_cli_cli_read_cb():      Type: 
IPAC_MSGT_PONG
+{20.500029} [NA] Client's test_segm_ipa_stream_cli_cli_read_cb():      (msg 
dump (including stripped headers): 00 01 fe 01 )
+{20.500029} [NA] Client's test_segm_ipa_stream_cli_cli_read_cb(): [3-cli] 
Received message from stream (len = 1)
+{20.500029} [NA] Client's test_segm_ipa_stream_cli_cli_read_cb():      msg 
buff data: 00
+{20.500029} [NA] Client's test_segm_ipa_stream_cli_cli_read_cb():      IPA 
payload: 00
+{20.500029} [NA] Client's test_segm_ipa_stream_cli_cli_read_cb():      Type: 
IPAC_MSGT_PING
+{20.500029} [NA] Client's test_segm_ipa_stream_cli_cli_read_cb():      (msg 
dump (including stripped headers): 00 01 fe 00 )
+{20.500029} [NA] Client's test_segm_ipa_stream_cli_cli_read_cb(): [4-cli] 
Received message from stream (len = 7)
+{20.500029} [NA] Client's test_segm_ipa_stream_cli_cli_read_cb():      msg 
buff data: 05 01 01 de ad be ef 
+{20.500029} [NA] Client's test_segm_ipa_stream_cli_cli_read_cb():      IPA 
payload: 05 01 01 de ad be ef
+{20.500029} [NA] Client's test_segm_ipa_stream_cli_cli_read_cb():      Type: 
IPAC_MSGT_ID_RESP
+{20.500029} [NA] Client's test_segm_ipa_stream_cli_cli_read_cb():      (msg 
dump (including stripped headers): 00 07 fe 05 01 01 de ad be ef )
+{20.500029} [NA] Client's test_segm_ipa_stream_cli_cli_read_cb(): Send 
IPAC_MSGT_ID_GET to trigger server to send next third

 {20.500031} [NA|OK] Server's test_segm_ipa_stream_cli_srv_read_cb(): Received 
message from stream (total len including stripped headers = 6)
 {20.500031} [NA|OK] Server's test_segm_ipa_stream_cli_srv_read_cb():   Type: 
IPAC_MSGT_ID_GET
@@ -169,21 +169,21 @@
 {20.625031} [NA|OK] Server's send_last_third_srv():    Sending:[ Last third of 
IPAC_MSGT_ID_GET | IPAC_MSGT_PONG | IPAC_MSGT_PONG ]
 {20.625031} [NA|OK] Server's send_last_third_srv():    (msg dump: 01 01 00 01 
fe 01 00 01 fe 01 )

-{20.625033} [OK] Client's test_segm_ipa_stream_cli_cli_read_cb(): [5-cli] 
Received message from stream (len = 3)
-{20.625033} [OK] Client's test_segm_ipa_stream_cli_cli_read_cb():      msg 
buff data: 04 01 01
-{20.625033} [OK] Client's test_segm_ipa_stream_cli_cli_read_cb():      IPA 
payload: 04 01 01
-{20.625033} [OK] Client's test_segm_ipa_stream_cli_cli_read_cb():      Type: 
IPAC_MSGT_ID_GET
-{20.625033} [OK] Client's test_segm_ipa_stream_cli_cli_read_cb():      (msg 
dump (including stripped headers): 00 03 fe 04 01 01 )
-{20.625033} [OK] Client's test_segm_ipa_stream_cli_cli_read_cb(): [6-cli] 
Received message from stream (len = 1)
-{20.625033} [OK] Client's test_segm_ipa_stream_cli_cli_read_cb():      msg 
buff data: 01
-{20.625033} [OK] Client's test_segm_ipa_stream_cli_cli_read_cb():      IPA 
payload: 01
-{20.625033} [OK] Client's test_segm_ipa_stream_cli_cli_read_cb():      Type: 
IPAC_MSGT_PONG
-{20.625033} [OK] Client's test_segm_ipa_stream_cli_cli_read_cb():      (msg 
dump (including stripped headers): 00 01 fe 01 )
-{20.625033} [OK] Client's test_segm_ipa_stream_cli_cli_read_cb(): [7-cli] 
Received message from stream (len = 1)
-{20.625033} [OK] Client's test_segm_ipa_stream_cli_cli_read_cb():      msg 
buff data: 01
-{20.625033} [OK] Client's test_segm_ipa_stream_cli_cli_read_cb():      IPA 
payload: 01
-{20.625033} [OK] Client's test_segm_ipa_stream_cli_cli_read_cb():      Type: 
IPAC_MSGT_PONG
-{20.625033} [OK] Client's test_segm_ipa_stream_cli_cli_read_cb():      (msg 
dump (including stripped headers): 00 01 fe 01 )
+{20.625033} [NA] Client's test_segm_ipa_stream_cli_cli_read_cb(): [5-cli] 
Received message from stream (len = 3)
+{20.625033} [NA] Client's test_segm_ipa_stream_cli_cli_read_cb():      msg 
buff data: 04 01 01
+{20.625033} [NA] Client's test_segm_ipa_stream_cli_cli_read_cb():      IPA 
payload: 04 01 01
+{20.625033} [NA] Client's test_segm_ipa_stream_cli_cli_read_cb():      Type: 
IPAC_MSGT_ID_GET
+{20.625033} [NA] Client's test_segm_ipa_stream_cli_cli_read_cb():      (msg 
dump (including stripped headers): 00 03 fe 04 01 01 )
+{20.625033} [NA] Client's test_segm_ipa_stream_cli_cli_read_cb(): [6-cli] 
Received message from stream (len = 1)
+{20.625033} [NA] Client's test_segm_ipa_stream_cli_cli_read_cb():      msg 
buff data: 01
+{20.625033} [NA] Client's test_segm_ipa_stream_cli_cli_read_cb():      IPA 
payload: 01
+{20.625033} [NA] Client's test_segm_ipa_stream_cli_cli_read_cb():      Type: 
IPAC_MSGT_PONG
+{20.625033} [NA] Client's test_segm_ipa_stream_cli_cli_read_cb():      (msg 
dump (including stripped headers): 00 01 fe 01 )
+{20.625033} [NA] Client's test_segm_ipa_stream_cli_cli_read_cb(): [7-cli] 
Received message from stream (len = 1)
+{20.625033} [NA] Client's test_segm_ipa_stream_cli_cli_read_cb():      msg 
buff data: 01
+{20.625033} [NA] Client's test_segm_ipa_stream_cli_cli_read_cb():      IPA 
payload: 01
+{20.625033} [NA] Client's test_segm_ipa_stream_cli_cli_read_cb():      Type: 
IPAC_MSGT_PONG
+{20.625033} [NA] Client's test_segm_ipa_stream_cli_cli_read_cb():      (msg 
dump (including stripped headers): 00 01 fe 01 )
 ==================================Test test_segm_ipa_stream_cli 
complete========================================

 Stream tests completed

--
To view, visit https://gerrit.osmocom.org/c/libosmo-netif/+/34799?usp=email
To unsubscribe, or for help writing mail filters, visit 
https://gerrit.osmocom.org/settings

Gerrit-Project: libosmo-netif
Gerrit-Branch: master
Gerrit-Change-Id: I9ef02ed113bc049ae430b93d0eb69641e2ee809b
Gerrit-Change-Number: 34799
Gerrit-PatchSet: 1
Gerrit-Owner: arehbein <arehb...@sysmocom.de>
Gerrit-MessageType: newchange

Reply via email to