Home
last modified time | relevance | path

Searched refs:so_rcv (Results 1 – 12 of 12) sorted by relevance

/third_party/gstreamer/gstplugins_bad/ext/sctp/usrsctp/usrsctplib/
Duser_socketvar.h194 } so_rcv, so_snd; member
319 #define SOCK_MTX(_so) SOCKBUF_MTX(&(_so)->so_rcv)
325 #define SOCK_LOCK_ASSERT(_so) SOCKBUF_LOCK_ASSERT(&(_so)->so_rcv)
433 ((int)((so)->so_rcv.sb_cc) >= (so)->so_rcv.sb_lowat || \
434 ((so)->so_rcv.sb_state & SBS_CANTRCVMORE) || \
502 SOCKBUF_LOCK_ASSERT(&(so)->so_rcv); \
503 if (sb_notify(&(so)->so_rcv)) \
504 sowakeup((so), &(so)->so_rcv); \
506 SOCKBUF_UNLOCK(&(so)->so_rcv); \
510 SOCKBUF_LOCK(&(so)->so_rcv); \
Duser_socket.c139 SOCKBUF_LOCK_ASSERT(&so->so_rcv); in socantrcvmore_locked()
140 so->so_rcv.sb_state |= SBS_CANTRCVMORE; in socantrcvmore_locked()
146 SOCKBUF_LOCK(&so->so_rcv); in socantrcvmore()
215 SOCKBUF_LOCK_INIT(&so->so_rcv, "so_rcv"); in soalloc()
217 SOCKBUF_COND_INIT(&so->so_rcv); in soalloc()
234 SOCKBUF_COND_DESTROY(&so->so_rcv); in sodealloc()
239 SOCKBUF_LOCK_DESTROY(&so->so_rcv); in sodealloc()
357 SOCKBUF_LOCK(&so->so_rcv); in soisdisconnecting()
360 so->so_rcv.sb_state |= SBS_CANTRCVMORE; in soisdisconnecting()
484 if (soreserve(so, head->so_snd.sb_hiwat, head->so_rcv.sb_hiwat)) { in sonewconn()
[all …]
/third_party/gstreamer/gstplugins_bad/ext/sctp/usrsctp/usrsctplib/netinet/
Dsctputil.c401 sctp_clog.x.lock.sock_lock = mtx_owned(&(inp->sctp_socket->so_rcv.sb_mtx)); in sctp_log_lock()
402 sctp_clog.x.lock.sockrcvbuf_lock = mtx_owned(&(inp->sctp_socket->so_rcv.sb_mtx)); in sctp_log_lock()
3355 &stcb->sctp_socket->so_rcv, 1, SCTP_READ_LOCK_NOT_HELD, in sctp_notify_assoc_change()
3515 &stcb->sctp_socket->so_rcv, 1, in sctp_notify_peer_addr_change()
3628 if (sctp_sbspace_failedmsgs(&stcb->sctp_socket->so_rcv) < SCTP_BUF_LEN(m_notify)) { in sctp_notify_send_failed()
3647 &stcb->sctp_socket->so_rcv, 1, in sctp_notify_send_failed()
3727 if (sctp_sbspace_failedmsgs(&stcb->sctp_socket->so_rcv) < SCTP_BUF_LEN(m_notify)) { in sctp_notify_send_failed2()
3746 &stcb->sctp_socket->so_rcv, 1, SCTP_READ_LOCK_NOT_HELD, so_locked); in sctp_notify_send_failed2()
3795 &stcb->sctp_socket->so_rcv, 1, SCTP_READ_LOCK_NOT_HELD, SCTP_SO_NOT_LOCKED); in sctp_notify_adaptation_layer()
3846 sb = &stcb->sctp_socket->so_rcv; in sctp_notify_partial_delivery_indication()
[all …]
Dsctp_process_lock.h504 SOCKBUF_LOCK(&(_so)->so_rcv)
506 SOCKBUF_UNLOCK(&(_so)->so_rcv)
522 SOCKBUF_LOCK(&(_so)->so_rcv)
524 SOCKBUF_UNLOCK(&(_so)->so_rcv)
Dsctp_indata.c112 calc = (uint32_t) sctp_sbspace(&stcb->asoc, &stcb->sctp_socket->so_rcv); in sctp_calc_rwnd()
607 &stcb->sctp_socket->so_rcv, 1, in sctp_queue_data_to_stream()
647 &stcb->sctp_socket->so_rcv, 1, in sctp_queue_data_to_stream()
711 sctp_sballoc(stcb, &stcb->sctp_socket->so_rcv, m); in sctp_setup_tail_pointer()
764 sctp_sballoc(stcb, &stcb->sctp_socket->so_rcv, m); in sctp_add_to_tail_pointer()
914 &stcb->sctp_socket->so_rcv, control->end_added, in sctp_handle_old_unordered_data()
950 &stcb->sctp_socket->so_rcv, control->end_added, in sctp_handle_old_unordered_data()
1159 &stcb->sctp_socket->so_rcv, control->end_added, in sctp_deliver_reasm_check()
1169 &stcb->sctp_socket->so_rcv, control->end_added, in sctp_deliver_reasm_check()
1227 &stcb->sctp_socket->so_rcv, control->end_added, in sctp_deliver_reasm_check()
[all …]
Dsctp_constants.h1059 SOCKBUF_UNLOCK(&((so)->so_rcv)); \
1070 SOCKBUF_UNLOCK(&((so)->so_rcv)); \
Dsctp_usrreq.c621 SCTP_SB_CLEAR(so->so_rcv);
671 if (so->so_snd.sb_hiwat == 0 || so->so_rcv.sb_hiwat == 0) {
748 if (so->so_snd.sb_hiwat == 0 || so->so_rcv.sb_hiwat == 0) {
823 (so->so_rcv.sb_cc > 0)) {
826 (so->so_rcv.sb_cc > 0)) {
848 SCTP_SB_CLEAR(so->so_rcv);
894 (so->so_rcv.sb_cc > 0)) {
897 (so->so_rcv.sb_cc > 0)) {
918 SCTP_SB_CLEAR(so->so_rcv);
1101 (so->so_rcv.sb_cc > 0)) {
[all …]
Dsctp_os_userspace.h964 #define SCTP_SB_LIMIT_RCV(so) so->so_rcv.sb_hiwat
Dsctp_auth.c1800 &stcb->sctp_socket->so_rcv, 1, SCTP_READ_LOCK_NOT_HELD, so_locked);
Dsctp_pcb.c3986 (so && (so->so_rcv.sb_cc > 0))) {
4198 so->so_rcv.sb_cc -= sq->length;
5626 SOCKBUF_LOCK(&so->so_rcv);
Dsctp_output.c12368 stcb->sctp_socket->so_rcv.sb_cc);
/third_party/gstreamer/gstplugins_bad/ext/sctp/usrsctp/usrsctplib/netinet6/
Dsctp6_usrreq.c709 SCTP_SB_CLEAR(so->so_rcv);
757 if (so->so_snd.sb_hiwat == 0 || so->so_rcv.sb_hiwat == 0) {