Lines Matching refs:sctp_ep
474 stcb->sctp_ep->last_abort_code = SCTP_FROM_SCTP_INDATA + SCTP_LOC_1; in sctp_abort_in_reasm()
475 sctp_abort_an_association(stcb->sctp_ep, stcb, oper, SCTP_SO_NOT_LOCKED); in sctp_abort_in_reasm()
562 stcb->sctp_ep->last_abort_code = SCTP_FROM_SCTP_INDATA + SCTP_LOC_2; in sctp_queue_data_to_stream()
563 sctp_abort_an_association(stcb->sctp_ep, stcb, op_err, SCTP_SO_NOT_LOCKED); in sctp_queue_data_to_stream()
576 so = SCTP_INP_SO(stcb->sctp_ep); in sctp_queue_data_to_stream()
582 if (stcb->sctp_ep->sctp_flags & SCTP_PCB_FLAGS_SOCKET_GONE) { in sctp_queue_data_to_stream()
605 sctp_add_to_readq(stcb->sctp_ep, stcb, in sctp_queue_data_to_stream()
645 sctp_add_to_readq(stcb->sctp_ep, stcb, in sctp_queue_data_to_stream()
670 stcb->sctp_ep->last_abort_code = SCTP_FROM_SCTP_INDATA + SCTP_LOC_3; in sctp_queue_data_to_stream()
671 sctp_abort_an_association(stcb->sctp_ep, stcb, op_err, SCTP_SO_NOT_LOCKED); in sctp_queue_data_to_stream()
913 sctp_add_to_readq(stcb->sctp_ep, stcb, control, in sctp_handle_old_unordered_data()
918 sctp_invoke_recv_callback(stcb->sctp_ep, stcb, control, inp_read_lock_held); in sctp_handle_old_unordered_data()
921 sctp_wakeup_the_read_socket(stcb->sctp_ep, stcb, SCTP_SO_NOT_LOCKED); in sctp_handle_old_unordered_data()
942 sctp_invoke_recv_callback(stcb->sctp_ep, stcb, control, SCTP_READ_LOCK_NOT_HELD); in sctp_handle_old_unordered_data()
944 sctp_wakeup_the_read_socket(stcb->sctp_ep, stcb, SCTP_SO_NOT_LOCKED); in sctp_handle_old_unordered_data()
949 sctp_add_to_readq(stcb->sctp_ep, stcb, control, in sctp_handle_old_unordered_data()
952 sctp_wakeup_the_read_socket(stcb->sctp_ep, stcb, SCTP_SO_NOT_LOCKED); in sctp_handle_old_unordered_data()
1112 stcb->sctp_ep->partial_delivery_point); in sctp_deliver_reasm_check()
1114 pd_point = stcb->sctp_ep->partial_delivery_point; in sctp_deliver_reasm_check()
1147 sctp_add_to_readq(stcb->sctp_ep, stcb, in sctp_deliver_reasm_check()
1157 sctp_add_to_readq(stcb->sctp_ep, stcb, in sctp_deliver_reasm_check()
1215 sctp_add_to_readq(stcb->sctp_ep, stcb, in sctp_deliver_reasm_check()
1290 sctp_add_to_readq(stcb->sctp_ep, stcb, in sctp_deliver_reasm_check()
1326 SCTP_INP_READ_LOCK(stcb->sctp_ep); in sctp_add_chk_to_control()
1376 SCTP_INP_READ_UNLOCK(stcb->sctp_ep); in sctp_add_chk_to_control()
1647 sctp_add_to_readq(stcb->sctp_ep, stcb, in sctp_queue_data_for_reasm()
1661 sctp_invoke_recv_callback(stcb->sctp_ep, stcb, control, SCTP_READ_LOCK_NOT_HELD); in sctp_queue_data_for_reasm()
1664 sctp_wakeup_the_read_socket(stcb->sctp_ep, stcb, SCTP_SO_NOT_LOCKED); in sctp_queue_data_for_reasm()
1751 stcb->sctp_ep->last_abort_code = SCTP_FROM_SCTP_INDATA + SCTP_LOC_15; in sctp_process_a_data_chunk()
1752 sctp_abort_an_association(stcb->sctp_ep, stcb, op_err, SCTP_SO_NOT_LOCKED); in sctp_process_a_data_chunk()
1766 SCTP_LTRACE_CHK(stcb->sctp_ep, stcb, chk_type, tsn); in sctp_process_a_data_chunk()
1810 if (((stcb->sctp_ep->sctp_flags & SCTP_PCB_FLAGS_SOCKET_GONE) || in sctp_process_a_data_chunk()
1811 (stcb->sctp_ep->sctp_flags & SCTP_PCB_FLAGS_SOCKET_ALLGONE) || in sctp_process_a_data_chunk()
1818 sctp_abort_an_association(stcb->sctp_ep, stcb, op_err, SCTP_SO_NOT_LOCKED); in sctp_process_a_data_chunk()
1889 stcb->sctp_ep->last_abort_code = SCTP_FROM_SCTP_INDATA + SCTP_LOC_16; in sctp_process_a_data_chunk()
1890 sctp_abort_an_association(stcb->sctp_ep, stcb, op_err, SCTP_SO_NOT_LOCKED); in sctp_process_a_data_chunk()
1948 so = SCTP_INP_SO(stcb->sctp_ep); in sctp_process_a_data_chunk()
1960 sctp_sorwakeup(stcb->sctp_ep, stcb->sctp_socket); in sctp_process_a_data_chunk()
2036 stcb->sctp_ep->last_abort_code = SCTP_FROM_SCTP_INDATA + SCTP_LOC_17; in sctp_process_a_data_chunk()
2037 sctp_abort_an_association(stcb->sctp_ep, stcb, op_err, SCTP_SO_NOT_LOCKED); in sctp_process_a_data_chunk()
2150 sctp_add_to_readq(stcb->sctp_ep, stcb, in sctp_process_a_data_chunk()
2258 sctp_add_to_readq(stcb->sctp_ep, stcb, in sctp_process_a_data_chunk()
2606 stcb->sctp_ep, stcb, NULL, in sctp_sack_check()
2650 stcb->sctp_ep, stcb, NULL); in sctp_sack_check()
2658 sctp_timer_stop(SCTP_TIMER_TYPE_RECV, stcb->sctp_ep, stcb, NULL, in sctp_sack_check()
2665 stcb->sctp_ep, stcb, NULL); in sctp_sack_check()
2763 stcb->sctp_ep->last_abort_code = SCTP_FROM_SCTP_INDATA + SCTP_LOC_20; in sctp_process_data()
2774 stcb->sctp_ep->last_abort_code = SCTP_FROM_SCTP_INDATA + SCTP_LOC_21; in sctp_process_data()
2799 stcb->sctp_ep->last_abort_code = SCTP_FROM_SCTP_INDATA + SCTP_LOC_22; in sctp_process_data()
2885 stcb->sctp_ep->last_abort_code = SCTP_FROM_SCTP_INDATA + SCTP_LOC_23; in sctp_process_data()
3971 if (asoc->peers_rwnd < stcb->sctp_ep->sctp_ep.sctp_sws_sender) {
4018 stcb->sctp_ep->last_abort_code = SCTP_FROM_SCTP_INDATA + SCTP_LOC_24;
4019 sctp_abort_an_association(stcb->sctp_ep, stcb, op_err, SCTP_SO_NOT_LOCKED);
4152 if (stcb->sctp_ep->recv_callback) {
4157 inp = stcb->sctp_ep;
4189 so = SCTP_INP_SO(stcb->sctp_ep);
4201 sctp_sowwakeup_locked(stcb->sctp_ep, stcb->sctp_socket);
4236 stcb->sctp_ep, stcb, net,
4238 sctp_timer_start(SCTP_TIMER_TYPE_HEARTBEAT, stcb->sctp_ep, stcb, net);
4270 if (asoc->peers_rwnd < stcb->sctp_ep->sctp_ep.sctp_sws_sender) {
4298 sctp_timer_start(SCTP_TIMER_TYPE_SEND, stcb->sctp_ep, stcb, net);
4307 sctp_timer_start(SCTP_TIMER_TYPE_SEND, stcb->sctp_ep, stcb, net);
4310 sctp_timer_stop(SCTP_TIMER_TYPE_SEND, stcb->sctp_ep,
4364 stcb->sctp_ep->last_abort_code = SCTP_FROM_SCTP_INDATA + SCTP_LOC_27;
4365 sctp_abort_an_association(stcb->sctp_ep, stcb, op_err, SCTP_SO_NOT_LOCKED);
4385 stcb->sctp_ep, stcb, netp);
4387 stcb->sctp_ep, stcb, NULL);
4402 stcb->sctp_ep, stcb, netp);
4442 stcb->sctp_ep, stcb, lchk->whoTo);
4579 stcb->sctp_ep->last_abort_code = SCTP_FROM_SCTP_INDATA + SCTP_LOC_28;
4580 sctp_abort_an_association(stcb->sctp_ep, stcb, op_err, SCTP_SO_NOT_LOCKED);
4604 if (asoc->peers_rwnd < stcb->sctp_ep->sctp_ep.sctp_sws_sender) {
4610 sctp_timer_stop(SCTP_TIMER_TYPE_SEND, stcb->sctp_ep,
4809 sctp_timer_stop(SCTP_TIMER_TYPE_SEND, stcb->sctp_ep,
4817 sctp_timer_stop(SCTP_TIMER_TYPE_SEND, stcb->sctp_ep,
4882 if (stcb->sctp_ep->recv_callback) {
4887 inp = stcb->sctp_ep;
4916 so = SCTP_INP_SO(stcb->sctp_ep);
4928 sctp_sowwakeup_locked(stcb->sctp_ep, stcb->sctp_socket);
5022 stcb->sctp_ep, stcb, net,
5024 sctp_timer_start(SCTP_TIMER_TYPE_HEARTBEAT, stcb->sctp_ep, stcb, net);
5046 sctp_timer_stop(SCTP_TIMER_TYPE_SEND, stcb->sctp_ep,
5066 if (asoc->peers_rwnd < stcb->sctp_ep->sctp_ep.sctp_sws_sender) {
5086 stcb->sctp_ep->last_abort_code = SCTP_FROM_SCTP_INDATA + SCTP_LOC_34;
5087 sctp_abort_an_association(stcb->sctp_ep, stcb, op_err, SCTP_SO_NOT_LOCKED);
5107 stcb->sctp_ep, stcb, netp);
5109 stcb->sctp_ep, stcb, NULL);
5125 stcb->sctp_ep, stcb, netp);
5181 if (asoc->peers_rwnd < stcb->sctp_ep->sctp_ep.sctp_sws_sender) {
5216 stcb->sctp_ep, stcb, net);
5226 stcb->sctp_ep, stcb, net);
5230 sctp_timer_stop(SCTP_TIMER_TYPE_SEND, stcb->sctp_ep,
5305 stcb->sctp_ep, stcb, lchk->whoTo);
5377 sctp_add_to_readq(stcb->sctp_ep, stcb,
5447 sctp_add_to_readq(stcb->sctp_ep, stcb,
5532 sctp_reset_a_control(control, stcb->sctp_ep, cumtsn);
5636 stcb->sctp_ep->last_abort_code = SCTP_FROM_SCTP_INDATA + SCTP_LOC_36;
5637 sctp_abort_an_association(stcb->sctp_ep, stcb, op_err, SCTP_SO_NOT_LOCKED);
5672 SCTP_INP_READ_LOCK(stcb->sctp_ep);
5676 SCTP_INP_READ_UNLOCK(stcb->sctp_ep);
5693 SCTP_INP_READ_LOCK(stcb->sctp_ep);
5753 TAILQ_FOREACH(control, &stcb->sctp_ep->read_queue, next) {
5803 SCTP_INP_READ_UNLOCK(stcb->sctp_ep);