Home
last modified time | relevance | path

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

/third_party/gstreamer/gstplugins_bad/ext/sctp/usrsctp/usrsctplib/netinet/
Dsctputil.h298 if (stcb->sctp_socket && ((stcb->sctp_ep->sctp_flags & SCTP_PCB_FLAGS_TCPTYPE) || \
300 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; \
319 if (stcb->sctp_socket && ((stcb->sctp_ep->sctp_flags & SCTP_PCB_FLAGS_TCPTYPE) || \
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; \
333 if ((stcb->sctp_socket != NULL) && \
336 atomic_add_int(&stcb->sctp_socket->so_snd.sb_cc,sz); \
Dsctputil.c380 sctp_clog.x.lock.sock = (void *) inp->sctp_socket; in sctp_log_lock()
400 if (inp && (inp->sctp_socket)) { in sctp_log_lock()
401 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()
403 sctp_clog.x.lock.socksndbuf_lock = mtx_owned(&(inp->sctp_socket->so_snd.sb_mtx)); in sctp_log_lock()
554 if (stcb->sctp_socket) { in sctp_wakeup_log()
555 struct socket *so = stcb->sctp_socket; in sctp_wakeup_log()
1285 asoc->my_rwnd = max(SCTP_SB_LIMIT_RCV(inp->sctp_socket), SCTP_MINIMAL_RWND); in sctp_init_asoc()
1286 asoc->peers_rwnd = SCTP_SB_LIMIT_RCV(inp->sctp_socket); in sctp_init_asoc()
1879 (stcb->sctp_socket != NULL)) { in sctp_timeout_handler()
[all …]
Dsctp_indata.c96 if (stcb->sctp_socket == NULL) { in sctp_calc_rwnd()
108 calc = max(SCTP_SB_LIMIT_RCV(stcb->sctp_socket), SCTP_MINIMAL_RWND); in sctp_calc_rwnd()
112 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()
1110 if (stcb->sctp_socket) { in sctp_deliver_reasm_check()
[all …]
Dsctp_input.c589 if (stcb->sctp_socket) { in sctp_process_init_ack()
595 sb_free_now = SCTP_SB_LIMIT_SND(stcb->sctp_socket) - (inqueue_bytes + stcb->asoc.sb_send_resv); in sctp_process_init_ack()
605 inp->send_callback(stcb->sctp_socket, sb_free_now); in sctp_process_init_ack()
1021 if (stcb->sctp_socket) { in sctp_handle_shutdown()
1022 sctp_sorwakeup(stcb->sctp_ep, stcb->sctp_socket); in sctp_handle_shutdown()
1029 if (stcb->sctp_socket) { in sctp_handle_shutdown()
1129 sctp_sorwakeup(stcb->sctp_ep, stcb->sctp_socket); in sctp_handle_shutdown_ack()
1147 if (stcb->sctp_socket) { in sctp_handle_shutdown_ack()
1150 stcb->sctp_socket->so_snd.sb_cc = 0; in sctp_handle_shutdown_ack()
1753 soisconnected(stcb->sctp_socket); in sctp_process_cookie_existing()
[all …]
Dsctp_peeloff.c121 n_inp->sctp_socket = so; in sctp_do_peeloff()
262 n_inp->sctp_socket = newso; in sctp_get_peeloff()
Dsctp_pcb.h475 struct socket *sctp_socket; member
598 struct socket *sctp_socket; /* back pointer to socket */ member
Dsctp_pcb.c1513 if ((inp->sctp_socket) && SCTP_IS_LISTENING(inp)) {
2805 inp->sctp_socket = so;
3100 stcb->sctp_socket = new_inp->sctp_socket;
3908 so = inp->sctp_socket;
3981 asoc->sctp_socket = NULL;
4072 inp->sctp_socket = NULL;
4079 inp->sctp_socket = NULL;
4101 asoc->sctp_socket = NULL;
5061 if ((err = sctp_inpcb_bind(inp->sctp_socket, NULL, NULL, p))) {
5084 stcb->sctp_socket = inp->sctp_socket;
[all …]
Dsctp_usrreq.c474 (stcb->sctp_socket != NULL)) {
477 upcall_socket = stcb->sctp_socket;
534 if (stcb == NULL || inp == NULL || inp->sctp_socket == NULL) {
556 error = cr_canseesocket(req->td->td_ucred, inp->sctp_socket);
561 cru2x(inp->sctp_socket->so_cred, &xuc);
3409 sasoc->sasoc_local_rwnd = sbspace(&inp->sctp_socket->so_rcv);
8485 SOCKBUF_LOCK(&inp->sctp_socket->so_snd);
8486 if (sowriteable(inp->sctp_socket)) {
8491 sowwakeup_locked(inp->sctp_socket);
8496 sowwakeup(inp->sctp_socket);
[all …]
Dsctp_sysctl.c520 xinpcb.socket = (uintptr_t)inp->sctp_socket;
522 xinpcb.socket = inp->sctp_socket;
524 so = inp->sctp_socket;
Dsctp_output.c5145 init->init.a_rwnd = htonl(max(inp->sctp_socket?SCTP_SB_LIMIT_RCV(inp->sctp_socket):0,
6384 so = inp->sctp_socket;
7686 if (SCTP_SB_LIMIT_SND(stcb->sctp_socket) < frag_point) {
7822 if ((stcb->sctp_socket != NULL) &&
7825 atomic_subtract_int(&stcb->sctp_socket->so_snd.sb_cc, sp->length);
8464 if (stcb->sctp_socket)
8465 max_send_per_dest = SCTP_SB_LIMIT_SND(stcb->sctp_socket) / asoc->numnets;
10838 if (inp->sctp_socket == NULL) {
10842 return (sctp_sosend(inp->sctp_socket,
12261 if (stcb->sctp_socket == NULL) {
[all …]
Dsctp_auth.c1800 &stcb->sctp_socket->so_rcv, 1, SCTP_READ_LOCK_NOT_HELD, so_locked);
/third_party/gstreamer/gstplugins_bad/ext/sctp/usrsctp/usrsctplib/netinet6/
Dsctp6_usrreq.c553 (stcb->sctp_socket != NULL) {
556 upcall_socket = stcb->sctp_socket;
625 if (stcb == NULL || inp == NULL || inp->sctp_socket == NULL) {
646 error = cr_canseesocket(req->td->td_ucred, inp->sctp_socket);
651 cru2x(inp->sctp_socket->so_cred, &xuc);