Home
last modified time | relevance | path

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

/third_party/gstreamer/gstplugins_bad/ext/sctp/usrsctp/usrsctplib/
Duser_socketvar.h194 } so_rcv, so_snd; member
440 ((sbspace(&(so)->so_snd) >= (so)->so_snd.sb_lowat && \
443 ((so)->so_snd.sb_state & SBS_CANTSENDMORE) || \
448 ((sbspace(&(so)->so_snd) >= (so)->so_snd.sb_lowat && \
450 ((so)->so_snd.sb_state & SBS_CANTSENDMORE) || \
515 SOCKBUF_LOCK_ASSERT(&(so)->so_snd); \
516 if (sb_notify(&(so)->so_snd)) \
517 sowakeup((so), &(so)->so_snd); \
519 SOCKBUF_UNLOCK(&(so)->so_snd); \
523 SOCKBUF_LOCK(&(so)->so_snd); \
Duser_socket.c153 SOCKBUF_LOCK_ASSERT(&so->so_snd); in socantsendmore_locked()
154 so->so_snd.sb_state |= SBS_CANTSENDMORE; in socantsendmore_locked()
161 SOCKBUF_LOCK(&so->so_snd); in socantsendmore()
214 SOCKBUF_LOCK_INIT(&so->so_snd, "so_snd"); in soalloc()
216 SOCKBUF_COND_INIT(&so->so_snd); in soalloc()
233 SOCKBUF_COND_DESTROY(&so->so_snd); in sodealloc()
238 SOCKBUF_LOCK_DESTROY(&so->so_snd); in sodealloc()
362 SOCKBUF_LOCK(&so->so_snd); in soisdisconnecting()
363 so->so_snd.sb_state |= SBS_CANTSENDMORE; 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.h300 if (stcb->sctp_socket->so_snd.sb_cc >= tp1->book_size) { \
301 atomic_subtract_int(&((stcb)->sctp_socket->so_snd.sb_cc), tp1->book_size); \
303 stcb->sctp_socket->so_snd.sb_cc = 0; \
321 if (stcb->sctp_socket->so_snd.sb_cc >= sp->length) { \
322 atomic_subtract_int(&stcb->sctp_socket->so_snd.sb_cc,sp->length); \
324 stcb->sctp_socket->so_snd.sb_cc = 0; \
336 atomic_add_int(&stcb->sctp_socket->so_snd.sb_cc,sz); \
Dsctp_constants.h1027 SOCKBUF_UNLOCK(&((so)->so_snd)); \
1037 SOCKBUF_UNLOCK(&((so)->so_snd)); \
Dsctp_output.c7825 atomic_subtract_int(&stcb->sctp_socket->so_snd.sb_cc, sp->length);
14084 SOCKBUF_LOCK(&so->so_snd);
14102 error = sbwait(&so->so_snd);
14112 SOCKBUF_UNLOCK(&so->so_snd);
14120 SOCKBUF_UNLOCK(&so->so_snd);
14130 SOCKBUF_UNLOCK(&so->so_snd);
14138 error = sblock(&so->so_snd, SBLOCKWAIT(flags));
14449 SOCKBUF_LOCK(&so->so_snd);
14486 sbunlock(&so->so_snd, 1);
14488 error = sbwait(&so->so_snd);
[all …]
Dsctp_os_userspace.h965 #define SCTP_SB_LIMIT_SND(so) so->so_snd.sb_hiwat
Dsctp_usrreq.c617 SCTP_SB_CLEAR(so->so_snd);
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) {
844 SCTP_SB_CLEAR(so->so_snd);
914 SCTP_SB_CLEAR(so->so_snd);
1257 so->so_snd.sb_cc = 0;
1258 so->so_snd.sb_mbcnt = 0;
1259 so->so_snd.sb_mb = NULL;
8485 SOCKBUF_LOCK(&inp->sctp_socket->so_snd);
8499 SOCKBUF_UNLOCK(&inp->sctp_socket->so_snd);
Dsctputil.c403 sctp_clog.x.lock.socksndbuf_lock = mtx_owned(&(inp->sctp_socket->so_snd.sb_mtx)); in sctp_log_lock()
557 sctp_clog.x.wake.sbflags = (uint8_t)((so->so_snd.sb_flags & 0x00ff)); in sctp_wakeup_log()
5518 if (stcb->sctp_socket->so_snd.sb_cc >= tp1->book_size) {
5519 stcb->sctp_socket->so_snd.sb_cc -= tp1->book_size;
5521 stcb->sctp_socket->so_snd.sb_cc = 0;
Dsctp_indata.c4202 SOCKBUF_LOCK(&stcb->sctp_socket->so_snd);
4930 SOCKBUF_LOCK(&stcb->sctp_socket->so_snd);
Dsctp_input.c1150 stcb->sctp_socket->so_snd.sb_cc = 0; in sctp_handle_shutdown_ack()
/third_party/gstreamer/gstplugins_bad/ext/sctp/usrsctp/usrsctplib/netinet6/
Dsctp6_usrreq.c705 SCTP_SB_CLEAR(so->so_snd);
757 if (so->so_snd.sb_hiwat == 0 || so->so_rcv.sb_hiwat == 0) {