Lines Matching refs:sp
56 iperf_tcp_recv(struct iperf_stream *sp) in iperf_tcp_recv() argument
60 r = Nread(sp->socket, sp->buffer, sp->settings->blksize, Ptcp); in iperf_tcp_recv()
66 if (sp->test->state == TEST_RUNNING) { in iperf_tcp_recv()
67 sp->result->bytes_received += r; in iperf_tcp_recv()
68 sp->result->bytes_received_this_interval += r; 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()
84 iperf_tcp_send(struct iperf_stream *sp) in iperf_tcp_send() argument
88 if (!sp->pending_size) in iperf_tcp_send()
89 sp->pending_size = sp->settings->blksize; in iperf_tcp_send()
91 if (sp->test->zerocopy) in iperf_tcp_send()
92 r = Nsendfile(sp->buffer_fd, sp->socket, sp->buffer, sp->pending_size); in iperf_tcp_send()
94 r = Nwrite(sp->socket, sp->buffer, sp->pending_size, Ptcp); in iperf_tcp_send()
99 sp->pending_size -= r; in iperf_tcp_send()
100 sp->result->bytes_sent += r; in iperf_tcp_send()
101 sp->result->bytes_sent_this_interval += r; in iperf_tcp_send()
103 if (sp->test->debug_level >= DEBUG_LEVEL_DEBUG) in iperf_tcp_send()
105 r, sp->settings->blksize, sp->pending_size, sp->result->bytes_sent); in iperf_tcp_send()