Home
last modified time | relevance | path

Searched refs:sp (Results 1 – 9 of 9) sorted by relevance

/iperf/src/
H A Diperf_udp.c79 r = Nread(sp->socket, sp->buffer, size, Pudp); in iperf_udp_recv()
147 sp->cnt_error += (pcount - 1) - sp->packet_count; in iperf_udp_recv()
157 sp->outoforder_packets++; in iperf_udp_recv()
165 if (sp->cnt_error > 0) in iperf_udp_recv()
166 sp->cnt_error--; in iperf_udp_recv()
169 if (sp->test->debug) in iperf_udp_recv()
196 sp->prev_transit = transit; in iperf_udp_recv()
197 sp->jitter += (d - sp->jitter) / 16.0; in iperf_udp_recv()
200 if (sp->test->debug) in iperf_udp_recv()
221 ++sp->packet_count; in iperf_udp_send()
[all …]
H A Diperf_api.c1857 if ((sp->green_light && sp->sender && in iperf_send()
1863 if ((r = sp->snd(sp)) < 0) { in iperf_send()
1902 if ((r = sp->rcv(sp)) < 0) { in iperf_recv()
4262 sp->snd2 = sp->snd; in iperf_new_stream()
4264 sp->rcv2 = sp->rcv; in iperf_new_stream()
4409 if (sp->diskfile_left < sp->test->settings->blksize && !sp->test->done) { in diskfile_send()
4410 r = read(sp->diskfile_fd, sp->buffer, sp->test->settings->blksize - in diskfile_send()
4447 r = sp->snd2(sp); in diskfile_send()
4458 if (sp->diskfile_left && sp->diskfile_left < sp->test->settings->blksize) { in diskfile_send()
4460 sp->buffer + (sp->test->settings->blksize - sp->diskfile_left), in diskfile_send()
[all …]
H A Diperf_tcp.c60 r = Nread(sp->socket, sp->buffer, sp->settings->blksize, Ptcp); in iperf_tcp_recv()
67 sp->result->bytes_received += r; in iperf_tcp_recv()
71 if (sp->test->debug) in iperf_tcp_recv()
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()
[all …]
H A Diperf_server_api.c185 struct iperf_stream *sp; in iperf_handle_message_server() local
210 close(sp->socket); in iperf_handle_message_server()
240 close(sp->socket); in iperf_handle_message_server()
256 struct iperf_stream *sp; in server_timer_proc() local
266 close(sp->socket); in server_timer_proc()
267 iperf_free_stream(sp); in server_timer_proc()
383 struct iperf_stream *sp; in cleanup_server() local
387 FD_CLR(sp->socket, &test->read_set); in cleanup_server()
388 FD_CLR(sp->socket, &test->write_set); in cleanup_server()
389 close(sp->socket); in cleanup_server()
[all …]
H A Diperf_sctp.c58 iperf_sctp_recv(struct iperf_stream *sp) in iperf_sctp_recv() argument
63 r = Nread(sp->socket, sp->buffer, sp->settings->blksize, Psctp); in iperf_sctp_recv()
68 if (sp->test->state == TEST_RUNNING) { in iperf_sctp_recv()
69 sp->result->bytes_received += r; in iperf_sctp_recv()
70 sp->result->bytes_received_this_interval += r; in iperf_sctp_recv()
73 if (sp->test->debug) in iperf_sctp_recv()
74 printf("Late receive, state = %d\n", sp->test->state); in iperf_sctp_recv()
90 iperf_sctp_send(struct iperf_stream *sp) in iperf_sctp_send() argument
95 r = Nwrite(sp->socket, sp->buffer, sp->settings->blksize, Psctp); in iperf_sctp_send()
99 sp->result->bytes_sent += r; in iperf_sctp_send()
[all …]
H A Diperf_client_api.c66 struct iperf_stream *sp; in iperf_create_streams() local
124 sp = iperf_new_stream(test, s, sender); in iperf_create_streams()
125 if (!sp) in iperf_create_streams()
130 test->on_new_stream(sp); in iperf_create_streams()
486 struct iperf_stream *sp; in iperf_client_end() local
489 SLIST_FOREACH(sp, &test->streams, streams) { in iperf_client_end()
490 close(sp->socket); in iperf_client_end()
518 struct iperf_stream *sp; in iperf_run_client() local
625 SLIST_FOREACH(sp, &test->streams, streams) { in iperf_run_client()
626 setnonblocking(sp->socket, 1); in iperf_run_client()
[all …]
H A Dtcp_info.c95 save_tcpinfo(struct iperf_stream *sp, struct iperf_interval_results *irp) in save_tcpinfo() argument
101 if (getsockopt(sp->socket, IPPROTO_TCP, TCP_INFO, (void *)&irp->tcpInfo, &tcp_info_length) < 0) in save_tcpinfo()
102 iperf_err(sp->test, "getsockopt - %s", strerror(errno)); in save_tcpinfo()
104 if (sp->test->debug) { in save_tcpinfo()
H A Diperf_api.h227 void connect_msg(struct iperf_stream * sp);
282 void iperf_free_stream(struct iperf_stream * sp);
286 void save_tcpinfo(struct iperf_stream *sp, struct iperf_interval_results *irp);
297 void iperf_check_throttle(struct iperf_stream *sp, struct iperf_time *nowP);
/iperf/config/
H A Dltmain.sh141 sp=' '
144 IFS="$sp $nl"
2841 IFS=$sp$nl
10312 IFS=$sp$nl