Lines Matching refs:data_socket
2842 int send_pktinfo(SOCKET data_socket, char *buffer, int len, struct sockaddr *destination, int destl… in send_pktinfo() argument
2869 return sendmsg(data_socket, &msg, 0); in send_pktinfo()
2877 send_data(SOCKET data_socket, struct ring_elt *send_ring, uint32_t bytes_to_send, struct sockaddr *… in send_data() argument
2889 data_socket, in send_data()
2899 len = send_pktinfo(data_socket, in send_data()
2906 len = sendto(data_socket, in send_data()
2920 len = send(data_socket, in send_data()
2927 len = write(data_socket, in send_data()
2968 recv_data_no_copy(SOCKET data_socket, struct ring_elt *recv_ring, uint32_t bytes_to_recv, struct so… in recv_data_no_copy() argument
3019 data_socket, in recv_data_no_copy()
3030 bytes_recvd = splice(data_socket, in recv_data_no_copy()
3083 int recv_pktinfo(SOCKET data_socket, char *message_ptr, int bytes_to_recv, int my_flags, struct so… in recv_pktinfo() argument
3108 setsockopt(data_socket, IPPROTO_IP, IP_PKTINFO, &onoff, sizeof(onoff)); in recv_pktinfo()
3110 ret = recvmsg(data_socket, &my_header, 0); in recv_pktinfo()
3127 setsockopt(data_socket, IPPROTO_IP, IP_PKTINFO, &onoff, sizeof(onoff)); in recv_pktinfo()
3137 recv_data(SOCKET data_socket, struct ring_elt *recv_ring, uint32_t bytes_to_recv, struct sockaddr *… in recv_data() argument
3148 …ret = recv_data_no_copy(data_socket, recv_ring, bytes_to_recv, source, sourcelen, flags, num_recei… in recv_data()
3166 data_socket, in recv_data()
3185 bytes_recvd = recv_pktinfo(data_socket, in recv_data()
3194 bytes_recvd = recvfrom(data_socket, in recv_data()
3204 bytes_recvd = recv(data_socket, in recv_data()
3253 close_data_socket(SOCKET data_socket, struct sockaddr *peer, int peerlen, int protocol) in close_data_socket() argument
3263 data_socket, in close_data_socket()
3277 ret = sendto(data_socket, in close_data_socket()
3284 ret = send(data_socket, in close_data_socket()
3289 close(data_socket); in close_data_socket()
3294 ret = close(data_socket); in close_data_socket()
3309 disconnect_data_socket(SOCKET data_socket, int initiate, int do_close, struct sockaddr *peer, int p… in disconnect_data_socket() argument
3319 data_socket, in disconnect_data_socket()
3338 shutdown(data_socket, SHUT_WR); in disconnect_data_socket()
3345 bytes_recvd = recv(data_socket, in disconnect_data_socket()
3365 bytes_recvd = sendto(data_socket, in disconnect_data_socket()
3372 bytes_recvd = send(data_socket, in disconnect_data_socket()
3379 close(data_socket); in disconnect_data_socket()
3386 close(data_socket); in disconnect_data_socket()
3718 SOCKET data_socket; in send_omni_inner() local
3828 data_socket = omni_create_data_socket(local_res); in send_omni_inner()
3830 if (data_socket == INVALID_SOCKET) { in send_omni_inner()
3839 enable_enobufs(data_socket); in send_omni_inner()
3851 set_multicast_ttl(data_socket); in send_omni_inner()
3887 join_multicast_addr(data_socket, local_res); in send_omni_inner()
3999 getsockname(data_socket, (struct sockaddr *)&my_addr, &my_addr_len); in send_omni_inner()
4166 data_socket = omni_create_data_socket(local_res); in send_omni_inner()
4168 if (data_socket == INVALID_SOCKET) { in send_omni_inner()
4176 enable_enobufs(data_socket); in send_omni_inner()
4185 ret = connect_data_socket(data_socket,remote_res,dont_give_up); in send_omni_inner()
4202 close(data_socket); in send_omni_inner()
4253 if ((ret = send_data(data_socket, in send_omni_inner()
4293 ret = send_data(data_socket, in send_omni_inner()
4360 win_kludge_socket = data_socket; in send_omni_inner()
4364 rret = recv_data(data_socket, in send_omni_inner()
4460 get_sock_buffer(data_socket, RECV_BUFFER, &lsr_size_end); in send_omni_inner()
4464 get_sock_buffer(data_socket, SEND_BUFFER, &lss_size_end); in send_omni_inner()
4477 get_transport_info(data_socket, in send_omni_inner()
4482 ret = disconnect_data_socket(data_socket, in send_omni_inner()
4553 get_transport_info(data_socket, in send_omni_inner()
4556 local_transport_retrans = get_transport_retrans(data_socket, in send_omni_inner()
4573 get_sock_buffer(data_socket, RECV_BUFFER, &lsr_size_end); in send_omni_inner()
4577 get_sock_buffer(data_socket, SEND_BUFFER, &lss_size_end); in send_omni_inner()
4586 get_transport_cong_control(data_socket, in send_omni_inner()
4593 ret = disconnect_data_socket(data_socket, in send_omni_inner()
4604 ret = disconnect_data_socket(data_socket, in send_omni_inner()
4982 SOCKET s_listen, data_socket; in recv_omni() local
5397 if ((data_socket=accept(s_listen, in recv_omni()
5427 kludge_socket_options(data_socket); in recv_omni()
5440 data_socket = s_listen; in recv_omni()
5455 win_kludge_socket = data_socket; in recv_omni()
5464 ret = recv_data(data_socket, in recv_omni()
5524 if (connect(data_socket, in recv_omni()
5529 close(data_socket); in recv_omni()
5535 ret = send_data(data_socket, in recv_omni()
5601 get_sock_buffer(data_socket, RECV_BUFFER, &lsr_size_end); in recv_omni()
5605 get_sock_buffer(data_socket, SEND_BUFFER, &lss_size_end); in recv_omni()
5612 ret = close_data_socket(data_socket,NULL,0,omni_request->protocol); in recv_omni()
5669 remote_transport_retrans = get_transport_retrans(data_socket, in recv_omni()
5680 get_sock_buffer(data_socket, RECV_BUFFER, &lsr_size_end); in recv_omni()
5684 get_sock_buffer(data_socket, SEND_BUFFER, &lss_size_end); in recv_omni()
5692 get_transport_cong_control(data_socket, 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()