| /src/sys/netinet/ |
| sctp_timer.c | 100 sctp_audit_retranmission_queue(struct sctp_association *asoc)
107 asoc->sent_queue_retran_cnt,
108 asoc->sent_queue_cnt);
111 asoc->sent_queue_retran_cnt = 0;
112 asoc->sent_queue_cnt = 0;
113 TAILQ_FOREACH(chk, &asoc->sent_queue, sctp_next) {
115 asoc->sent_queue_retran_cnt++;
117 asoc->sent_queue_cnt++;
119 TAILQ_FOREACH(chk, &asoc->control_send_queue, sctp_next) {
121 asoc->sent_queue_retran_cnt++
694 struct sctp_association *asoc; local in function:sctp_move_all_chunks_to_alt
1361 struct sctp_association *asoc; local in function:sctp_autoclose_timer
[all...] |
| sctp_asconf.c | 95 * the asoc local addr list is always a "DO NOT USE" list
99 * the asoc local addr list is the "DO NOT USE" list
102 * the asoc local addr list is the usable address list
104 * An ASCONF parameter queue exists per asoc which holds the pending
432 * note if result == -2, the address doesn't exist in the asoc
437 /* only one address in the asoc */
573 struct sctp_association *asoc; local in function:sctp_handle_asconf
595 asoc = &stcb->asoc;
598 if (serial_num == asoc->asconf_seq_in)
1331 struct sctp_association *asoc; local in function:sctp_handle_asconf_ack
[all...] |
| sctp_indata.c | 107 sctp_set_rwnd(struct sctp_tcb *stcb, struct sctp_association *asoc)
121 asoc->size_on_delivery_queue,
122 asoc->size_on_reasm_queue,
123 asoc->size_on_all_streams);
127 asoc->size_on_delivery_queue == 0 &&
128 asoc->size_on_reasm_queue == 0 &&
129 asoc->size_on_all_streams == 0) {
131 asoc->my_rwnd = uimax(stcb->sctp_socket->so_rcv.sb_hiwat,
141 calc = sctp_sbspace_sub(calc, (u_int32_t)asoc->size_on_delivery_queue);
142 calc = sctp_sbspace_sub(calc, (u_int32_t)asoc->size_on_reasm_queue)
2211 struct sctp_association *asoc; local in function:sctp_sack_check
2504 struct sctp_association *asoc; local in function:sctp_process_data
3469 struct sctp_association *asoc; local in function:sctp_handle_sack
4333 struct sctp_association *asoc; local in function:sctp_kick_prsctp_reorder_queue
4417 struct sctp_association *asoc; local in function:sctp_handle_forward_tsn
[all...] |
| sctp_pcb.h | 352 struct sctp_association asoc; member in struct:sctp_tcb
|
| sctp_structs.h | 243 struct sctp_association *asoc; /* bp to asoc this belongs to */ member in struct:sctp_tmit_chunk
|
| sctp_pcb.c | 355 TAILQ_FOREACH(net, &stcb->asoc.nets, sctp_next) {
546 TAILQ_FOREACH(net, &stcb->asoc.nets, sctp_next) {
576 TAILQ_FOREACH(net, &stcb->asoc.nets, sctp_next) {
640 if (stcb->asoc.my_vtag == vtag) {
1078 if (stcb->asoc.my_vtag == vtag) {
1224 printf("Found endpoint %p but no asoc - ep state:%x\n",
2002 struct sctp_tcb *asoc, *nasoc; local in function:sctp_inpcb_free
2037 for ((asoc = LIST_FIRST(&inp->sctp_asoc_list)); asoc != NULL;
2038 asoc = nasoc)
2616 struct sctp_association *asoc; local in function:sctp_aloc_assoc
2869 struct sctp_association *asoc; local in function:sctp_del_remote_addr
3023 struct sctp_association *asoc; local in function:sctp_free_assoc
4492 struct sctp_association *asoc; local in function:sctp_drain_mbufs
[all...] |
| sctp_usrreq.c | 182 sctp_split_chunks(struct sctp_association *asoc,
231 asoc->stream_queue_cnt++;
256 if (ntohl(sh->v_tag) != (stcb->asoc.peer_vtag)) {
291 if (stcb->asoc.smallest_mtu > nxtsz) {
295 stcb->asoc.smallest_mtu = nxtsz;
298 TAILQ_FOREACH(chk, &stcb->asoc.send_queue, sctp_next) {
303 TAILQ_FOREACH(chk, &stcb->asoc.sent_queue, sctp_next) {
311 stcb->asoc.sent_queue_retran_cnt++;
326 TAILQ_FOREACH(strm, &stcb->asoc.out_wheel, next_spoke) {
331 sctp_split_chunks(&stcb->asoc, strm, chk)
708 struct sctp_association *asoc; local in function:sctp_disconnect
830 struct sctp_association *asoc; local in function:sctp_shutdown
1489 struct sctp_association *asoc; local in function:sctp_optsget
[all...] |
| sctp_input.c | 168 struct sctp_association *asoc; local in function:sctp_process_init
173 asoc = &stcb->asoc;
175 asoc->peer_vtag = ntohl(init->initiate_tag);
176 asoc->peers_rwnd = ntohl(init->a_rwnd);
178 if (TAILQ_FIRST(&asoc->nets)) {
180 TAILQ_FOREACH(lnet, &asoc->nets, sctp_next) {
181 lnet->ssthresh = asoc->peers_rwnd;
184 if (asoc->pre_open_streams > ntohs(init->num_inbound_streams)) {
192 if (asoc->strmout)
298 struct sctp_association *asoc; local in function:sctp_process_init_ack
512 struct sctp_association *asoc; local in function:sctp_handle_shutdown
623 struct sctp_association *asoc; local in function:sctp_handle_shutdown_ack
767 struct sctp_association *asoc; local in function:sctp_handle_error
1045 struct sctp_association *asoc; local in function:sctp_process_cookie_existing
1420 struct sctp_association *asoc; local in function:sctp_process_cookie_new
2140 struct sctp_association *asoc; local in function:sctp_handle_cookie_ack
2332 struct sctp_association *asoc; local in function:sctp_handle_shutdown_complete
2631 struct sctp_association *asoc; local in function:sctp_clean_up_stream_reset
3029 struct sctp_association *asoc; local in function:sctp_process_control
[all...] |
| sctputil.c | 286 sctp_log_block(uint8_t from, struct socket *so, struct sctp_association *asoc)
292 sctp_clog[sctp_cwnd_log_at].x.blk.onmb = asoc->total_output_mbuf_queue_size;
294 sctp_clog[sctp_cwnd_log_at].x.blk.onsb = asoc->total_output_queue_size;
295 sctp_clog[sctp_cwnd_log_at].x.blk.send_sent_qcnt = (u_int16_t)(asoc->send_queue_cnt + asoc->sent_queue_cnt);
296 sctp_clog[sctp_cwnd_log_at].x.blk.stream_qcnt = (u_int16_t)asoc->stream_queue_cnt;
464 (0x000000ff & stcb->asoc.sent_queue_retran_cnt);
472 TAILQ_FOREACH(chk, &stcb->asoc.sent_queue, sctp_next) {
480 if (resend_cnt != stcb->asoc.sent_queue_retran_cnt) {
487 printf("resend_cnt:%d asoc-tot:%d\n"
2569 struct sctp_association *asoc; local in function:sctp_report_all_outbound
3262 struct sctp_association *asoc; local in function:sctp_grub_through_socket_buffer
[all...] |
| sctp_output.c | 461 LIST_FOREACH(laddr, &stcb->asoc.sctp_local_addr_list, sctp_nxt_addr) {
469 LIST_FOREACH(laddr, &stcb->asoc.sctp_local_addr_list, sctp_nxt_addr) {
682 starting_point = stcb->asoc.last_used_address;
684 if (stcb->asoc.last_used_address == NULL) {
686 stcb->asoc.last_used_address = LIST_FIRST(&inp->sctp_addr_list);
689 for (laddr = stcb->asoc.last_used_address; laddr;
707 stcb->asoc.last_used_address = NULL;
711 stcb->asoc.last_used_address = starting_point;
714 if (stcb->asoc.last_used_address == NULL) {
716 stcb->asoc.last_used_address = LIST_FIRST(&inp->sctp_addr_list)
3249 struct sctp_association *asoc; local in function:sctp_send_initiate_ack
4129 struct sctp_association *asoc; local in function:sctp_msg_append
4855 struct sctp_association *asoc; local in function:sctp_toss_old_asconf
4992 struct sctp_association *asoc; local in function:sctp_move_to_outqueue
5127 struct sctp_association *asoc; local in function:sctp_fill_outqueue
6885 struct sctp_association *asoc; local in function:sctp_chunk_output
7091 struct sctp_association *asoc; local in function:sctp_output
7658 struct sctp_association *asoc; local in function:sctp_send_sack
8428 struct sctp_association *asoc; local in function:sctp_send_ecn_echo
8480 struct sctp_association *asoc; local in function:sctp_send_packet_dropped
8608 struct sctp_association *asoc; local in function:sctp_send_cwr
8684 struct sctp_association *asoc; local in function:sctp_send_str_reset_ack
8834 struct sctp_association *asoc; local in function:sctp_send_str_reset_req
9810 struct sctp_association *asoc; local in function:sctp_sosend
[all...] |
| /src/lib/libc/net/ |
| sctp_sys_calls.c | 250 sctp_assoc_t asoc; local in function:sctp_getpaddrs
259 asoc = id;
262 &asoc, &siz) != 0) {
265 siz = (unsigned int)asoc;
|
| /src/sys/netinet6/ |
| sctp6_usrreq.c | 327 if (ntohl(sh->v_tag) != (stcb->asoc.peer_vtag))
349 if (stcb->asoc.smallest_mtu > nxtsz) {
353 stcb->asoc.smallest_mtu = nxtsz;
356 TAILQ_FOREACH(chk, &stcb->asoc.send_queue, sctp_next) {
361 TAILQ_FOREACH(chk, &stcb->asoc.sent_queue, sctp_next) {
369 stcb->asoc.sent_queue_retran_cnt++;
377 stcb->asoc.total_flight -= chk->send_size;
381 TAILQ_FOREACH(strm, &stcb->asoc.out_wheel, next_spoke) {
715 struct sctp_association *asoc; local in function:sctp6_disconnect
722 asoc = &stcb->asoc
[all...] |
