Home
last modified time | relevance | path

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

123

/illumos-gate/usr/src/uts/common/inet/ip/
H A Dipclassifier.c581 conn_t *connp; in ipcl_conn_create() local
586 if ((connp = kmem_cache_alloc(sctp_conn_cache, sleep)) == NULL) in ipcl_conn_create()
588 sctp_conn_init(connp); in ipcl_conn_create()
590 connp->conn_netstack = ns; in ipcl_conn_create()
591 connp->conn_ixa->ixa_ipst = ns->netstack_ip; in ipcl_conn_create()
592 connp->conn_ixa->ixa_conn_id = (long)connp; in ipcl_conn_create()
593 ipcl_globalhash_insert(connp); in ipcl_conn_create()
594 return (connp); in ipcl_conn_create()
618 connp = NULL; in ipcl_conn_create()
622 if ((connp = kmem_cache_alloc(conn_cache, sleep)) == NULL) in ipcl_conn_create()
[all …]
H A Dicmp.c115 static void icmp_icmp_error_ipv6(conn_t *connp, mblk_t *mp,
125 int icmp_opt_set(conn_t *connp, uint_t optset_context,
129 int icmp_opt_get(conn_t *connp, int level, int name,
131 static int icmp_output_newdst(conn_t *connp, mblk_t *data_mp, sin_t *sin,
319 conn_t *connp = Q_TO_CONN(q); in icmp_tpi_bind() local
337 icmp = connp->conn_icmp; in icmp_tpi_bind()
371 if (connp->conn_family == AF_INET) { in icmp_tpi_bind()
380 ASSERT(connp->conn_family == AF_INET6); in icmp_tpi_bind()
408 error = rawip_do_bind(connp, sa, len); in icmp_tpi_bind()
422 rawip_do_bind(conn_t *connp, struct sockaddr *sa, socklen_t len) in rawip_do_bind() argument
[all …]
H A Dconn_opt.c109 conn_recvancillary_size(conn_t *connp, crb_t recv_ancillary, in conn_recvancillary_size() argument
113 ip_stack_t *ipst = connp->conn_netstack->netstack_ip; in conn_recvancillary_size()
133 connp->conn_family == AF_INET) { in conn_recvancillary_size()
147 ip_stack_t *ipst = connp->conn_netstack->netstack_ip; in conn_recvancillary_size()
174 connp->conn_family == AF_INET6) { in conn_recvancillary_size()
268 conn_recvancillary_add(conn_t *connp, crb_t recv_ancillary, in conn_recvancillary_add() argument
297 connp->conn_family == AF_INET) { in conn_recvancillary_add()
298 ip_stack_t *ipst = connp->conn_netstack->netstack_ip; in conn_recvancillary_add()
318 ipif = ipif_good_addr(ill, IPCL_ZONEID(connp)); in conn_recvancillary_add()
348 ip_stack_t *ipst = connp->conn_netstack->netstack_ip; in conn_recvancillary_add()
[all …]
H A Drts.c204 rts_common_close(queue_t *q, conn_t *connp) in rts_common_close() argument
207 ASSERT(connp != NULL && IPCL_IS_RTS(connp)); in rts_common_close()
209 ip_rts_unregister(connp); in rts_common_close()
211 ip_quiesce_conn(connp); in rts_common_close()
213 if (!IPCL_IS_NONSTR(connp)) { in rts_common_close()
227 ASSERT(connp->conn_ref == 1); in rts_common_close()
229 if (!IPCL_IS_NONSTR(connp)) { in rts_common_close()
230 inet_minor_free(connp->conn_minor_arena, connp->conn_dev); in rts_common_close()
232 ip_free_helper_stream(connp); in rts_common_close()
235 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.c758 conn_get_ixa_impl(conn_t *connp, boolean_t replace, int kmflag) in conn_get_ixa_impl() argument
769 mutex_enter(&connp->conn_lock); in conn_get_ixa_impl()
770 oldixa = connp->conn_ixa; in conn_get_ixa_impl()
776 mutex_exit(&connp->conn_lock); in conn_get_ixa_impl()
782 mutex_exit(&connp->conn_lock); in conn_get_ixa_impl()
791 connp->conn_ixa = ixa; in conn_get_ixa_impl()
792 mutex_exit(&connp->conn_lock); in conn_get_ixa_impl()
795 mutex_exit(&connp->conn_lock); in conn_get_ixa_impl()
817 conn_get_ixa(conn_t *connp, boolean_t replace) in conn_get_ixa() argument
819 return (conn_get_ixa_impl(connp, replace, KM_NOSLEEP)); in conn_get_ixa()
[all …]
/illumos-gate/usr/src/uts/common/inet/udp/
H A Dudp.c147 static void udp_icmp_error_ipv6(conn_t *connp, mblk_t *mp,
160 int udp_opt_set(conn_t *connp, uint_t optset_context,
164 int udp_opt_get(conn_t *connp, int level, int name,
166 static int udp_output_connected(conn_t *connp, mblk_t *mp, cred_t *cr,
168 static int udp_output_lastdst(conn_t *connp, mblk_t *mp, cred_t *cr,
170 static int udp_output_newdst(conn_t *connp, mblk_t *data_mp, sin_t *sin,
477 conn_t *connp = udp->udp_connp; in udp_bind_hash_remove() local
486 ASSERT(connp->conn_lport != 0); in udp_bind_hash_remove()
488 lockp = &us->us_bind_fanout[UDP_BIND_HASH(connp->conn_lport, in udp_bind_hash_remove()
510 conn_t *connp = udp->udp_connp; in udp_bind_hash_insert() local
[all …]
H A Dudp_stats.c80 conn_t *connp = Q_TO_CONN(q); in udp_snmp_get() local
85 ip_stack_t *ipst = connp->conn_netstack->netstack_ip; in udp_snmp_get()
86 udp_stack_t *us = connp->conn_netstack->netstack_udp; in udp_snmp_get()
121 zoneid = connp->conn_zoneid; in udp_snmp_get()
162 connp = NULL; in udp_snmp_get()
164 while ((connp = ipcl_get_next_conn(connfp, connp, in udp_snmp_get()
166 sonode_t *so = (sonode_t *)connp->conn_upper_handle; in udp_snmp_get()
168 udp = connp->conn_udp; in udp_snmp_get()
169 if (zoneid != connp->conn_zoneid) in udp_snmp_get()
188 if (connp->conn_mlp_type != mlptSingle) { in udp_snmp_get()
[all …]
/illumos-gate/usr/src/uts/common/inet/
H A Dipclassifier.h100 #define IPCL_IS_CONNECTED(connp) \ argument
101 ((connp)->conn_flags & IPCL_CONNECTED)
103 #define IPCL_IS_BOUND(connp) \ argument
104 ((connp)->conn_flags & IPCL_BOUND)
110 #define IPCL_IS_TCP(connp) \ argument
111 ((connp)->conn_flags & IPCL_TCPCONN)
113 #define IPCL_IS_SCTP(connp) \ argument
114 ((connp)->conn_flags & IPCL_SCTPCONN)
116 #define IPCL_IS_UDP(connp) \ argument
117 ((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.c217 #define SQUEUE_DBG_SET(sqp, mp, proc, connp, tag) { \ argument
220 (sqp)->sq_connp = (connp); \
230 #define SQUEUE_DBG_SET(sqp, mp, proc, connp, tag) argument
333 conn_t *connp; in squeue_enter() local
372 connp = (conn_t *)mp->b_prev; in squeue_enter()
376 ASSERT(proc != NULL && connp != NULL); in squeue_enter()
383 if (connp->conn_sqp == sqp) { in squeue_enter()
384 SQUEUE_DBG_SET(sqp, mp, proc, connp, in squeue_enter()
386 connp->conn_on_sqp = B_TRUE; in squeue_enter()
388 sqp, mblk_t *, mp, conn_t *, connp); in squeue_enter()
[all …]
/illumos-gate/usr/src/uts/common/inet/tcp/
H A Dtcp.c428 conn_t *connp = tcp->tcp_connp; in tcp_set_recv_threshold() local
440 (*connp->conn_upcalls->su_set_proto_props) in tcp_set_recv_threshold()
441 (connp->conn_upper_handle, &sopp); in tcp_set_recv_threshold()
471 conn_t *connp = tcp->tcp_connp; in tcp_ipsec_cleanup() local
473 ASSERT(connp->conn_flags & IPCL_TCPCONN); in tcp_ipsec_cleanup()
475 if (connp->conn_latch != NULL) { in tcp_ipsec_cleanup()
476 IPLATCH_REFRELE(connp->conn_latch); in tcp_ipsec_cleanup()
477 connp->conn_latch = NULL; in tcp_ipsec_cleanup()
479 if (connp->conn_latch_in_policy != NULL) { in tcp_ipsec_cleanup()
480 IPPOL_REFRELE(connp->conn_latch_in_policy); in tcp_ipsec_cleanup()
[all …]
H A Dtcp_socket.c99 conn_t *connp = (conn_t *)proto_handle; in tcp_activate() local
103 ASSERT(connp->conn_upper_handle == NULL); in tcp_activate()
122 connp->conn_upcalls = sock_upcalls; in tcp_activate()
123 connp->conn_upper_handle = sock_handle; in tcp_activate()
125 ASSERT(connp->conn_rcvbuf != 0 && in tcp_activate()
126 connp->conn_rcvbuf == connp->conn_tcp->tcp_rwnd); in tcp_activate()
203 conn_t *connp = (conn_t *)proto_handle; in tcp_bind() local
207 ASSERT(connp->conn_upper_handle != NULL); in tcp_bind()
209 error = squeue_synch_enter(connp, NULL); in tcp_bind()
217 if (connp->conn_tcp->tcp_state < TCPS_LISTEN) in tcp_bind()
[all …]
H A Dtcp_bind.c75 conn_t *connp = tcp->tcp_connp; in tcp_bind_hash_insert() local
93 connp->conn_lport != tcphash->tcp_connp->conn_lport) in tcp_bind_hash_insert()
115 if (V6_OR_V4_INADDR_ANY(connp->conn_bound_addr_v6) && in tcp_bind_hash_insert()
162 conn_t *connp = tcp->tcp_connp; in tcp_bind_hash_remove() local
171 ASSERT(connp->conn_lport != 0); in tcp_bind_hash_remove()
173 connp->conn_lport)].tf_lock; in tcp_bind_hash_remove()
320 conn_t *connp = tcp->tcp_connp; in tcp_bind_select_lport() local
323 in6_addr_t v6addr = connp->conn_laddr_v6; in tcp_bind_select_lport()
346 requested_port = connp->conn_anon_priv_bind ? in tcp_bind_select_lport()
360 if (connp->conn_anon_mlp && is_system_labeled()) { in tcp_bind_select_lport()
[all …]
H A Dtcp_output.c101 conn_t *connp = Q_TO_CONN(q); in tcp_wput() local
109 ASSERT(connp->conn_ref >= 2); in tcp_wput()
113 tcp = connp->conn_tcp; in tcp_wput()
120 if (TCP_UNSENT_BYTES(tcp) > connp->conn_sndbuf) { in tcp_wput()
125 CONN_INC_REF(connp); in tcp_wput()
126 SQUEUE_ENTER_ONE(connp->conn_sqp, mp, tcp_output, connp, in tcp_wput()
139 tcp = connp->conn_tcp; in tcp_wput()
144 if (connp->conn_debug) { in tcp_wput()
188 tcp = connp->conn_tcp; in tcp_wput()
210 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.c379 tcp_opt_get(conn_t *connp, int level, int name, uchar_t *ptr) in tcp_opt_get() argument
382 tcp_t *tcp = connp->conn_tcp; in tcp_opt_get()
386 coas.coa_connp = connp; in tcp_opt_get()
387 coas.coa_ixa = connp->conn_ixa; in tcp_opt_get()
388 coas.coa_ipp = &connp->conn_xmit_ipp; in tcp_opt_get()
483 if (connp->conn_family != AF_INET) in tcp_opt_get()
489 return (ip_opt_get_user(connp, ptr)); in tcp_opt_get()
500 if (connp->conn_ipversion != IPV6_VERSION) { in tcp_opt_get()
511 mutex_enter(&connp->conn_lock); in tcp_opt_get()
513 mutex_exit(&connp->conn_lock); in tcp_opt_get()
[all …]
H A Dtcp_input.c109 #define SET_TIME_WAIT(tcps, tcp, connp) \ argument
116 (connp)->conn_exclbind = 0; \
315 conn_t *connp = tcp->tcp_connp; in tcp_mss_set() local
317 if (connp->conn_ipversion == IPV4_VERSION) in tcp_mss_set()
337 if ((mss << 2) > connp->conn_sndbuf) in tcp_mss_set()
338 connp->conn_sndbuf = mss << 2; in tcp_mss_set()
343 if ((mss << 1) > connp->conn_sndlowat) in tcp_mss_set()
344 connp->conn_sndlowat = mss << 1; in tcp_mss_set()
554 conn_t *connp = tcp->tcp_connp; in tcp_process_options() local
594 if (connp->conn_ipversion == IPV4_VERSION) in tcp_process_options()
[all …]
H A Dtcp_cluster.c105 conn_t *connp; in cl_tcp_walk_list_stack() local
113 connp = NULL; in cl_tcp_walk_list_stack()
115 while ((connp = in cl_tcp_walk_list_stack()
116 ipcl_get_next_conn(connfp, connp, IPCL_TCPCONN)) != NULL) { in cl_tcp_walk_list_stack()
118 tcp = connp->conn_tcp; in cl_tcp_walk_list_stack()
120 cl_tcpi.cl_tcpi_ipversion = connp->conn_ipversion; in cl_tcp_walk_list_stack()
122 cl_tcpi.cl_tcpi_lport = connp->conn_lport; in cl_tcp_walk_list_stack()
123 cl_tcpi.cl_tcpi_fport = connp->conn_fport; in cl_tcp_walk_list_stack()
124 cl_tcpi.cl_tcpi_laddr_v6 = connp->conn_laddr_v6; in cl_tcp_walk_list_stack()
125 cl_tcpi.cl_tcpi_faddr_v6 = connp->conn_faddr_v6; in cl_tcp_walk_list_stack()
/illumos-gate/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
139 hash = connp->conn_c2s_hash; in ilb_conn_remove_common()
141 next = &connp->conn_c2s_next; in ilb_conn_remove_common()
142 prev = &connp->conn_c2s_prev; in ilb_conn_remove_common()
148 hash = connp->conn_s2c_hash; in ilb_conn_remove_common()
150 next = &connp->conn_s2c_next; in ilb_conn_remove_common()
151 prev = &connp->conn_s2c_prev; in ilb_conn_remove_common()
158 if (hash->ilb_connp == connp) { in ilb_conn_remove_common()
176 ilb_conn_remove(ilb_conn_t *connp) in ilb_conn_remove() argument
178 ASSERT(MUTEX_HELD(&connp->conn_c2s_hash->ilb_conn_hash_lock)); in ilb_conn_remove()
[all …]
/illumos-gate/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 …]
/illumos-gate/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