Home
last modified time | relevance | path

Searched refs:SCTP_BASE_VAR (Results 1 – 11 of 11) sorted by relevance

/third_party/gstreamer/gstplugins_bad/ext/sctp/usrsctp/usrsctplib/
Duser_recv_thread.c150 ret = recv(SCTP_BASE_VAR(userspace_route), rt_buffer, sizeof(rt_buffer), 0); in recv_function_route()
214 len = recvmsg(SCTP_BASE_VAR(userspace_route), &msg, 0);
326 …nResult = WSARecvFrom(SCTP_BASE_VAR(userspace_rawsctp), recv_iovec, MAXLEN_MBUF_CHAIN, &ncounter, … in recv_function_raw()
343 ncounter = n = recvmsg(SCTP_BASE_VAR(userspace_rawsctp), &msg, 0); in recv_function_raw()
500 nResult = WSAIoctl(SCTP_BASE_VAR(userspace_rawsctp6), SIO_GET_EXTENSION_FUNCTION_POINTER, in recv_function_raw6()
512 nResult = WSARecvMsg(SCTP_BASE_VAR(userspace_rawsctp6), &msg, &ncounter, NULL, NULL); in recv_function_raw6()
535 ncounter = n = recvmsg(SCTP_BASE_VAR(userspace_rawsctp6), &msg, 0); in recv_function_raw6()
704 ncounter = n = recvmsg(SCTP_BASE_VAR(userspace_udpsctp), &msg, 0); in recv_function_udp()
713 nResult = WSAIoctl(SCTP_BASE_VAR(userspace_udpsctp), SIO_GET_EXTENSION_FUNCTION_POINTER, in recv_function_udp()
725 nResult = WSARecvMsg(SCTP_BASE_VAR(userspace_udpsctp), &msg, &ncounter, NULL, NULL); in recv_function_udp()
[all …]
Duser_socket.c1333 if ((protocol == IPPROTO_SCTP) && (SCTP_BASE_VAR(sctp_pcb_initialized) == 0)) { in usrsctp_socket()
1342 if ((domain == AF_CONN) && (SCTP_BASE_VAR(conn_output) == NULL)) { in usrsctp_socket()
2064 if (SCTP_BASE_VAR(sctp_pcb_initialized) == 0) {
2960 if ((!use_udp_tunneling) && (SCTP_BASE_VAR(userspace_rawsctp) != -1)) {
2961 if (sendmsg(SCTP_BASE_VAR(userspace_rawsctp), &msg_hdr, MSG_DONTWAIT) < 0) {
2965 if ((use_udp_tunneling) && (SCTP_BASE_VAR(userspace_udpsctp) != -1)) {
2966 if (sendmsg(SCTP_BASE_VAR(userspace_udpsctp), &msg_hdr, MSG_DONTWAIT) < 0) {
2980 if ((!use_udp_tunneling) && (SCTP_BASE_VAR(userspace_rawsctp) != -1)) {
2981 …if (WSASendTo(SCTP_BASE_VAR(userspace_rawsctp), (LPWSABUF) send_iovec, iovcnt, &win_sent_len, win_…
2985 if ((use_udp_tunneling) && (SCTP_BASE_VAR(userspace_udpsctp) != -1)) {
[all …]
/third_party/gstreamer/gstplugins_bad/ext/sctp/usrsctp/usrsctplib/netinet/
Dsctp_callout.h57 #define SCTP_TIMERQ_LOCK() EnterCriticalSection(&SCTP_BASE_VAR(timer_mtx))
58 #define SCTP_TIMERQ_UNLOCK() LeaveCriticalSection(&SCTP_BASE_VAR(timer_mtx))
59 #define SCTP_TIMERQ_LOCK_INIT() InitializeCriticalSection(&SCTP_BASE_VAR(timer_mtx))
60 #define SCTP_TIMERQ_LOCK_DESTROY() DeleteCriticalSection(&SCTP_BASE_VAR(timer_mtx))
63 #define SCTP_TIMERQ_LOCK() KASSERT(pthread_mutex_lock(&SCTP_BASE_VAR(timer_mtx)) == 0, ("%…
64 #define SCTP_TIMERQ_UNLOCK() KASSERT(pthread_mutex_unlock(&SCTP_BASE_VAR(timer_mtx)) == 0, (…
66 #define SCTP_TIMERQ_LOCK() (void)pthread_mutex_lock(&SCTP_BASE_VAR(timer_mtx))
67 #define SCTP_TIMERQ_UNLOCK() (void)pthread_mutex_unlock(&SCTP_BASE_VAR(timer_mtx))
69 …e SCTP_TIMERQ_LOCK_INIT() (void)pthread_mutex_init(&SCTP_BASE_VAR(timer_mtx), &SCTP_BASE_VAR(m…
70 #define SCTP_TIMERQ_LOCK_DESTROY() (void)pthread_mutex_destroy(&SCTP_BASE_VAR(timer_mtx))
Dsctp_callout.c187 sctp_handle_tick(SCTP_BASE_VAR(sctp_main_timer_ticks)); in sctp_timeout()
211 if (atomic_cmpset_int(&SCTP_BASE_VAR(timer_thread_should_exit), 1, 1)) { in user_sctp_timer_iterate()
228 rc = sctp_userspace_thread_create(&SCTP_BASE_VAR(timer_thread), user_sctp_timer_iterate); in sctp_start_timer_thread()
232 SCTP_BASE_VAR(timer_thread_started) = 1; in sctp_start_timer_thread()
239 atomic_cmpset_int(&SCTP_BASE_VAR(timer_thread_should_exit), 0, 1); in sctp_stop_timer_thread()
240 if (SCTP_BASE_VAR(timer_thread_started)) { in sctp_stop_timer_thread()
242 WaitForSingleObject(SCTP_BASE_VAR(timer_thread), INFINITE); in sctp_stop_timer_thread()
243 CloseHandle(SCTP_BASE_VAR(timer_thread)); in sctp_stop_timer_thread()
245 pthread_join(SCTP_BASE_VAR(timer_thread), NULL); in sctp_stop_timer_thread()
Dsctp_bsd_addr.c192 SCTP_BASE_VAR(iterator_thread_started) = 1;
666 if (SCTP_BASE_VAR(sctp_pcb_initialized) == 0) {
674 if (SCTP_BASE_VAR(first_time) == 0) {
676 SCTP_BASE_VAR(first_time) = 1;
880 atomic_add_int(&SCTP_BASE_VAR(packet_log_writers), 1);
882 if (SCTP_BASE_VAR(packet_log_writers) > SCTP_PKTLOG_WRITERS_NEED_LOCK) {
886 value = SCTP_BASE_VAR(packet_log_end);
887 newval = SCTP_BASE_VAR(packet_log_end) + total_len;
893 thisbegin = SCTP_BASE_VAR(packet_log_end);
896 if (!(atomic_cmpset_int(&SCTP_BASE_VAR(packet_log_end), value, thisend))) {
[all …]
Dsctp_process_lock.h256 (void)pthread_mutex_init(&SCTP_BASE_INFO(wq_addr_mtx), &SCTP_BASE_VAR(mtx_attr))
274 (void)pthread_mutex_init(&SCTP_BASE_INFO(ipi_ep_mtx), &SCTP_BASE_VAR(mtx_attr))
300 (void)pthread_mutex_init(&SCTP_BASE_INFO(ipi_pktlog_mtx), &SCTP_BASE_VAR(mtx_attr))
322 (void)pthread_mutex_init(&(_inp)->inp_rdata_mtx, &SCTP_BASE_VAR(mtx_attr))
338 (void)pthread_mutex_init(&(_inp)->inp_mtx, &SCTP_BASE_VAR(mtx_attr))
394 (void)pthread_mutex_init(&(_tcb)->tcb_send_mtx, &SCTP_BASE_VAR(mtx_attr))
410 (void)pthread_mutex_init(&(_inp)->inp_create_mtx, &SCTP_BASE_VAR(mtx_attr))
449 (void)pthread_mutex_init(&(_tcb)->tcb_mtx, &SCTP_BASE_VAR(mtx_attr))
572 (void)pthread_mutex_init(&SCTP_BASE_INFO(ipi_addr_mtx), &SCTP_BASE_VAR(mtx_attr))
603 (void)pthread_mutex_init(&sctp_it_ctl.it_mtx, &SCTP_BASE_VAR(mtx_attr))
[all …]
Dsctp_os_userspace.h537 if (SCTP_BASE_VAR(debug_printf)) { \
538 SCTP_BASE_VAR(debug_printf)(__VA_ARGS__); \
580 #define SCTP_BASE_VAR(__m) system_base_info.__m macro
Dsctp_usrreq.c118 SCTP_BASE_VAR(first_time) = 0; in sctp_init()
119 SCTP_BASE_VAR(sctp_pcb_initialized) = 0; in sctp_init()
123 SCTP_BASE_VAR(userspace_route) = -1; in sctp_init()
127 SCTP_BASE_VAR(userspace_rawsctp) = -1; in sctp_init()
128 SCTP_BASE_VAR(userspace_udpsctp) = -1; in sctp_init()
131 SCTP_BASE_VAR(userspace_rawsctp6) = -1; in sctp_init()
132 SCTP_BASE_VAR(userspace_udpsctp6) = -1; in sctp_init()
134 SCTP_BASE_VAR(timer_thread_should_exit) = 0; in sctp_init()
135 SCTP_BASE_VAR(conn_output) = conn_output; in sctp_init()
136 SCTP_BASE_VAR(debug_printf) = debug_printf; in sctp_init()
[all …]
Dsctp_pcb.c6541 if (SCTP_BASE_VAR(sctp_pcb_initialized) != 0) {
6545 SCTP_BASE_VAR(sctp_pcb_initialized) = 1;
6549 pthread_mutexattr_init(&SCTP_BASE_VAR(mtx_attr));
6551 pthread_mutexattr_settype(&SCTP_BASE_VAR(mtx_attr), PTHREAD_MUTEX_ERRORCHECK);
6768 if (SCTP_BASE_VAR(sctp_pcb_initialized) == 0) {
6772 SCTP_BASE_VAR(sctp_pcb_initialized) = 0;
6807 if (SCTP_BASE_VAR(iterator_thread_started)) {
6823 pthread_mutexattr_destroy(&SCTP_BASE_VAR(mtx_attr));
8068 if (SCTP_BASE_VAR(sctp_pcb_initialized) == 0) {
8070 SCTP_BASE_VAR(sctp_pcb_initialized));
[all …]
Dsctp_output.c5037 if (SCTP_BASE_VAR(crc32c_offloaded) == 0) {
5053 …ret = SCTP_BASE_VAR(conn_output)(sconn->sconn_addr, buffer, packet_length, tos_value, nofragment_f…
11972 if (SCTP_BASE_VAR(crc32c_offloaded) == 0) {
11986 ret = SCTP_BASE_VAR(conn_output)(sconn->sconn_addr, buffer, len, 0, 0);
Dsctputil.c1728 if (SCTP_BASE_VAR(sctp_pcb_initialized) == 0) { in sctp_handle_addr_wq()