Home
last modified time | relevance | path

Searched refs:connp (Results 1 – 25 of 73) sorted by relevance

123

/titanic_44/usr/src/uts/common/inet/ip/
H A Dipclassifier.c578 conn_t *connp; in ipcl_conn_create() local
583 if ((connp = kmem_cache_alloc(sctp_conn_cache, sleep)) == NULL) in ipcl_conn_create()
585 sctp_conn_init(connp); in ipcl_conn_create()
587 connp->conn_netstack = ns; in ipcl_conn_create()
588 connp->conn_ixa->ixa_ipst = ns->netstack_ip; in ipcl_conn_create()
589 connp->conn_ixa->ixa_conn_id = (long)connp; in ipcl_conn_create()
590 ipcl_globalhash_insert(connp); in ipcl_conn_create()
591 return (connp); in ipcl_conn_create()
614 connp = NULL; in ipcl_conn_create()
618 if ((connp = kmem_cache_alloc(conn_cache, sleep)) == NULL) in ipcl_conn_create()
[all …]
H A Dicmp.c113 static void icmp_icmp_error_ipv6(conn_t *connp, mblk_t *mp,
123 int icmp_opt_set(conn_t *connp, uint_t optset_context,
127 int icmp_opt_get(conn_t *connp, int level, int name,
129 static int icmp_output_newdst(conn_t *connp, mblk_t *data_mp, sin_t *sin,
317 conn_t *connp = Q_TO_CONN(q); in icmp_tpi_bind() local
335 icmp = connp->conn_icmp; in icmp_tpi_bind()
369 if (connp->conn_family == AF_INET) { in icmp_tpi_bind()
378 ASSERT(connp->conn_family == AF_INET6); in icmp_tpi_bind()
406 error = rawip_do_bind(connp, sa, len); in icmp_tpi_bind()
420 rawip_do_bind(conn_t *connp, struct sockaddr *sa, socklen_t len) in rawip_do_bind() argument
[all …]
H A Dconn_opt.c107 conn_recvancillary_size(conn_t *connp, crb_t recv_ancillary, in conn_recvancillary_size() argument
111 ip_stack_t *ipst = connp->conn_netstack->netstack_ip; in conn_recvancillary_size()
131 connp->conn_family == AF_INET) { in conn_recvancillary_size()
145 ip_stack_t *ipst = connp->conn_netstack->netstack_ip; in conn_recvancillary_size()
172 connp->conn_family == AF_INET6) { in conn_recvancillary_size()
255 conn_recvancillary_add(conn_t *connp, crb_t recv_ancillary, in conn_recvancillary_add() argument
284 connp->conn_family == AF_INET) { in conn_recvancillary_add()
285 ip_stack_t *ipst = connp->conn_netstack->netstack_ip; in conn_recvancillary_add()
305 ipif = ipif_good_addr(ill, IPCL_ZONEID(connp)); in conn_recvancillary_add()
335 ip_stack_t *ipst = connp->conn_netstack->netstack_ip; in conn_recvancillary_add()
[all …]
H A Drts.c203 rts_common_close(queue_t *q, conn_t *connp) in rts_common_close() argument
206 ASSERT(connp != NULL && IPCL_IS_RTS(connp)); in rts_common_close()
208 ip_rts_unregister(connp); in rts_common_close()
210 ip_quiesce_conn(connp); in rts_common_close()
212 if (!IPCL_IS_NONSTR(connp)) { in rts_common_close()
226 ASSERT(connp->conn_ref == 1); in rts_common_close()
228 if (!IPCL_IS_NONSTR(connp)) { in rts_common_close()
229 inet_minor_free(connp->conn_minor_arena, connp->conn_dev); in rts_common_close()
231 ip_free_helper_stream(connp); in rts_common_close()
234 connp->conn_ref--; in rts_common_close()
[all …]
H A Dip_helper_stream.c67 conn_t *connp = *((conn_t **)mp->b_cont->b_rptr); in ip_helper_share_conn() local
78 connp->conn_helper_info->iphs_minfo = q->q_ptr; in ip_helper_share_conn()
79 connp->conn_helper_info->iphs_rq = RD(q); in ip_helper_share_conn()
80 connp->conn_helper_info->iphs_wq = WR(q); in ip_helper_share_conn()
81 WR(q)->q_ptr = RD(q)->q_ptr = (void *)connp; in ip_helper_share_conn()
82 connp->conn_rq = RD(q); in ip_helper_share_conn()
83 connp->conn_wq = WR(q); in ip_helper_share_conn()
180 ip_create_helper_stream(conn_t *connp, ldi_ident_t li) in ip_create_helper_stream() argument
188 if (connp->conn_helper_info != NULL) { in ip_create_helper_stream()
202 error = ldi_open_by_name((connp->conn_family == AF_INET6 ? DEV_IP6 : in ip_create_helper_stream()
[all …]
H A Dip_multi.c86 static int ilg_add(conn_t *connp, const in6_addr_t *group,
89 static void ilg_delete(conn_t *connp, ilg_t *ilg, const in6_addr_t *src);
92 static int ip_opt_delete_group_excl(conn_t *connp,
223 conn_ilg_alloc(conn_t *connp, int *errp) in conn_ilg_alloc() argument
227 ASSERT(RW_WRITE_HELD(&connp->conn_ilg_lock)); in conn_ilg_alloc()
233 if (connp->conn_state_flags & CONN_CLOSING) { in conn_ilg_alloc()
247 if (connp->conn_ilg != NULL) in conn_ilg_alloc()
248 connp->conn_ilg->ilg_ptpn = &ilg->ilg_next; in conn_ilg_alloc()
249 ilg->ilg_next = connp->conn_ilg; in conn_ilg_alloc()
250 ilg->ilg_ptpn = &connp->conn_ilg; in conn_ilg_alloc()
[all …]
H A Dip_attr.c754 conn_get_ixa_impl(conn_t *connp, boolean_t replace, int kmflag) in conn_get_ixa_impl() argument
765 mutex_enter(&connp->conn_lock); in conn_get_ixa_impl()
766 oldixa = connp->conn_ixa; in conn_get_ixa_impl()
772 mutex_exit(&connp->conn_lock); in conn_get_ixa_impl()
778 mutex_exit(&connp->conn_lock); in conn_get_ixa_impl()
787 connp->conn_ixa = ixa; in conn_get_ixa_impl()
788 mutex_exit(&connp->conn_lock); in conn_get_ixa_impl()
791 mutex_exit(&connp->conn_lock); in conn_get_ixa_impl()
813 conn_get_ixa(conn_t *connp, boolean_t replace) in conn_get_ixa() argument
815 return (conn_get_ixa_impl(connp, replace, KM_NOSLEEP)); in conn_get_ixa()
[all …]
/titanic_44/usr/src/uts/common/inet/
H A Dipclassifier.h96 #define IPCL_IS_CONNECTED(connp) \ argument
97 ((connp)->conn_flags & IPCL_CONNECTED)
99 #define IPCL_IS_BOUND(connp) \ argument
100 ((connp)->conn_flags & IPCL_BOUND)
106 #define IPCL_IS_TCP(connp) \ argument
107 ((connp)->conn_flags & IPCL_TCPCONN)
109 #define IPCL_IS_SCTP(connp) \ argument
110 ((connp)->conn_flags & IPCL_SCTPCONN)
112 #define IPCL_IS_UDP(connp) \ argument
113 ((connp)->conn_flags & IPCL_UDPCONN)
[all …]
H A Dtcp_cluster.h59 #define CL_INET_CONNECT(connp, is_outgoing, err) { \ argument
66 if ((connp)->conn_ipversion == IPV4_VERSION) { \
67 if ((connp)->conn_laddr_v4 != 0) { \
69 (connp)->conn_netstack->netstack_stackid,\
71 (uint8_t *)(&((connp)->conn_laddr_v4)),\
72 (in_port_t)(connp)->conn_lport, \
73 (uint8_t *)(&((connp)->conn_faddr_v4)),\
74 (in_port_t)(connp)->conn_fport, NULL); \
78 &(connp)->conn_laddr_v6)) { \
80 (connp)->conn_netstack->netstack_stackid,\
[all …]
H A Dproto_set.c41 proto_set_rx_hiwat(queue_t *q, conn_t *connp, size_t size) in proto_set_rx_hiwat() argument
44 if (connp != NULL && IPCL_IS_NONSTR(connp)) { in proto_set_rx_hiwat()
49 (*connp->conn_upcalls->su_set_proto_props) in proto_set_rx_hiwat()
50 (connp->conn_upper_handle, &sopp); in proto_set_rx_hiwat()
68 proto_set_rx_lowat(queue_t *q, conn_t *connp, size_t size) in proto_set_rx_lowat() argument
71 if (connp != NULL && IPCL_IS_NONSTR(connp)) { in proto_set_rx_lowat()
76 (*connp->conn_upcalls->su_set_proto_props) in proto_set_rx_lowat()
77 (connp->conn_upper_handle, &sopp); in proto_set_rx_lowat()
100 proto_set_maxpsz(queue_t *q, conn_t *connp, size_t size) in proto_set_maxpsz() argument
102 if (connp != NULL && IPCL_IS_NONSTR(connp)) { in proto_set_maxpsz()
[all …]
H A Dsqueue.c218 #define SQUEUE_DBG_SET(sqp, mp, proc, connp, tag) { \ argument
221 (sqp)->sq_connp = (connp); \
231 #define SQUEUE_DBG_SET(sqp, mp, proc, connp, tag) argument
428 conn_t *connp; in squeue_enter() local
467 connp = (conn_t *)mp->b_prev; in squeue_enter()
471 ASSERT(proc != NULL && connp != NULL); in squeue_enter()
478 if (connp->conn_sqp == sqp) { in squeue_enter()
479 SQUEUE_DBG_SET(sqp, mp, proc, connp, in squeue_enter()
481 connp->conn_on_sqp = B_TRUE; in squeue_enter()
483 sqp, mblk_t *, mp, conn_t *, connp); in squeue_enter()
[all …]
/titanic_44/usr/src/uts/common/inet/udp/
H A Dudp.c143 static void udp_icmp_error_ipv6(conn_t *connp, mblk_t *mp,
156 int udp_opt_set(conn_t *connp, uint_t optset_context,
160 int udp_opt_get(conn_t *connp, int level, int name,
162 static int udp_output_connected(conn_t *connp, mblk_t *mp, cred_t *cr,
164 static int udp_output_lastdst(conn_t *connp, mblk_t *mp, cred_t *cr,
166 static int udp_output_newdst(conn_t *connp, mblk_t *data_mp, sin_t *sin,
394 conn_t *connp = udp->udp_connp; in udp_bind_hash_remove() local
403 ASSERT(connp->conn_lport != 0); in udp_bind_hash_remove()
405 lockp = &us->us_bind_fanout[UDP_BIND_HASH(connp->conn_lport, in udp_bind_hash_remove()
427 conn_t *connp = udp->udp_connp; in udp_bind_hash_insert() local
[all …]
H A Dudp_stats.c70 conn_t *connp = Q_TO_CONN(q); in udp_snmp_get() local
75 ip_stack_t *ipst = connp->conn_netstack->netstack_ip; in udp_snmp_get()
76 udp_stack_t *us = connp->conn_netstack->netstack_udp; in udp_snmp_get()
102 zoneid = connp->conn_zoneid; in udp_snmp_get()
142 connp = NULL; in udp_snmp_get()
144 while ((connp = ipcl_get_next_conn(connfp, connp, in udp_snmp_get()
146 udp = connp->conn_udp; in udp_snmp_get()
147 if (zoneid != connp->conn_zoneid) in udp_snmp_get()
166 if (connp->conn_mlp_type != mlptSingle) { in udp_snmp_get()
167 if (connp->conn_mlp_type == mlptShared || in udp_snmp_get()
[all …]
/titanic_44/usr/src/uts/common/inet/tcp/
H A Dtcp.c427 conn_t *connp = tcp->tcp_connp; in tcp_set_recv_threshold() local
439 (*connp->conn_upcalls->su_set_proto_props) in tcp_set_recv_threshold()
440 (connp->conn_upper_handle, &sopp); in tcp_set_recv_threshold()
470 conn_t *connp = tcp->tcp_connp; in tcp_ipsec_cleanup() local
472 ASSERT(connp->conn_flags & IPCL_TCPCONN); in tcp_ipsec_cleanup()
474 if (connp->conn_latch != NULL) { in tcp_ipsec_cleanup()
475 IPLATCH_REFRELE(connp->conn_latch); in tcp_ipsec_cleanup()
476 connp->conn_latch = NULL; in tcp_ipsec_cleanup()
478 if (connp->conn_latch_in_policy != NULL) { in tcp_ipsec_cleanup()
479 IPPOL_REFRELE(connp->conn_latch_in_policy); in tcp_ipsec_cleanup()
[all …]
H A Dtcp_socket.c98 conn_t *connp = (conn_t *)proto_handle; in tcp_activate() local
102 ASSERT(connp->conn_upper_handle == NULL); in tcp_activate()
121 connp->conn_upcalls = sock_upcalls; in tcp_activate()
122 connp->conn_upper_handle = sock_handle; in tcp_activate()
124 ASSERT(connp->conn_rcvbuf != 0 && in tcp_activate()
125 connp->conn_rcvbuf == connp->conn_tcp->tcp_rwnd); in tcp_activate()
202 conn_t *connp = (conn_t *)proto_handle; in tcp_bind() local
206 ASSERT(connp->conn_upper_handle != NULL); in tcp_bind()
208 error = squeue_synch_enter(connp, NULL); in tcp_bind()
216 if (connp->conn_tcp->tcp_state < TCPS_LISTEN) in tcp_bind()
[all …]
H A Dtcp_bind.c73 conn_t *connp = tcp->tcp_connp; in tcp_bind_hash_insert() local
91 connp->conn_lport != tcphash->tcp_connp->conn_lport) in tcp_bind_hash_insert()
113 if (V6_OR_V4_INADDR_ANY(connp->conn_bound_addr_v6) && in tcp_bind_hash_insert()
160 conn_t *connp = tcp->tcp_connp; in tcp_bind_hash_remove() local
169 ASSERT(connp->conn_lport != 0); in tcp_bind_hash_remove()
171 connp->conn_lport)].tf_lock; in tcp_bind_hash_remove()
318 conn_t *connp = tcp->tcp_connp; in tcp_bind_select_lport() local
321 in6_addr_t v6addr = connp->conn_laddr_v6; in tcp_bind_select_lport()
343 requested_port = connp->conn_anon_priv_bind ? in tcp_bind_select_lport()
357 if (connp->conn_anon_mlp && is_system_labeled()) { in tcp_bind_select_lport()
[all …]
H A Dtcp_output.c86 conn_t *connp = Q_TO_CONN(q); in tcp_wput() local
94 ASSERT(connp->conn_ref >= 2); in tcp_wput()
98 tcp = connp->conn_tcp; in tcp_wput()
105 if (TCP_UNSENT_BYTES(tcp) > connp->conn_sndbuf) { in tcp_wput()
110 CONN_INC_REF(connp); in tcp_wput()
111 SQUEUE_ENTER_ONE(connp->conn_sqp, mp, tcp_output, connp, in tcp_wput()
124 tcp = connp->conn_tcp; in tcp_wput()
129 if (connp->conn_debug) { in tcp_wput()
173 tcp = connp->conn_tcp; in tcp_wput()
195 CONN_INC_REF(connp); in tcp_wput()
[all …]
H A Dtcp_timers.c136 tcp_timeout(conn_t *connp, void (*f)(void *), hrtime_t tim) in tcp_timeout() argument
140 tcp_t *tcp = connp->conn_tcp; in tcp_timeout()
142 ASSERT(connp->conn_sqp != NULL); in tcp_timeout()
156 CONN_INC_REF(connp); in tcp_timeout()
158 tcpt->connp = connp; in tcp_timeout()
180 conn_t *connp; in tcp_timer_callback() local
183 connp = tcpt->connp; in tcp_timer_callback()
184 SQUEUE_ENTER_ONE(connp->conn_sqp, mp, tcp_timer_handler, connp, in tcp_timer_callback()
193 conn_t *connp = (conn_t *)arg; in tcp_timer_handler() local
194 tcp_t *tcp = connp->conn_tcp; in tcp_timer_handler()
[all …]
H A Dtcp_opt_data.c361 tcp_opt_get(conn_t *connp, int level, int name, uchar_t *ptr) in tcp_opt_get() argument
364 tcp_t *tcp = connp->conn_tcp; in tcp_opt_get()
368 coas.coa_connp = connp; in tcp_opt_get()
369 coas.coa_ixa = connp->conn_ixa; in tcp_opt_get()
370 coas.coa_ipp = &connp->conn_xmit_ipp; in tcp_opt_get()
452 if (connp->conn_family != AF_INET) in tcp_opt_get()
458 return (ip_opt_get_user(connp, ptr)); in tcp_opt_get()
469 if (connp->conn_ipversion != IPV6_VERSION) { in tcp_opt_get()
480 mutex_enter(&connp->conn_lock); in tcp_opt_get()
482 mutex_exit(&connp->conn_lock); in tcp_opt_get()
[all …]
H A Dtcp_time_wait.c257 conn_t *connp = (conn_t *)arg; in tcp_timewait_close() local
258 tcp_t *tcp = connp->conn_tcp; in tcp_timewait_close()
265 ASSERT((connp->conn_family == AF_INET && in tcp_timewait_close()
266 connp->conn_ipversion == IPV4_VERSION) || in tcp_timewait_close()
267 (connp->conn_family == AF_INET6 && in tcp_timewait_close()
268 (connp->conn_ipversion == IPV4_VERSION || in tcp_timewait_close()
269 connp->conn_ipversion == IPV6_VERSION))); in tcp_timewait_close()
294 conn_t *connp; in tcp_time_wait_collector() local
340 connp = tcp->tcp_connp; in tcp_time_wait_collector()
341 ASSERT(connp->conn_fanout != NULL); in tcp_time_wait_collector()
[all …]
H A Dtcp_input.c115 #define SET_TIME_WAIT(tcps, tcp, connp) \ argument
122 (connp)->conn_exclbind = 0; \
194 conn_t *connp = tcp->tcp_connp; in tcp_mss_set() local
196 if (connp->conn_ipversion == IPV4_VERSION) in tcp_mss_set()
216 if ((mss << 2) > connp->conn_sndbuf) in tcp_mss_set()
217 connp->conn_sndbuf = mss << 2; in tcp_mss_set()
222 if ((mss << 1) > connp->conn_sndlowat) in tcp_mss_set()
223 connp->conn_sndlowat = mss << 1; in tcp_mss_set()
408 conn_t *connp = tcp->tcp_connp; in tcp_process_options() local
420 if (connp->conn_ipversion == IPV4_VERSION) in tcp_process_options()
[all …]
/titanic_44/usr/src/uts/common/inet/ilb/
H A Dilb_conn.c129 ilb_conn_remove_common(ilb_conn_t *connp, boolean_t c2s) in ilb_conn_remove_common() argument
136 hash = connp->conn_c2s_hash; in ilb_conn_remove_common()
138 next = &connp->conn_c2s_next; in ilb_conn_remove_common()
139 prev = &connp->conn_c2s_prev; in ilb_conn_remove_common()
145 hash = connp->conn_s2c_hash; in ilb_conn_remove_common()
147 next = &connp->conn_s2c_next; in ilb_conn_remove_common()
148 prev = &connp->conn_s2c_prev; in ilb_conn_remove_common()
155 if (hash->ilb_connp == connp) { in ilb_conn_remove_common()
173 ilb_conn_remove(ilb_conn_t *connp) in ilb_conn_remove() argument
175 ASSERT(MUTEX_HELD(&connp->conn_c2s_hash->ilb_conn_hash_lock)); in ilb_conn_remove()
[all …]
/titanic_44/usr/src/uts/common/inet/sctp/
H A Dsctp_bind.c64 conn_t *connp = sctp->sctp_connp; in sctp_select_port() local
77 crgetzone(connp->conn_cred), sctps); in sctp_select_port()
110 if (secpolicy_net_privaddr(connp->conn_cred, in sctp_select_port()
129 conn_t *connp = sctp->sctp_connp; in sctp_listen() local
148 ss.ss_family = connp->conn_family; in sctp_listen()
158 ASSERT(!(connp->conn_ixa->ixa_free_flags & IXA_FREE_CRED)); in sctp_listen()
159 connp->conn_ixa->ixa_cred = connp->conn_cred; in sctp_listen()
160 connp->conn_ixa->ixa_cpid = connp->conn_cpid; in sctp_listen()
162 connp->conn_ixa->ixa_tsl = crgetlabel(connp->conn_cred); in sctp_listen()
180 ntohs(connp->conn_lport)); in sctp_listen()
[all …]
H A Dsctp.c179 conn_t *connp; in sctp_create_eager() local
183 if ((connp = ipcl_conn_create(IPCL_SCTPCONN, KM_NOSLEEP, in sctp_create_eager()
188 sctp = CONN2SCTP(connp); in sctp_create_eager()
197 sctp_conn_clear(connp); in sctp_create_eager()
199 kmem_cache_free(sctp_conn_cache, connp); in sctp_create_eager()
209 sctp_conn_clear(connp); in sctp_create_eager()
211 kmem_cache_free(sctp_conn_cache, connp); in sctp_create_eager()
216 connp->conn_cred = credp; in sctp_create_eager()
302 conn_t *connp = sctp->sctp_connp; in sctp_disconnect() local
332 if (connp->conn_linger && connp->conn_lingertime == 0) { in sctp_disconnect()
[all …]
/titanic_44/usr/src/cmd/ldmad/
H A Dldmad.c107 ldma_connexion_t *connp; in ldma_connexion_lookup() local
111 for (connp = agent->conn, i = 0; i < LDOMS_MAX_DOMAINS; i++, connp++) { in ldma_connexion_lookup()
112 if (connp->hdl == hdl) in ldma_connexion_lookup()
113 return (connp); in ldma_connexion_lookup()
125 ldma_connexion_t *connp; in ldma_connexion_add() local
130 for (connp = agent->conn, i = 0; i < LDOMS_MAX_DOMAINS; i++, connp++) { in ldma_connexion_add()
131 if (connp->hdl == hdl) in ldma_connexion_add()
133 if (availp == NULL && connp->hdl == DS_INVALID_HDL) in ldma_connexion_add()
134 availp = connp; in ldma_connexion_add()
166 ldma_connexion_t *connp; in ldma_connexion_delete() local
[all …]

123