90     if (sp->test->state == TEST_RUNNING) {  in iperf_udp_recv()
104 	if (sp->test->udp_counters_64bit) {  in iperf_udp_recv()
126 	if (sp->test->debug_level >= DEBUG_LEVEL_DEBUG)  in iperf_udp_recv()
169 	    if (sp->test->debug)  in iperf_udp_recv()
200 	if (sp->test->debug)  in iperf_udp_recv()
201 	    printf("Late receive, state = %d\n", sp->test->state);  in iperf_udp_recv()
223     if (sp->test->udp_counters_64bit) {  in iperf_udp_send()
259     if (sp->test->debug_level >=  DEBUG_LEVEL_DEBUG)  in iperf_udp_send()
283 iperf_udp_buffercheck(struct iperf_test *test, int s)  in iperf_udp_buffercheck()  argument
295     if ((opt = test->settings->socket_bufsize)) {  in iperf_udp_buffercheck()
312     if (test->debug) {  in iperf_udp_buffercheck()
313 	printf("SNDBUF is %u, expecting %u\n", sndbuf_actual, test->settings->socket_bufsize);  in iperf_udp_buffercheck()
315     if (test->settings->socket_bufsize && test->settings->socket_bufsize > sndbuf_actual) {  in iperf_udp_buffercheck()
319     if (test->settings->blksize > sndbuf_actual) {  in iperf_udp_buffercheck()
323 		 test->settings->blksize, sndbuf_actual);  in iperf_udp_buffercheck()
334     if (test->debug) {  in iperf_udp_buffercheck()
335 	printf("RCVBUF is %u, expecting %u\n", rcvbuf_actual, test->settings->socket_bufsize);  in iperf_udp_buffercheck()
337     if (test->settings->socket_bufsize && test->settings->socket_bufsize > rcvbuf_actual) {  in iperf_udp_buffercheck()
341     if (test->settings->blksize > rcvbuf_actual) {  in iperf_udp_buffercheck()
345 		 test->settings->blksize, rcvbuf_actual);  in iperf_udp_buffercheck()
350     if (test->json_output) {  in iperf_udp_buffercheck()
351 	cJSON_AddNumberToObject(test->json_start, "sock_bufsize", test->settings->socket_bufsize);  in iperf_udp_buffercheck()
352 	cJSON_AddNumberToObject(test->json_start, "sndbuf_actual", sndbuf_actual);  in iperf_udp_buffercheck()
353 	cJSON_AddNumberToObject(test->json_start, "rcvbuf_actual", rcvbuf_actual);  in iperf_udp_buffercheck()
365 iperf_udp_accept(struct iperf_test *test)  in iperf_udp_accept()  argument
377     s = test->prot_listener;  in iperf_udp_accept()
385 …if ((sz = recvfrom(test->prot_listener, &buf, sizeof(buf), 0, (struct sockaddr *) &sa_peer, &len))…  in iperf_udp_accept()
396     rc = iperf_udp_buffercheck(test, s);  in iperf_udp_accept()
405 	if (test->settings->socket_bufsize == 0) {  in iperf_udp_accept()
407 	    int bufsize = test->settings->blksize + UDP_BUFFER_EXTRA;  in iperf_udp_accept()
411 	    test->settings->socket_bufsize = bufsize;  in iperf_udp_accept()
412 	    rc = iperf_udp_buffercheck(test, s);  in iperf_udp_accept()
420     if (test->settings->fqrate) {  in iperf_udp_accept()
422 	unsigned int fqrate = test->settings->fqrate / 8;  in iperf_udp_accept()
424 	    if (test->debug) {  in iperf_udp_accept()
434 	unsigned int rate = test->settings->rate / 8;  in iperf_udp_accept()
436 	    if (test->debug) {  in iperf_udp_accept()
445 …test->prot_listener = netannounce(test->settings->domain, Pudp, test->bind_address, test->bind_dev…  in iperf_udp_accept()
446     if (test->prot_listener < 0) {  in iperf_udp_accept()
451     FD_SET(test->prot_listener, &test->read_set);  in iperf_udp_accept()
452     test->max_fd = (test->max_fd < test->prot_listener) ? test->prot_listener : test->max_fd;  in iperf_udp_accept()
473 iperf_udp_listen(struct iperf_test *test)  in iperf_udp_listen()  argument
477 …if ((s = netannounce(test->settings->domain, Pudp, test->bind_address, test->bind_dev, test->serve…  in iperf_udp_listen()
495 iperf_udp_connect(struct iperf_test *test)  in iperf_udp_connect()  argument
506 …if ((s = netdial(test->settings->domain, Pudp, test->bind_address, test->bind_dev, test->bind_port…  in iperf_udp_connect()
512     rc = iperf_udp_buffercheck(test, s);  in iperf_udp_connect()
521 	if (test->settings->socket_bufsize == 0) {  in iperf_udp_connect()
523 	    int bufsize = test->settings->blksize + UDP_BUFFER_EXTRA;  in iperf_udp_connect()
527 	    test->settings->socket_bufsize = bufsize;  in iperf_udp_connect()
528 	    rc = iperf_udp_buffercheck(test, s);  in iperf_udp_connect()
536     if (test->settings->fqrate) {  in iperf_udp_connect()
538 	unsigned int fqrate = test->settings->fqrate / 8;  in iperf_udp_connect()
540 	    if (test->debug) {  in iperf_udp_connect()
550 	unsigned int rate = test->settings->rate / 8;  in iperf_udp_connect()
552 	    if (test->debug) {  in iperf_udp_connect()
570     if (test->debug) {  in iperf_udp_connect()
584 …if (test->reverse) /* In reverse mode allow few packets to have the "accept" response - to handle …  in iperf_udp_connect()
585         max_len_wait_for_reply += MAX_REVERSE_OUT_OF_ORDER_PACKETS * test->settings->blksize;  in iperf_udp_connect()
591         if (test->debug) {  in iperf_udp_connect()
611 iperf_udp_init(struct iperf_test *test)  in iperf_udp_init()  argument