Lines Matching refs:tcp_stream_request
1321 struct tcp_stream_request_struct *tcp_stream_request; in send_tcp_stream() local
1325 tcp_stream_request = in send_tcp_stream()
1448 tcp_stream_request->send_buf_size = rss_size_req; in send_tcp_stream()
1449 tcp_stream_request->recv_buf_size = rsr_size_req; in send_tcp_stream()
1450 tcp_stream_request->receive_size = recv_size; in send_tcp_stream()
1451 tcp_stream_request->no_delay = rem_nodelay; in send_tcp_stream()
1452 tcp_stream_request->recv_alignment = remote_recv_align; in send_tcp_stream()
1453 tcp_stream_request->recv_offset = remote_recv_offset; in send_tcp_stream()
1454 tcp_stream_request->measure_cpu = remote_cpu_usage; in send_tcp_stream()
1455 tcp_stream_request->cpu_rate = remote_cpu_rate; in send_tcp_stream()
1457 tcp_stream_request->test_length = test_time; in send_tcp_stream()
1460 tcp_stream_request->test_length = test_bytes; in send_tcp_stream()
1462 tcp_stream_request->so_rcvavoid = rem_rcvavoid; in send_tcp_stream()
1463 tcp_stream_request->so_sndavoid = rem_sndavoid; in send_tcp_stream()
1465 tcp_stream_request->dirty_count = rem_dirty_count; in send_tcp_stream()
1466 tcp_stream_request->clean_count = rem_clean_count; in send_tcp_stream()
1468 tcp_stream_request->port = atoi(remote_data_port); in send_tcp_stream()
1469 tcp_stream_request->ipfamily = af_to_nf(remote_res->ai_family); in send_tcp_stream()
2735 struct tcp_stream_request_struct *tcp_stream_request; in send_exs_tcp_stream() local
2739 tcp_stream_request = in send_exs_tcp_stream()
2873 tcp_stream_request->send_buf_size = rss_size_req; in send_exs_tcp_stream()
2874 tcp_stream_request->recv_buf_size = rsr_size_req; in send_exs_tcp_stream()
2875 tcp_stream_request->receive_size = recv_size; in send_exs_tcp_stream()
2876 tcp_stream_request->no_delay = rem_nodelay; in send_exs_tcp_stream()
2877 tcp_stream_request->recv_alignment = remote_recv_align; in send_exs_tcp_stream()
2878 tcp_stream_request->recv_offset = remote_recv_offset; in send_exs_tcp_stream()
2879 tcp_stream_request->measure_cpu = remote_cpu_usage; in send_exs_tcp_stream()
2880 tcp_stream_request->cpu_rate = remote_cpu_rate; in send_exs_tcp_stream()
2882 tcp_stream_request->test_length = test_time; in send_exs_tcp_stream()
2885 tcp_stream_request->test_length = test_bytes; in send_exs_tcp_stream()
2887 tcp_stream_request->so_rcvavoid = rem_rcvavoid; in send_exs_tcp_stream()
2888 tcp_stream_request->so_sndavoid = rem_sndavoid; in send_exs_tcp_stream()
2890 tcp_stream_request->dirty_count = rem_dirty_count; in send_exs_tcp_stream()
2891 tcp_stream_request->clean_count = rem_clean_count; in send_exs_tcp_stream()
2893 tcp_stream_request->port = atoi(remote_data_port); in send_exs_tcp_stream()
2894 tcp_stream_request->ipfamily = af_to_nf(remote_res->ai_family); in send_exs_tcp_stream()
3508 struct tcp_stream_request_struct *tcp_stream_request; local
3512 tcp_stream_request =
3674 tcp_stream_request->send_buf_size = rss_size_req;
3675 tcp_stream_request->recv_buf_size = rsr_size_req;
3676 tcp_stream_request->receive_size = recv_size;
3677 tcp_stream_request->no_delay = rem_nodelay;
3678 tcp_stream_request->recv_alignment = remote_recv_align;
3679 tcp_stream_request->recv_offset = remote_recv_offset;
3680 tcp_stream_request->measure_cpu = remote_cpu_usage;
3681 tcp_stream_request->cpu_rate = remote_cpu_rate;
3684 tcp_stream_request->test_length = test_time;
3687 tcp_stream_request->test_length = test_bytes;
3690 tcp_stream_request->so_rcvavoid = rem_rcvavoid;
3691 tcp_stream_request->so_sndavoid = rem_sndavoid;
3694 tcp_stream_request->dirty_count = rem_dirty_count;
3695 tcp_stream_request->clean_count = rem_clean_count;
3697 tcp_stream_request->port = atoi(remote_data_port);
3698 tcp_stream_request->ipfamily = af_to_nf(remote_res->ai_family);
4250 struct tcp_stream_request_struct *tcp_stream_request; in recv_tcp_stream() local
4260 tcp_stream_request = in recv_tcp_stream()
4302 tcp_stream_request->recv_alignment); in recv_tcp_stream()
4310 lss_size_req = tcp_stream_request->send_buf_size; in recv_tcp_stream()
4311 lsr_size_req = tcp_stream_request->recv_buf_size; in recv_tcp_stream()
4312 loc_nodelay = tcp_stream_request->no_delay; in recv_tcp_stream()
4313 loc_rcvavoid = tcp_stream_request->so_rcvavoid; in recv_tcp_stream()
4314 loc_sndavoid = tcp_stream_request->so_sndavoid; in recv_tcp_stream()
4318 nf_to_af(tcp_stream_request->ipfamily), in recv_tcp_stream()
4319 tcp_stream_request->port); in recv_tcp_stream()
4324 nf_to_af(tcp_stream_request->ipfamily), in recv_tcp_stream()
4345 if (tcp_stream_request->receive_size == 0) { in recv_tcp_stream()
4354 recv_size = tcp_stream_request->receive_size; in recv_tcp_stream()
4371 tcp_stream_request->recv_alignment, in recv_tcp_stream()
4372 tcp_stream_request->recv_offset); in recv_tcp_stream()
4416 if (tcp_stream_request->measure_cpu) { in recv_tcp_stream()
4419 calibrate_local_cpu(tcp_stream_request->cpu_rate); in recv_tcp_stream()
4458 cpu_start(tcp_stream_request->measure_cpu); in recv_tcp_stream()
4486 tcp_stream_request->dirty_count, in recv_tcp_stream()
4487 tcp_stream_request->clean_count); in recv_tcp_stream()
4514 cpu_stop(tcp_stream_request->measure_cpu,&elapsed_time); in recv_tcp_stream()
4535 if (tcp_stream_request->measure_cpu) { in recv_tcp_stream()