59 	test_data.input_pos = 0;  in test_recv_buf()
64 				 msg_type, remaining, 0);  in test_recv_buf()
76 	0x81, 0x8c, 0xe1, 0x7e, 0x8e, 0xb9, 0x95, 0x1b,
77 	0xfd, 0xcd, 0xc1, 0x13, 0xeb, 0xca, 0x92, 0x1f,
78 	0xe9, 0xdc
83 	't', 'e', 's', 't', ' ', 'm', 'e', 's', 's', 'a', 'g', 'e', '\0'
90 	0x81, 0x8c, 0xe1, 0x7e, 0x8e, 0xb9, 0x95, 0x1b,
91 	0xfd, 0xcd, 0xc1, 0x13, 0xeb, 0xca, 0x92, 0x1f,
92 	0xe9, 0xdc,
93 	0x81, 0x8c, 0xe1, 0x7e, 0x8e, 0xb9, 0x95, 0x1b,
94 	0xfd, 0xcd, 0xc1, 0x13, 0xeb, 0xca, 0x92, 0x1f,
95 	0xe9, 0xdc
99 static const unsigned char ping[] = {0x89, 0x00};
108 	int total_read = 0;  in test_recv()
111 	memset(&ctx, 0, sizeof(ctx));  in test_recv()
115 	ctx.recv_buf.count = 0;  in test_recv()
123 	for (i = 0; i < sizeof(frame1) / count; i++) {  in test_recv()
139 	if (left > 0) {  in test_recv()
170 	zassert_equal(remaining, 0, "Msg not empty");  in test_recv()
227 	int total_read = 0;  in ZTEST()
231 	memset(&ctx, 0, sizeof(ctx));  in ZTEST()
235 	ctx.recv_buf.count = 0;  in ZTEST()
239 	total_read = test_recv_buf(&feed_buf[0], sizeof(ping), &ctx, &msg_type, &remaining,  in ZTEST()
242 	zassert_equal(total_read, 0, "Msg not empty (ret %d)", total_read);  in ZTEST()
251 	int total_read = 0;  in test_recv_2()
254 	memset(&ctx, 0, sizeof(ctx));  in test_recv_2()
264 	total_read = test_recv_buf(&feed_buf[0], count, &ctx, &msg_type,  in test_recv_2()
271 	zassert_equal(remaining, 0, "Msg not empty");  in test_recv_2()
283 	zassert_equal(remaining, 0, "Msg not empty");  in test_recv_2()
297 	size_t split_len = 0, total_read = 0;  in verify_sent_and_received_msg()
300 	memset(&ctx, 0, sizeof(ctx));  in verify_sent_and_received_msg()
306 	ret = test_recv_buf(msg->msg_iov[0].iov_base,  in verify_sent_and_received_msg()
307 			    msg->msg_iov[0].iov_len,  in verify_sent_and_received_msg()
310 	if (remaining > 0) {  in verify_sent_and_received_msg()
313 		zassert_equal(ret, 0, "Msg header read error (ret %d)", ret);  in verify_sent_and_received_msg()
324 		zassert_true(ret > 0, "Cannot read data (%d)", ret);  in verify_sent_and_received_msg()
330 	while (remaining > 0) {  in verify_sent_and_received_msg()
336 		zassert_true(ret > 0, "Cannot read data (%d)", ret);  in verify_sent_and_received_msg()
338 		if (memcmp(recv_buf, lorem_ipsum + total_read, ret) != 0) {  in verify_sent_and_received_msg()
354 		msg->msg_iov[0].iov_len, total_read);  in verify_sent_and_received_msg()
356 	return msg->msg_iov[0].iov_len + total_read;  in verify_sent_and_received_msg()
364 	memset(&ctx, 0, sizeof(ctx));  in ZTEST()
387 	memset(&ctx, 0, sizeof(ctx));  in ZTEST()
410 	memset(&ctx, 0, sizeof(ctx));  in ZTEST()
415 	test_msg_len = 0;  in ZTEST()
431 	int total_read = 0;  in ZTEST()
436 	memset(&ctx, 0, sizeof(ctx));  in ZTEST()
444 	ret = test_recv_buf(&feed_buf[0], sizeof(frame1), &ctx, &msg_type, &remaining, recv_buf,  in ZTEST()
451 	ret = test_recv_buf(&feed_buf[sizeof(frame1)], 0, &ctx, &msg_type, &remaining,  in ZTEST()