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()

Related: OS#6222
Change-Id: I9ef02ed113bc049ae430b93d0eb69641e2ee809b

2 files changed, 79 insertions, 81 deletions

diff --git a/tests/stream/stream_test.c b/tests/stream/stream_test.c
index 4830302..0851558 100644
--- a/tests/stream/stream_test.c
+++ b/tests/stream/stream_test.c
@@ -340,10 +340,17 @@ static void test_recon(void *ctx, const char *host, unsigned port, unsigned step
 		       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 @@ static void test_recon(void *ctx, const char *host, unsigned port, unsigned step
 	}
 
 	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 @@ static int test_segm_ipa_stream_srv_cli_read_cb(struct osmo_stream_cli *osc, str
 	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 @@ struct osmo_stream_cli *test_segm_ipa_stream_srv_run_client(void)
 	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 @@ int test_segm_ipa_stream_srv_srv_read_cb(struct osmo_stream_srv *conn, struct ms
 
 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 @@ static void test_segm_ipa_stream_srv_run(void *ctx, const char *host, unsigned p
 		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 @@ int test_segm_ipa_stream_cli_srv_read_cb(struct osmo_stream_srv *conn, struct ms
 
 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 @@ static int test_segm_ipa_stream_cli_cli_read_cb(struct osmo_stream_cli *osc, str
 	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 @@ static void *test_segm_ipa_stream_cli_run_client(void)
 	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 @@ static void test_segm_ipa_stream_cli_run(void *ctx, const char *host, unsigned p
 		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,16 @@ int main(void)
 	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_free(tall_test);
 	return EXIT_SUCCESS;
 }
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 @@ Client/Server entering non-reconnecting event loop...
 {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 @@ ______________________________________Running test test_segm_ipa_stream_srv_____
 {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 @@ ______________________________________Running test test_segm_ipa_stream_cli_____
 {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 @@ ______________________________________Running test test_segm_ipa_stream_cli_____
 {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