Lines Matching refs:send_socket
379 int send_socket; in send_sctp_stream() local
457 send_socket = create_data_socket(local_res); in send_sctp_stream()
459 if (send_socket == INVALID_SOCKET){ in send_sctp_stream()
602 if (connect(send_socket, in send_sctp_stream()
609 sctp_enable_events(send_socket, SCTP_ASSOC_CHANGE_EV); in send_sctp_stream()
613 if (!set_nonblock(send_socket)) { in send_sctp_stream()
710 while ((len=sctp_sendmsg(send_socket, in send_sctp_stream()
777 get_sctp_info(send_socket, &sctp_mss); in send_sctp_stream()
780 shutdown(send_socket, SHUT_WR); in send_sctp_stream()
791 FD_SET(send_socket, &readfds); in send_sctp_stream()
792 select(send_socket+1, &readfds, NULL, NULL, NULL); in send_sctp_stream()
794 sctp_recvmsg(send_socket, send_ring->buffer_ptr, send_size, NULL, in send_sctp_stream()
808 close(send_socket); in send_sctp_stream()
1511 int *send_socket; in send_sctp_stream_1toMany() local
1564 send_socket = malloc(sizeof (int) * num_associations); in send_sctp_stream_1toMany()
1565 if (send_socket == NULL) { in send_sctp_stream_1toMany()
1726 send_socket[j] = create_data_socket(local_res); in send_sctp_stream_1toMany()
1728 if (send_socket[j] < 0){ in send_sctp_stream_1toMany()
1738 if (connect(send_socket[j], in send_sctp_stream_1toMany()
1746 sctp_enable_events(send_socket[j], SCTP_ASSOC_CHANGE_EV); in send_sctp_stream_1toMany()
1750 if (!set_nonblock(send_socket[j])) { in send_sctp_stream_1toMany()
1850 if((len=sctp_sendmsg(send_socket[j], in send_sctp_stream_1toMany()
1922 get_sctp_info(send_socket[0], &sctp_mss); in send_sctp_stream_1toMany()
1929 sctp_sendmsg(send_socket[0], NULL, 0, remote_res->ai_addr, in send_sctp_stream_1toMany()
1948 FD_SET(send_socket[num_associations-1], &readfds); in send_sctp_stream_1toMany()
1949 select(send_socket[num_associations-1]+1, &readfds, NULL, NULL, NULL); in send_sctp_stream_1toMany()
1951 sctp_recvmsg(send_socket[num_associations], send_ring->buffer_ptr, in send_sctp_stream_1toMany()
1966 close(send_socket[j]); in send_sctp_stream_1toMany()
2605 int send_socket; in send_sctp_rr() local
2710 send_socket = create_data_socket(local_res); in send_sctp_rr()
2712 if (send_socket < 0){ in send_sctp_rr()
2805 if (connect(send_socket, in send_sctp_rr()
2813 sctp_enable_events(send_socket, 0); in send_sctp_rr()
2817 if (!set_nonblock(send_socket)) { in send_sctp_rr()
2818 close(send_socket); in send_sctp_rr()
2880 if((len=sctp_sendmsg(send_socket, in send_sctp_rr()
2902 while ((len=sctp_sendmsg(send_socket, in send_sctp_rr()
2930 if ((rsp_bytes_recvd=sctp_recvmsg(send_socket, in send_sctp_rr()
3096 close(send_socket); in send_sctp_rr()
3655 int *send_socket; in send_sctp_rr_1toMany() local
3718 send_socket = malloc(sizeof(int) * num_associations); in send_sctp_rr_1toMany()
3719 if (send_socket == NULL) { in send_sctp_rr_1toMany()
3851 send_socket[j] = create_data_socket(local_res); in send_sctp_rr_1toMany()
3853 if (send_socket < 0){ in send_sctp_rr_1toMany()
3859 if (connect(send_socket[j], in send_sctp_rr_1toMany()
3870 sctp_enable_events(send_socket[j], 0); in send_sctp_rr_1toMany()
3873 if (!set_nonblock(send_socket[j])) { in send_sctp_rr_1toMany()
3874 close(send_socket[j]); in send_sctp_rr_1toMany()
3938 if((len=sctp_sendmsg(send_socket[j], in send_sctp_rr_1toMany()
3970 while ((len=sctp_sendmsg(send_socket[j], in send_sctp_rr_1toMany()
4000 if((rsp_bytes_recvd = sctp_recvmsg(send_socket[j], in send_sctp_rr_1toMany()
4146 close(send_socket[j]); in send_sctp_rr_1toMany()