Lines Matching refs:test

66     if (sp->test->state == TEST_RUNNING) {  in iperf_tcp_recv()
71 if (sp->test->debug) in iperf_tcp_recv()
72 printf("Late receive, state = %d\n", sp->test->state); in iperf_tcp_recv()
91 if (sp->test->zerocopy) in iperf_tcp_send()
103 if (sp->test->debug_level >= DEBUG_LEVEL_DEBUG) in iperf_tcp_send()
116 iperf_tcp_accept(struct iperf_test * test) in iperf_tcp_accept() argument
125 if ((s = accept(test->listener, (struct sockaddr *) &addr, &len)) < 0) { in iperf_tcp_accept()
135 if (strcmp(test->cookie, cookie) != 0) { in iperf_tcp_accept()
137 …iperf_err(test, "failed to send access denied from busy server to new connecting client, errno = %… in iperf_tcp_accept()
151 iperf_tcp_listen(struct iperf_test *test) in iperf_tcp_listen() argument
158 s = test->listener; in iperf_tcp_listen()
169 if (test->no_delay || test->settings->mss || test->settings->socket_bufsize) { in iperf_tcp_listen()
173 FD_CLR(s, &test->read_set); in iperf_tcp_listen()
176 snprintf(portstr, 6, "%d", test->server_port); in iperf_tcp_listen()
184 if (test->settings->domain == AF_UNSPEC && !test->bind_address) { in iperf_tcp_listen()
188 hints.ai_family = test->settings->domain; in iperf_tcp_listen()
192 if ((gerror = getaddrinfo(test->bind_address, portstr, &hints, &res)) != 0) { in iperf_tcp_listen()
203 if (test->no_delay) { in iperf_tcp_listen()
215 if ((opt = test->settings->mss)) { in iperf_tcp_listen()
225 if ((opt = test->settings->socket_bufsize)) { in iperf_tcp_listen()
245 if (test->settings->fqrate) { in iperf_tcp_listen()
247 unsigned int fqrate = test->settings->fqrate / 8; in iperf_tcp_listen()
249 if (test->debug) { in iperf_tcp_listen()
259 unsigned int rate = test->settings->rate / 8; in iperf_tcp_listen()
261 if (test->debug) { in iperf_tcp_listen()
282 …if (res->ai_family == AF_INET6 && (test->settings->domain == AF_UNSPEC || test->settings->domain =… in iperf_tcp_listen()
283 if (test->settings->domain == AF_UNSPEC) in iperf_tcp_listen()
315 test->listener = s; in iperf_tcp_listen()
327 if (test->debug) { in iperf_tcp_listen()
328 printf("SNDBUF is %u, expecting %u\n", sndbuf_actual, test->settings->socket_bufsize); in iperf_tcp_listen()
330 if (test->settings->socket_bufsize && test->settings->socket_bufsize > sndbuf_actual) { in iperf_tcp_listen()
344 if (test->debug) { in iperf_tcp_listen()
345 printf("RCVBUF is %u, expecting %u\n", rcvbuf_actual, test->settings->socket_bufsize); in iperf_tcp_listen()
347 if (test->settings->socket_bufsize && test->settings->socket_bufsize > rcvbuf_actual) { in iperf_tcp_listen()
352 if (test->json_output) { in iperf_tcp_listen()
353 cJSON_AddNumberToObject(test->json_start, "sock_bufsize", test->settings->socket_bufsize); in iperf_tcp_listen()
354 cJSON_AddNumberToObject(test->json_start, "sndbuf_actual", sndbuf_actual); in iperf_tcp_listen()
355 cJSON_AddNumberToObject(test->json_start, "rcvbuf_actual", rcvbuf_actual); in iperf_tcp_listen()
370 iperf_tcp_connect(struct iperf_test *test) in iperf_tcp_connect() argument
378 …s = create_socket(test->settings->domain, SOCK_STREAM, test->bind_address, test->bind_dev, test->b… in iperf_tcp_connect()
385 if (test->no_delay) { in iperf_tcp_connect()
396 if ((opt = test->settings->mss)) { in iperf_tcp_connect()
406 if ((opt = test->settings->socket_bufsize)) { in iperf_tcp_connect()
425 if ((opt = test->settings->snd_timeout)) { in iperf_tcp_connect()
447 if (test->debug) { in iperf_tcp_connect()
448 printf("SNDBUF is %u, expecting %u\n", sndbuf_actual, test->settings->socket_bufsize); in iperf_tcp_connect()
450 if (test->settings->socket_bufsize && test->settings->socket_bufsize > sndbuf_actual) { in iperf_tcp_connect()
465 if (test->debug) { in iperf_tcp_connect()
466 printf("RCVBUF is %u, expecting %u\n", rcvbuf_actual, test->settings->socket_bufsize); in iperf_tcp_connect()
468 if (test->settings->socket_bufsize && test->settings->socket_bufsize > rcvbuf_actual) { in iperf_tcp_connect()
473 if (test->json_output) { in iperf_tcp_connect()
474 cJSON_AddNumberToObject(test->json_start, "sock_bufsize", test->settings->socket_bufsize); in iperf_tcp_connect()
475 cJSON_AddNumberToObject(test->json_start, "sndbuf_actual", sndbuf_actual); in iperf_tcp_connect()
476 cJSON_AddNumberToObject(test->json_start, "rcvbuf_actual", rcvbuf_actual); in iperf_tcp_connect()
480 if (test->settings->flowlabel) { in iperf_tcp_connect()
495 freq->flr_label = htonl(test->settings->flowlabel & IPV6_FLOWINFO_FLOWLABEL); in iperf_tcp_connect()
526 if (test->settings->fqrate) { in iperf_tcp_connect()
528 unsigned int fqrate = test->settings->fqrate / 8; in iperf_tcp_connect()
530 if (test->debug) { in iperf_tcp_connect()
540 unsigned int rate = test->settings->rate / 8; in iperf_tcp_connect()
542 if (test->debug) { in iperf_tcp_connect()
560 if (Nwrite(s, test->cookie, COOKIE_SIZE, Ptcp) < 0) { in iperf_tcp_connect()