Home
last modified time | relevance | path

Searched refs:stcb (Results 1 – 25 of 27) sorted by relevance

12

/third_party/gstreamer/gstplugins_bad/ext/sctp/usrsctp/usrsctplib/netinet/
Dsctp_input.c67 sctp_stop_all_cookie_timers(struct sctp_tcb *stcb) in sctp_stop_all_cookie_timers() argument
76 SCTP_TCB_LOCK_ASSERT(stcb); in sctp_stop_all_cookie_timers()
77 TAILQ_FOREACH(net, &stcb->asoc.nets, sctp_next) { in sctp_stop_all_cookie_timers()
80 stcb->sctp_ep, in sctp_stop_all_cookie_timers()
81 stcb, in sctp_stop_all_cookie_timers()
85 stcb->sctp_ep, in sctp_stop_all_cookie_timers()
86 stcb, in sctp_stop_all_cookie_timers()
97 struct sctp_tcb *stcb, struct sctp_nets *net, int *abort_no_unlock, in sctp_handle_init() argument
107 (void *)stcb); in sctp_handle_init()
108 if (stcb == NULL) { in sctp_handle_init()
[all …]
Dsctp_timer.c97 sctp_threshold_management(struct sctp_inpcb *inp, struct sctp_tcb *stcb, in sctp_threshold_management() argument
112 stcb, 0, in sctp_threshold_management()
120 sctp_send_hb(stcb, net, SCTP_SO_NOT_LOCKED); in sctp_threshold_management()
122 inp, stcb, net, in sctp_threshold_management()
124 sctp_timer_start(SCTP_TIMER_TYPE_HEARTBEAT, inp, stcb, net); in sctp_threshold_management()
128 if (stcb == NULL) in sctp_threshold_management()
135 stcb->asoc.overall_error_count, in sctp_threshold_management()
136 (stcb->asoc.overall_error_count+1), in sctp_threshold_management()
140 stcb->asoc.overall_error_count++; in sctp_threshold_management()
145 stcb->asoc.overall_error_count, in sctp_threshold_management()
[all …]
Dsctp_var.h57 #define sctp_stcb_feature_on(inp, stcb, feature) {\ argument
58 if (stcb) { \
59 stcb->asoc.sctp_features |= feature; \
64 #define sctp_stcb_feature_off(inp, stcb, feature) {\ argument
65 if (stcb) { \
66 stcb->asoc.sctp_features &= ~feature; \
71 #define sctp_stcb_is_feature_on(inp, stcb, feature) \ argument
72 (((stcb != NULL) && \
73 ((stcb->asoc.sctp_features & feature) == feature)) || \
74 ((stcb == NULL) && (inp != NULL) && \
[all …]
Dsctputil.c89 sctp_sblog(struct sockbuf *sb, struct sctp_tcb *stcb, int from, int incr) in sctp_sblog() argument
94 sctp_clog.x.sb.stcb = stcb; in sctp_sblog()
96 if (stcb) in sctp_sblog()
97 sctp_clog.x.sb.stcb_sbcc = stcb->asoc.sb_cc; in sctp_sblog()
112 sctp_log_closing(struct sctp_inpcb *inp, struct sctp_tcb *stcb, int16_t loc) in sctp_log_closing() argument
119 if (stcb) { in sctp_log_closing()
120 sctp_clog.x.close.stcb = (void *)stcb; in sctp_log_closing()
121 sctp_clog.x.close.state = (uint16_t)stcb->asoc.state; in sctp_log_closing()
123 sctp_clog.x.close.stcb = 0; in sctp_log_closing()
157 sctp_log_strm_del_alt(struct sctp_tcb *stcb, uint32_t tsn, uint16_t sseq, uint16_t stream, int from) in sctp_log_strm_del_alt() argument
[all …]
Dsctp_usrreq.c199 sctp_pathmtu_adjustment(struct sctp_tcb *stcb, uint16_t nxtsz) in sctp_pathmtu_adjustment() argument
205 stcb->asoc.smallest_mtu = nxtsz; in sctp_pathmtu_adjustment()
208 if (sctp_auth_is_required_chunk(SCTP_DATA, stcb->asoc.peer_auth_chunks)) { in sctp_pathmtu_adjustment()
209 overhead += sctp_get_auth_chunk_len(stcb->asoc.peer_hmac_id); in sctp_pathmtu_adjustment()
211 TAILQ_FOREACH(chk, &stcb->asoc.send_queue, sctp_next) { in sctp_pathmtu_adjustment()
216 TAILQ_FOREACH(chk, &stcb->asoc.sent_queue, sctp_next) { in sctp_pathmtu_adjustment()
225 sctp_total_flight_decrease(stcb, chk); in sctp_pathmtu_adjustment()
227 sctp_ucount_incr(stcb->asoc.sent_queue_retran_cnt); in sctp_pathmtu_adjustment()
250 struct sctp_tcb *stcb, argument
264 SCTP_TCB_UNLOCK(stcb);
[all …]
Dsctp_asconf.c155 struct sctp_tcb *stcb, int send_hb, int response_required) in sctp_process_asconf_add_ip() argument
204 sin->sin_port = stcb->rport; in sctp_process_asconf_add_ip()
229 sin6->sin6_port = stcb->rport; in sctp_process_asconf_add_ip()
261 } else if (sctp_add_remote_addr(stcb, sa, &net, stcb->asoc.port, in sctp_process_asconf_add_ip()
276 sctp_ulp_notify(SCTP_NOTIFY_ASCONF_ADD_IP, stcb, 0, sa, SCTP_SO_NOT_LOCKED); in sctp_process_asconf_add_ip()
277 sctp_timer_start(SCTP_TIMER_TYPE_PATHMTURAISE, stcb->sctp_ep, stcb, net); in sctp_process_asconf_add_ip()
278 sctp_timer_start(SCTP_TIMER_TYPE_HEARTBEAT, stcb->sctp_ep, in sctp_process_asconf_add_ip()
279 stcb, net); in sctp_process_asconf_add_ip()
281 sctp_send_hb(stcb, net, SCTP_SO_NOT_LOCKED); in sctp_process_asconf_add_ip()
289 sctp_asconf_del_remote_addrs_except(struct sctp_tcb *stcb, struct sockaddr *src) in sctp_asconf_del_remote_addrs_except() argument
[all …]
Dsctp_indata.c73 struct sctp_tcb *stcb,
79 sctp_set_rwnd(struct sctp_tcb *stcb, struct sctp_association *asoc) in sctp_set_rwnd() argument
81 asoc->my_rwnd = sctp_calc_rwnd(stcb, asoc); in sctp_set_rwnd()
86 sctp_calc_rwnd(struct sctp_tcb *stcb, struct sctp_association *asoc) in sctp_calc_rwnd() argument
96 if (stcb->sctp_socket == NULL) { in sctp_calc_rwnd()
104 if (stcb->asoc.sb_cc == 0 && 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()
127 calc = sctp_sbspace_sub(calc, stcb->asoc.my_rwnd_control_len); in sctp_calc_rwnd()
131 if (calc < stcb->asoc.my_rwnd_control_len) { in sctp_calc_rwnd()
[all …]
Dsctp_output.c2064 sctp_add_addresses_to_i_ia(struct sctp_inpcb *inp, struct sctp_tcb *stcb, in sctp_add_addresses_to_i_ia() argument
2116 if (sctp_is_addr_restricted(stcb, sctp_ifap)) { in sctp_add_addresses_to_i_ia()
2166 if (sctp_is_addr_restricted(stcb, sctp_ifap)) { in sctp_add_addresses_to_i_ia()
2461 sctp_is_addr_restricted(struct sctp_tcb *stcb, struct sctp_ifa *ifa) in sctp_is_addr_restricted() argument
2465 if (stcb == NULL) { in sctp_is_addr_restricted()
2469 LIST_FOREACH(laddr, &stcb->asoc.sctp_restricted_addrs, sctp_nxt_addr) { in sctp_is_addr_restricted()
2644 struct sctp_tcb *stcb, in sctp_choose_boundspecific_stcb() argument
2703 (sctp_is_addr_restricted(stcb, sifa))) || in sctp_choose_boundspecific_stcb()
2705 (sctp_is_addr_restricted(stcb, sifa)) && in sctp_choose_boundspecific_stcb()
2706 (!sctp_is_addr_pending(stcb, sifa)))) { in sctp_choose_boundspecific_stcb()
[all …]
Dsctp_ss_functions.c57 sctp_ss_default_init(struct sctp_tcb *stcb, struct sctp_association *asoc, in sctp_ss_default_init() argument
63 SCTP_TCB_SEND_LOCK(stcb); in sctp_ss_default_init()
74 for (i = 0; i < stcb->asoc.streamoutcnt; i++) { in sctp_ss_default_init()
75 stcb->asoc.ss_functions.sctp_ss_add_to_stream(stcb, &stcb->asoc, in sctp_ss_default_init()
76 &stcb->asoc.strmout[i], in sctp_ss_default_init()
80 SCTP_TCB_SEND_UNLOCK(stcb); in sctp_ss_default_init()
86 sctp_ss_default_clear(struct sctp_tcb *stcb, struct sctp_association *asoc, in sctp_ss_default_clear() argument
90 SCTP_TCB_SEND_LOCK(stcb); in sctp_ss_default_clear()
102 SCTP_TCB_SEND_UNLOCK(stcb); in sctp_ss_default_clear()
108 sctp_ss_default_init_stream(struct sctp_tcb *stcb, struct sctp_stream_out *strq, struct sctp_stream… in sctp_ss_default_init_stream() argument
[all …]
Dsctp_pcb.c926 sctp_does_stcb_own_this_addr(struct sctp_tcb *stcb, struct sockaddr *to) argument
942 loopback_scope = stcb->asoc.scope.loopback_scope;
944 ipv4_local_scope = stcb->asoc.scope.ipv4_local_scope;
945 ipv4_addr_legal = stcb->asoc.scope.ipv4_addr_legal;
948 local_scope = stcb->asoc.scope.local_scope;
949 site_scope = stcb->asoc.scope.site_scope;
950 ipv6_addr_legal = stcb->asoc.scope.ipv6_addr_legal;
953 conn_addr_legal = stcb->asoc.scope.conn_addr_legal;
957 vrf = sctp_find_vrf(stcb->asoc.vrf_id);
964 if (stcb->sctp_ep->sctp_flags & SCTP_PCB_FLAGS_BOUNDALL) {
[all …]
Dsctputil.h49 void sctp_print_out_track_log(struct sctp_tcb *stcb);
65 #define sctp_get_associd(stcb) ((sctp_assoc_t)stcb->asoc.assoc_id) argument
92 sctp_notify_stream_reset_add(struct sctp_tcb *stcb, uint16_t numberin,
95 sctp_notify_stream_reset_tsn(struct sctp_tcb *stcb, uint32_t sending_tsn, uint32_t recv_tsn, int fl…
120 sctp_wakeup_the_read_socket(struct sctp_inpcb *inp, struct sctp_tcb *stcb,
136 struct sctp_tcb *stcb,
174 struct sctp_tcb *stcb, int waitflags);
214 int sctp_connectx_helper_add(struct sctp_tcb *stcb, struct sockaddr *addr,
281 int sctp_local_addr_count(struct sctp_tcb *stcb);
289 #define sctp_free_bufspace(stcb, asoc, tp1, chk_cnt) \ argument
[all …]
Dsctp_peeloff.c56 struct sctp_tcb *stcb; in sctp_can_peel_off() local
73 stcb = sctp_findassociation_ep_asocid(inp, assoc_id, 1); in sctp_can_peel_off()
74 if (stcb == NULL) { in sctp_can_peel_off()
75 SCTP_LTRACE_ERR_RET(inp, stcb, NULL, SCTP_FROM_SCTP_PEELOFF, ENOENT); in sctp_can_peel_off()
78 state = SCTP_GET_STATE(stcb); in sctp_can_peel_off()
81 SCTP_TCB_UNLOCK(stcb); in sctp_can_peel_off()
82 SCTP_LTRACE_ERR_RET(inp, stcb, NULL, SCTP_FROM_SCTP_PEELOFF, ENOTCONN); in sctp_can_peel_off()
85 SCTP_TCB_UNLOCK(stcb); in sctp_can_peel_off()
94 struct sctp_tcb *stcb; in sctp_do_peeloff() local
102 stcb = sctp_findassociation_ep_asocid(inp, assoc_id, 1); in sctp_do_peeloff()
[all …]
Dsctp_cc_functions.c75 sctp_set_initial_cc_param(struct sctp_tcb *stcb, struct sctp_nets *net) in sctp_set_initial_cc_param() argument
80 assoc = &stcb->asoc; in sctp_set_initial_cc_param()
94 if ((stcb->asoc.sctp_cmt_on_off == SCTP_CMT_RPV1) || in sctp_set_initial_cc_param()
95 (stcb->asoc.sctp_cmt_on_off == SCTP_CMT_RPV2)) { in sctp_set_initial_cc_param()
106 stcb->asoc.my_vtag, ((stcb->sctp_ep->sctp_lport << 16) | (stcb->rport)), net, in sctp_set_initial_cc_param()
111 sctp_log_cwnd(stcb, net, 0, SCTP_CWND_INITIALIZATION); in sctp_set_initial_cc_param()
116 sctp_cwnd_update_after_fr(struct sctp_tcb *stcb, in sctp_cwnd_update_after_fr() argument
201 stcb->asoc.my_vtag, ((stcb->sctp_ep->sctp_lport << 16) | (stcb->rport)), net, in sctp_cwnd_update_after_fr()
205 sctp_log_cwnd(stcb, net, (net->cwnd - old_cwnd), in sctp_cwnd_update_after_fr()
234 stcb->sctp_ep, stcb, net, in sctp_cwnd_update_after_fr()
[all …]
Dsctp_auth.c553 sctp_auth_key_acquire(struct sctp_tcb *stcb, uint16_t key_id) in sctp_auth_key_acquire() argument
558 skey = sctp_find_sharedkey(&stcb->asoc.shared_keys, key_id); in sctp_auth_key_acquire()
565 __func__, (void *)stcb, key_id, skey->refcount); in sctp_auth_key_acquire()
570 sctp_auth_key_release(struct sctp_tcb *stcb, uint16_t key_id, int so_locked) in sctp_auth_key_release() argument
575 skey = sctp_find_sharedkey(&stcb->asoc.shared_keys, key_id); in sctp_auth_key_release()
581 __func__, (void *)stcb, key_id, skey->refcount); in sctp_auth_key_release()
586 sctp_ulp_notify(SCTP_NOTIFY_AUTH_FREE_KEY, stcb, in sctp_auth_key_release()
590 __func__, (void *)stcb, key_id, skey->refcount); in sctp_auth_key_release()
1176 sctp_clear_cachedkeys(struct sctp_tcb *stcb, uint16_t keyid) argument
1178 if (stcb == NULL)
[all …]
Dsctp_auth.h148 extern void sctp_auth_key_acquire(struct sctp_tcb *stcb, uint16_t keyid);
149 extern void sctp_auth_key_release(struct sctp_tcb *stcb, uint16_t keyid,
186 extern void sctp_clear_cachedkeys(struct sctp_tcb *stcb, uint16_t keyid);
188 extern int sctp_delete_sharedkey(struct sctp_tcb *stcb, uint16_t keyid);
190 extern int sctp_auth_setactivekey(struct sctp_tcb *stcb, uint16_t keyid);
192 extern int sctp_deact_sharedkey(struct sctp_tcb *stcb, uint16_t keyid);
195 extern void sctp_auth_get_cookie_params(struct sctp_tcb *stcb, struct mbuf *m,
198 struct sctp_auth_chunk *auth, struct sctp_tcb *stcb, uint16_t key_id);
201 struct sctp_tcb *stcb, uint8_t chunk);
202 extern int sctp_handle_auth(struct sctp_tcb *stcb, struct sctp_auth_chunk *ch,
[all …]
Dsctp_structs.h147 struct sctp_tcb *stcb; /* current* assoc */ member
527 struct sctp_tcb *stcb; /* assoc, used for window update */ member
710 void *stcb; member
757 void (*sctp_set_initial_cc_param)(struct sctp_tcb *stcb, struct sctp_nets *net);
758 void (*sctp_cwnd_update_after_sack)(struct sctp_tcb *stcb,
761 void (*sctp_cwnd_update_exit_pf)(struct sctp_tcb *stcb, struct sctp_nets *net);
762 void (*sctp_cwnd_update_after_fr)(struct sctp_tcb *stcb,
764 void (*sctp_cwnd_update_after_timeout)(struct sctp_tcb *stcb,
766 void (*sctp_cwnd_update_after_ecn_echo)(struct sctp_tcb *stcb,
768 void (*sctp_cwnd_update_after_packet_dropped)(struct sctp_tcb *stcb,
[all …]
Dsctp_sysctl.c245 sctp_sysctl_copy_out_local_addresses(struct sctp_inpcb *inp, struct sctp_tcb *stcb, struct sysctl_r… in sctp_sysctl_copy_out_local_addresses() argument
260 if (stcb) { in sctp_sysctl_copy_out_local_addresses()
262 loopback_scope = stcb->asoc.scope.loopback_scope; in sctp_sysctl_copy_out_local_addresses()
263 ipv4_local_scope = stcb->asoc.scope.ipv4_local_scope; in sctp_sysctl_copy_out_local_addresses()
264 local_scope = stcb->asoc.scope.local_scope; in sctp_sysctl_copy_out_local_addresses()
265 site_scope = stcb->asoc.scope.site_scope; in sctp_sysctl_copy_out_local_addresses()
266 ipv4_addr_legal = stcb->asoc.scope.ipv4_addr_legal; in sctp_sysctl_copy_out_local_addresses()
267 ipv6_addr_legal = stcb->asoc.scope.ipv6_addr_legal; in sctp_sysctl_copy_out_local_addresses()
269 conn_addr_legal = stcb->asoc.scope.conn_addr_legal; in sctp_sysctl_copy_out_local_addresses()
315 if (stcb) { in sctp_sysctl_copy_out_local_addresses()
[all …]
Dsctp_indata.h46 sctp_build_readq_entry(struct sctp_tcb *stcb,
71 (_ctl)->stcb = (in_it); \
88 sctp_calc_rwnd(struct sctp_tcb *stcb, struct sctp_association *asoc);
91 sctp_express_handle_sack(struct sctp_tcb *stcb, uint32_t cumack,
96 struct sctp_tcb *stcb,
119 void sctp_slide_mapping_arrays(struct sctp_tcb *stcb);
Dsctp_output.h50 struct sctp_tcb *stcb,
70 struct sctp_tcb *stcb,
110 sctp_remove_from_wheel(struct sctp_tcb *stcb,
140 void sctp_move_chunks_from_net(struct sctp_tcb *stcb, struct sctp_nets *net);
143 #define SCTP_DATA_CHUNK_OVERHEAD(stcb) ((stcb)->asoc.idata_supported ? \ argument
Dsctp_input.h56 sctp_find_stream_reset(struct sctp_tcb *stcb, uint32_t seq,
59 void sctp_reset_in_stream(struct sctp_tcb *stcb, uint32_t number_entries,
63 int sctp_is_there_unsent_data(struct sctp_tcb *stcb, int so_locked);
Dsctp_os_userspace.h619 #define SCTP_LTRACE_ERR_RET_PKT(m, inp, stcb, net, file, err) \ argument
622 (void *)m, (void *)inp, (void *)stcb, (void *)net, file, __LINE__, err);
623 #define SCTP_LTRACE_ERR_RET(inp, stcb, net, file, err) \ argument
626 (void *)inp, (void *)stcb, (void *)net, file, __LINE__, err);
628 #define SCTP_LTRACE_ERR_RET_PKT(m, inp, stcb, net, file, err) argument
629 #define SCTP_LTRACE_ERR_RET(inp, stcb, net, file, err) argument
1034 sctp_route_t *ro, void *stcb,
1037 #define SCTP_IP_OUTPUT(result, o_pak, ro, stcb, vrf_id) sctp_userspace_ip_output(&result, o_pak, ro… argument
1041 struct route_in6 *ro, void *stcb,
1043 …ine SCTP_IP6_OUTPUT(result, o_pak, ro, ifp, stcb, vrf_id) sctp_userspace_ip6_output(&result, o_pak… argument
[all …]
Dsctp_asconf.h68 struct sctp_tcb *stcb,
89 sctp_asconf_send_nat_state_update(struct sctp_tcb *stcb,
Dsctp_uio.h822 void *stcb; /* FIXME: LP64 issue */ member
831 void *stcb; /* FIXME: LP64 issue */ member
890 void *stcb; /* FIXME: LP64 issue */ member
898 void *stcb; /* FIXME: LP64 issue */ member
918 void *stcb; /* FIXME: LP64 issue */ member
Dsctp_pcb.h854 void sctp_clean_up_stream(struct sctp_tcb *stcb, struct sctp_readhead *rh);
/third_party/gstreamer/gstplugins_bad/ext/sctp/usrsctp/usrsctplib/netinet6/
Dsctp6_usrreq.c313 struct sctp_tcb *stcb,
336 stcb, 0, (void *)net, SCTP_SO_NOT_LOCKED);
339 SCTP_TCB_UNLOCK(stcb);
344 sctp_abort_notification(stcb, 1, 0, NULL, SCTP_SO_NOT_LOCKED);
347 atomic_add_int(&stcb->asoc.refcnt, 1);
348 SCTP_TCB_UNLOCK(stcb);
350 SCTP_TCB_LOCK(stcb);
351 atomic_subtract_int(&stcb->asoc.refcnt, 1);
353 (void)sctp_free_assoc(inp, stcb, SCTP_NORMAL_PROC,
359 SCTP_TCB_UNLOCK(stcb);
[all …]

12