Lines Matching refs:test_data

266 	struct test_msg_waitall_data *test_data =  in test_msg_waitall_tx_work_handler()  local
269 if (test_data->retries > 0) { in test_msg_waitall_tx_work_handler()
270 test_send(test_data->sock, test_data->data + test_data->offset, 1, 0); in test_msg_waitall_tx_work_handler()
271 test_data->offset++; in test_msg_waitall_tx_work_handler()
272 test_data->retries--; in test_msg_waitall_tx_work_handler()
273 test_work_reschedule(&test_data->tx_work, K_MSEC(10)); in test_msg_waitall_tx_work_handler()
314 struct connect_data test_data; in test_prepare_tls_connection() local
340 test_data.sock = c_sock; in test_prepare_tls_connection()
341 test_data.addr = &s_saddr; in test_prepare_tls_connection()
342 k_work_init_delayable(&test_data.work, client_connect_work_handler); in test_prepare_tls_connection()
343 test_work_reschedule(&test_data.work, K_NO_WAIT); in test_prepare_tls_connection()
348 test_work_wait(&test_data.work); in test_prepare_tls_connection()
358 struct connect_data test_data; in test_prepare_dtls_connection() local
389 test_data.sock = c_sock; in test_prepare_dtls_connection()
390 test_data.addr = &s_saddr; in test_prepare_dtls_connection()
391 k_work_init_delayable(&test_data.work, dtls_client_connect_send_work_handler); in test_prepare_dtls_connection()
392 test_work_reschedule(&test_data.work, K_NO_WAIT); in test_prepare_dtls_connection()
407 test_work_wait(&test_data.work); in test_prepare_dtls_connection()
412 struct test_msg_waitall_data test_data = { in ZTEST() local
427 test_data.offset = 0; in ZTEST()
428 test_data.retries = sizeof(rx_buf); in ZTEST()
429 test_data.sock = c_sock; in ZTEST()
430 k_work_init_delayable(&test_data.tx_work, in ZTEST()
432 test_work_reschedule(&test_data.tx_work, K_MSEC(10)); in ZTEST()
438 test_work_wait(&test_data.tx_work); in ZTEST()
448 test_data.offset = 0; in ZTEST()
449 test_data.retries = sizeof(rx_buf) - 1; in ZTEST()
450 test_data.sock = c_sock; in ZTEST()
451 k_work_init_delayable(&test_data.tx_work, in ZTEST()
453 test_work_reschedule(&test_data.tx_work, K_MSEC(10)); in ZTEST()
459 test_work_wait(&test_data.tx_work); in ZTEST()
468 struct test_msg_waitall_data test_data = { in ZTEST() local
483 test_data.offset = 0; in ZTEST()
484 test_data.retries = sizeof(rx_buf); in ZTEST()
485 test_data.sock = c_sock; in ZTEST()
486 k_work_init_delayable(&test_data.tx_work, in ZTEST()
488 test_work_reschedule(&test_data.tx_work, K_MSEC(10)); in ZTEST()
494 test_work_wait(&test_data.tx_work); in ZTEST()
504 test_data.offset = 0; in ZTEST()
505 test_data.retries = sizeof(rx_buf) - 1; in ZTEST()
506 test_data.sock = c_sock; in ZTEST()
507 k_work_init_delayable(&test_data.tx_work, in ZTEST()
509 test_work_reschedule(&test_data.tx_work, K_MSEC(10)); in ZTEST()
515 test_work_wait(&test_data.tx_work); in ZTEST()
532 struct send_data *test_data = in send_work_handler() local
535 test_send(test_data->sock, test_data->data, test_data->datalen, 0); in send_work_handler()
542 struct send_data test_data = { in test_msg_trunc() local
551 test_data.sock = c_sock; in test_msg_trunc()
552 k_work_init_delayable(&test_data.tx_work, send_work_handler); in test_msg_trunc()
553 test_work_reschedule(&test_data.tx_work, K_MSEC(10)); in test_msg_trunc()
570 test_work_wait(&test_data.tx_work); in test_msg_trunc()
595 struct test_sendmsg_data *test_data = in test_sendmsg_tx_work_handler() local
598 test_sendmsg(test_data->sock, test_data->msg, 0); in test_sendmsg_tx_work_handler()
614 struct test_sendmsg_data test_data = { in test_dtls_sendmsg_no_buf() local
620 test_data.sock = c_sock; in test_dtls_sendmsg_no_buf()
621 k_work_init_delayable(&test_data.tx_work, test_sendmsg_tx_work_handler); in test_dtls_sendmsg_no_buf()
628 test_work_reschedule(&test_data.tx_work, K_MSEC(10)); in test_dtls_sendmsg_no_buf()
635 test_work_wait(&test_data.tx_work); in test_dtls_sendmsg_no_buf()
642 test_work_reschedule(&test_data.tx_work, K_MSEC(10)); in test_dtls_sendmsg_no_buf()
649 test_work_wait(&test_data.tx_work); in test_dtls_sendmsg_no_buf()
702 struct test_sendmsg_data test_data = { in test_dtls_sendmsg() local
708 test_data.sock = c_sock; in test_dtls_sendmsg()
709 k_work_init_delayable(&test_data.tx_work, test_sendmsg_tx_work_handler); in test_dtls_sendmsg()
716 test_work_reschedule(&test_data.tx_work, K_NO_WAIT); in test_dtls_sendmsg()
723 test_work_wait(&test_data.tx_work); in test_dtls_sendmsg()
734 test_work_reschedule(&test_data.tx_work, K_NO_WAIT); in test_dtls_sendmsg()
741 test_work_wait(&test_data.tx_work); in test_dtls_sendmsg()
753 test_work_reschedule(&test_data.tx_work, K_NO_WAIT); in test_dtls_sendmsg()
765 test_work_wait(&test_data.tx_work); in test_dtls_sendmsg()
1132 struct send_data test_data = { in ZTEST() local
1139 test_data.sock = c_sock; in ZTEST()
1140 k_work_init_delayable(&test_data.tx_work, send_work_handler); in ZTEST()
1141 test_work_reschedule(&test_data.tx_work, K_MSEC(10)); in ZTEST()
1240 struct recv_data *test_data = CONTAINER_OF(dwork, struct recv_data, work); in recv_work_handler() local
1245 while (off < test_data->datalen) { in recv_work_handler()
1246 size_t recvlen = MIN(sizeof(rx_buf), test_data->datalen - off); in recv_work_handler()
1248 ret = zsock_recv(test_data->sock, rx_buf, recvlen, 0); in recv_work_handler()
1250 zassert_mem_equal(rx_buf, test_data->data + off, ret, in recv_work_handler()
1254 zassert_true(off <= test_data->datalen, in recv_work_handler()
1264 struct recv_data test_data = { in ZTEST() local
1285 test_data.sock = new_sock; in ZTEST()
1286 k_work_init_delayable(&test_data.work, recv_work_handler); in ZTEST()
1287 test_work_reschedule(&test_data.work, K_MSEC(10)); in ZTEST()
1365 struct send_data test_data = { in ZTEST() local
1386 test_data.sock = c_sock; in ZTEST()
1387 k_work_init_delayable(&test_data.tx_work, send_work_handler); in ZTEST()
1388 test_work_reschedule(&test_data.tx_work, K_MSEC(10)); in ZTEST()
1408 struct recv_data test_data = { in ZTEST() local
1441 test_data.sock = new_sock; in ZTEST()
1442 k_work_init_delayable(&test_data.work, recv_work_handler); in ZTEST()
1443 test_work_reschedule(&test_data.work, K_MSEC(10)); in ZTEST()
1486 struct shutdown_data test_data = { in ZTEST() local
1493 k_work_init_delayable(&test_data.work, shutdown_work); in ZTEST()
1494 test_data.sock = c_sock; in ZTEST()
1495 test_work_reschedule(&test_data.work, K_MSEC(10)); in ZTEST()
1579 struct send_data test_data = { in ZTEST() local
1594 test_data.sock = c_sock; in ZTEST()
1595 k_work_init_delayable(&test_data.tx_work, send_work_handler); in ZTEST()
1596 test_work_reschedule(&test_data.tx_work, K_NO_WAIT); in ZTEST()