Lines Matching refs:omni_request
3646 set_omni_request_flags(struct omni_request_struct *omni_request) { in set_omni_request_flags() argument
3651 omni_request->flags |= OMNI_NO_DELAY; in set_omni_request_flags()
3654 omni_request->flags |= OMNI_USE_SENDFILE; in set_omni_request_flags()
3657 omni_request->flags |= OMNI_CONNECT_TEST; in set_omni_request_flags()
3660 omni_request->flags |= OMNI_CHECKSUM_OFF; in set_omni_request_flags()
3663 omni_request->flags |= OMNI_MEASURE_CPU; in set_omni_request_flags()
3666 omni_request->flags |= OMNI_ROUTING_ALLOWED; in set_omni_request_flags()
3669 omni_request->flags |= OMNI_WANT_IFNAME; in set_omni_request_flags()
3672 omni_request->flags |= OMNI_WANT_IFSLOT; in set_omni_request_flags()
3675 omni_request->flags |= OMNI_WANT_IFIDS; in set_omni_request_flags()
3678 omni_request->flags |= OMNI_WANT_DRVINFO; in set_omni_request_flags()
3681 omni_request->flags |= OMNI_WANT_REM_CONG; in set_omni_request_flags()
3684 omni_request->flags |= OMNI_FASTOPEN; in set_omni_request_flags()
3687 omni_request->flags |= OMNI_USE_PKTINFO; in set_omni_request_flags()
3690 omni_request->flags |= OMNI_WANT_DEFER_ACCEPT; in set_omni_request_flags()
3727 struct omni_request_struct *omni_request; in send_omni_inner() local
3735 omni_request = in send_omni_inner()
3939 omni_request->flags = 0; in send_omni_inner()
3940 omni_request->send_buf_size = rss_size_req; in send_omni_inner()
3941 omni_request->send_size = remote_send_size_req; in send_omni_inner()
3942 omni_request->send_alignment = remote_send_align; in send_omni_inner()
3943 omni_request->send_offset = remote_send_offset; in send_omni_inner()
3944 omni_request->send_width = send_width; in send_omni_inner()
3945 omni_request->request_size = req_size; in send_omni_inner()
3947 omni_request->recv_buf_size = rsr_size_req; in send_omni_inner()
3948 omni_request->receive_size = remote_recv_size_req; in send_omni_inner()
3949 omni_request->recv_alignment = remote_recv_align; in send_omni_inner()
3950 omni_request->recv_offset = remote_recv_offset; in send_omni_inner()
3951 omni_request->recv_width = recv_width; in send_omni_inner()
3952 omni_request->response_size = rsp_size; in send_omni_inner()
3953 omni_request->socket_prio = remote_socket_prio; in send_omni_inner()
3954 omni_request->socket_tos = remote_socket_tos; in send_omni_inner()
3956 set_omni_request_flags(omni_request); in send_omni_inner()
3960 strncpy(omni_request->cong_control, in send_omni_inner()
3962 sizeof(omni_request->cong_control)); in send_omni_inner()
3963 omni_request->cong_control[sizeof(omni_request->cong_control) - 1] = in send_omni_inner()
3967 omni_request->flags |= OMNI_WANT_KEEPALIVE; in send_omni_inner()
3969 omni_request->cpu_rate = remote_cpu_rate; in send_omni_inner()
3971 omni_request->test_length = test_time; in send_omni_inner()
3973 omni_request->test_length = test_trans * -1; in send_omni_inner()
3974 omni_request->so_rcvavoid = rem_rcvavoid; in send_omni_inner()
3975 omni_request->so_sndavoid = rem_sndavoid; in send_omni_inner()
3976 omni_request->send_dirty_count = rem_dirty_count; in send_omni_inner()
3977 omni_request->recv_dirty_count = rem_dirty_count; in send_omni_inner()
3978 omni_request->recv_clean_count = rem_clean_count; in send_omni_inner()
3980 omni_request->data_port = atoi(remote_data_port); in send_omni_inner()
3981 omni_request->ipfamily = af_to_nf(remote_res->ai_family); in send_omni_inner()
3982 omni_request->socket_type = hst_to_nst(socket_type); in send_omni_inner()
3983 omni_request->protocol = protocol; in send_omni_inner()
3985 omni_request->interval_burst = remote_interval_burst; in send_omni_inner()
3986 omni_request->interval_usecs = remote_interval_usecs; in send_omni_inner()
3988 omni_request->direction = 0; in send_omni_inner()
3992 omni_request->direction |= NETPERF_RECV; in send_omni_inner()
3994 omni_request->direction |= NETPERF_XMIT; in send_omni_inner()
4002 nf_to_af(omni_request->ipfamily), in send_omni_inner()
4003 omni_request->netperf_ip, in send_omni_inner()
4004 &(omni_request->netperf_port)); in send_omni_inner()
4006 nf_to_af(omni_request->ipfamily), in send_omni_inner()
4007 omni_request->netserver_ip, in send_omni_inner()
4008 &(omni_request->data_port)); in send_omni_inner()
4014 omni_request->netserver_ip[0] = 0; in send_omni_inner()
4015 omni_request->netserver_ip[1] = 0; in send_omni_inner()
4016 omni_request->netserver_ip[2] = 0; in send_omni_inner()
4017 omni_request->netserver_ip[3] = 0; in send_omni_inner()
4023 strncpy(omni_request->fill_file, in send_omni_inner()
4025 sizeof(omni_request->fill_file)); in send_omni_inner()
4996 struct omni_request_struct *omni_request; in recv_omni() local
5000 omni_request = in recv_omni()
5019 omni_request->cong_control, in recv_omni()
5049 lss_size_req = omni_request->send_buf_size; in recv_omni()
5050 lsr_size_req = omni_request->recv_buf_size; in recv_omni()
5051 loc_nodelay = (omni_request->flags) & OMNI_NO_DELAY; in recv_omni()
5052 loc_rcvavoid = omni_request->so_rcvavoid; in recv_omni()
5053 loc_sndavoid = omni_request->so_sndavoid; in recv_omni()
5054 routing_allowed = (omni_request->flags) & OMNI_ROUTING_ALLOWED; in recv_omni()
5055 want_keepalive = (omni_request->flags) & OMNI_WANT_KEEPALIVE; in recv_omni()
5056 local_socket_prio = omni_request->socket_prio; in recv_omni()
5057 local_socket_tos = omni_request->socket_tos; in recv_omni()
5058 want_defer_accept = omni_request->flags & OMNI_WANT_DEFER_ACCEPT; in recv_omni()
5061 interval_usecs = omni_request->interval_usecs; in recv_omni()
5063 interval_burst = omni_request->interval_burst; in recv_omni()
5070 connection_test = omni_request->flags & OMNI_CONNECT_TEST; in recv_omni()
5072 use_fastopen = omni_request->flags & OMNI_FASTOPEN; in recv_omni()
5074 direction = omni_request->direction; in recv_omni()
5075 use_pktinfo = (omni_request->flags) & OMNI_USE_PKTINFO; in recv_omni()
5078 omni_request->fill_file[sizeof(omni_request->fill_file) - 1] = '\0'; in recv_omni()
5080 omni_request->fill_file, in recv_omni()
5086 switch (nf_to_af(omni_request->ipfamily)) { in recv_omni()
5093 omni_request->netserver_ip[ret] = htonl(omni_request->netserver_ip[ret]); in recv_omni()
5094 omni_request->netperf_ip[ret] = htonl(omni_request->netperf_ip[ret]); in recv_omni()
5099 set_hostname_and_port_2(omni_request->netserver_ip, in recv_omni()
5102 nf_to_af(omni_request->ipfamily), in recv_omni()
5103 omni_request->data_port); in recv_omni()
5108 nf_to_af(omni_request->ipfamily), in recv_omni()
5109 nst_to_hst(omni_request->socket_type), in recv_omni()
5110 omni_request->protocol, in recv_omni()
5132 omni_request->recv_alignment, in recv_omni()
5133 omni_request->recv_offset, in recv_omni()
5134 omni_request->send_alignment, in recv_omni()
5135 omni_request->send_offset); in recv_omni()
5139 omni_response->send_size = omni_request->send_size; in recv_omni()
5140 omni_response->send_width = omni_request->send_width; in recv_omni()
5144 if (omni_request->direction & NETPERF_XMIT) { in recv_omni()
5154 if (omni_request->response_size > 0) { in recv_omni()
5156 bytes_to_send = omni_request->response_size; in recv_omni()
5157 if (omni_request->send_width == 0) send_width = 1; in recv_omni()
5158 else send_width = omni_request->send_width; in recv_omni()
5161 if (omni_request->send_size == -1) { in recv_omni()
5162 bytes_to_send = choose_send_size(lss_size,omni_request->protocol); in recv_omni()
5164 else bytes_to_send = omni_request->send_size; in recv_omni()
5166 if (omni_request->send_width == 0) { in recv_omni()
5171 send_width = omni_request->send_width; in recv_omni()
5175 omni_request->send_alignment, in recv_omni()
5176 omni_request->send_offset); in recv_omni()
5182 omni_response->receive_size = omni_request->receive_size; in recv_omni()
5183 omni_response->recv_width = omni_request->recv_width; in recv_omni()
5184 if (omni_request->direction & NETPERF_RECV) { in recv_omni()
5193 if (omni_request->request_size > 0) { in recv_omni()
5195 bytes_to_recv = omni_request->request_size; in recv_omni()
5196 if (omni_request->recv_width == 0) recv_width = 1; in recv_omni()
5197 else recv_width = omni_request->recv_width; in recv_omni()
5200 if (omni_request->receive_size == -1) { in recv_omni()
5205 bytes_to_recv = omni_request->receive_size; in recv_omni()
5208 if (omni_request->recv_width == 0) { in recv_omni()
5213 recv_width = omni_request->recv_width; in recv_omni()
5217 omni_request->recv_alignment, in recv_omni()
5218 omni_request->recv_offset); in recv_omni()
5231 need_to_accept = (omni_request->protocol != IPPROTO_UDP); in recv_omni()
5322 if (omni_request->flags & OMNI_MEASURE_CPU) { in recv_omni()
5325 calibrate_local_cpu(omni_request->cpu_rate); in recv_omni()
5353 cpu_start(omni_request->flags & OMNI_MEASURE_CPU); in recv_omni()
5361 if (omni_request->test_length >= 0) { in recv_omni()
5364 test_time=omni_request->test_length; in recv_omni()
5367 if (!(NETPERF_XMIT_ONLY(omni_request->direction)) && in recv_omni()
5368 (omni_request->test_length > 0)) in recv_omni()
5370 start_timer(omni_request->test_length + pad_time); in recv_omni()
5374 units_remaining = omni_request->test_length * -1; in recv_omni()
5437 if ((omni_request->protocol == IPPROTO_UDP) && in recv_omni()
5442 nf_to_af(omni_request->ipfamily), in recv_omni()
5443 omni_request->netperf_ip, in recv_omni()
5444 omni_request->netperf_port); in recv_omni()
5462 if ((omni_request->direction & NETPERF_RECV) && in recv_omni()
5513 if ((omni_request->direction & NETPERF_XMIT) && in recv_omni()
5522 if (omni_request->protocol == IPPROTO_UDP && need_to_connect && in recv_omni()
5540 omni_request->protocol); in recv_omni()
5612 ret = close_data_socket(data_socket,NULL,0,omni_request->protocol); in recv_omni()
5637 if (NETPERF_IS_RR(omni_request->direction)) { in recv_omni()
5648 cpu_stop(omni_request->flags & OMNI_MEASURE_CPU,&elapsed_time); in recv_omni()
5670 omni_request->protocol); in recv_omni()
5691 if (omni_request->flags & OMNI_WANT_REM_CONG) { in recv_omni()
5702 close_data_socket(data_socket,NULL,0,omni_request->protocol); in recv_omni()
5705 close_data_socket(data_socket,(struct sockaddr *)&peeraddr_in,addrlen,omni_request->protocol); in recv_omni()
5725 if (omni_request->flags & OMNI_MEASURE_CPU) { in recv_omni()