Lines Matching refs:connp
203 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()
235 ipcl_conn_destroy(connp); in rts_common_close()
242 conn_t *connp = Q_TO_CONN(q); in rts_stream_close() local
244 (void) rts_common_close(q, connp); in rts_stream_close()
257 conn_t *connp; in rts_stream_open() local
276 connp = rts_open(flag, credp); in rts_stream_open()
277 ASSERT(connp != NULL); in rts_stream_open()
281 rts = connp->conn_rts; in rts_stream_open()
283 connp->conn_dev = conn_dev; in rts_stream_open()
284 connp->conn_minor_arena = ip_minor_arena_sa; in rts_stream_open()
286 q->q_ptr = connp; in rts_stream_open()
287 WR(q)->q_ptr = connp; in rts_stream_open()
288 connp->conn_rq = q; in rts_stream_open()
289 connp->conn_wq = WR(q); in rts_stream_open()
291 WR(q)->q_hiwat = connp->conn_sndbuf; in rts_stream_open()
292 WR(q)->q_lowat = connp->conn_sndlowat; in rts_stream_open()
294 mutex_enter(&connp->conn_lock); in rts_stream_open()
295 connp->conn_state_flags &= ~CONN_INCIPIENT; in rts_stream_open()
296 mutex_exit(&connp->conn_lock); in rts_stream_open()
300 ip_rts_register(connp); in rts_stream_open()
314 conn_t *connp; in rts_open() local
331 connp = ipcl_conn_create(IPCL_RTSCONN, KM_SLEEP, ns); in rts_open()
332 rts = connp->conn_rts; in rts_open()
341 ASSERT(connp->conn_rts == rts); in rts_open()
342 ASSERT(rts->rts_connp == connp); in rts_open()
344 connp->conn_ixa->ixa_flags |= IXAF_MULTICAST_LOOP | IXAF_SET_ULP_CKSUM; in rts_open()
346 connp->conn_ixa->ixa_zoneid = zoneid; in rts_open()
347 connp->conn_zoneid = zoneid; in rts_open()
348 connp->conn_flow_cntrld = B_FALSE; in rts_open()
352 connp->conn_rcvbuf = rtss->rtss_recv_hiwat; in rts_open()
353 connp->conn_sndbuf = rtss->rtss_xmit_hiwat; in rts_open()
354 connp->conn_sndlowat = rtss->rtss_xmit_lowat; in rts_open()
355 connp->conn_rcvlowat = rts_mod_info.mi_lowat; in rts_open()
357 connp->conn_family = PF_ROUTE; in rts_open()
358 connp->conn_so_type = SOCK_RAW; in rts_open()
361 connp->conn_recv = rts_input; in rts_open()
362 connp->conn_recvicmp = rts_icmp_input; in rts_open()
365 connp->conn_cred = credp; in rts_open()
366 connp->conn_cpid = curproc->p_pid; in rts_open()
368 ASSERT(!(connp->conn_ixa->ixa_free_flags & IXA_FREE_CRED)); in rts_open()
369 connp->conn_ixa->ixa_cred = connp->conn_cred; in rts_open()
370 connp->conn_ixa->ixa_cpid = connp->conn_cpid; in rts_open()
372 connp->conn_ixa->ixa_tsl = crgetlabel(connp->conn_cred); in rts_open()
382 return (connp); in rts_open()
411 conn_t *connp = Q_TO_CONN(q); in rts_tpi_unbind() local
412 rts_t *rts = connp->conn_rts; in rts_tpi_unbind()
432 conn_t *connp = Q_TO_CONN(q); in rts_tpi_bind() local
433 rts_t *rts = connp->conn_rts; in rts_tpi_bind()
481 conn_t *connp = Q_TO_CONN(q); in rts_capability_req() local
482 rts_t *rts = connp->conn_rts; in rts_capability_req()
512 conn_t *connp = Q_TO_CONN(q); in rts_info_req() local
513 rts_t *rts = connp->conn_rts; in rts_info_req()
537 rts_opt_get(conn_t *connp, int level, int name, uchar_t *ptr) in rts_opt_get() argument
539 rts_t *rts = connp->conn_rts; in rts_opt_get()
550 mutex_enter(&connp->conn_lock); in rts_opt_get()
551 *(int *)ptr = connp->conn_rtaware; in rts_opt_get()
552 mutex_exit(&connp->conn_lock); in rts_opt_get()
557 coas.coa_connp = connp; in rts_opt_get()
558 coas.coa_ixa = connp->conn_ixa; in rts_opt_get()
559 coas.coa_ipp = &connp->conn_xmit_ipp; in rts_opt_get()
560 mutex_enter(&connp->conn_lock); in rts_opt_get()
562 mutex_exit(&connp->conn_lock); in rts_opt_get()
568 rts_do_opt_set(conn_t *connp, int level, int name, uint_t inlen, in rts_do_opt_set() argument
573 rts_t *rts = connp->conn_rts; in rts_do_opt_set()
578 coas.coa_connp = connp; in rts_do_opt_set()
579 coas.coa_ixa = connp->conn_ixa; in rts_do_opt_set()
580 coas.coa_ipp = &connp->conn_xmit_ipp; in rts_do_opt_set()
612 connp->conn_proto = *i1; in rts_do_opt_set()
638 mutex_enter(&connp->conn_lock); in rts_do_opt_set()
639 connp->conn_rtaware = *i1; in rts_do_opt_set()
640 mutex_exit(&connp->conn_lock); in rts_do_opt_set()
666 rts_opt_set(conn_t *connp, uint_t optset_context, int level, int name, in rts_opt_set() argument
713 return (rts_do_opt_set(connp, level, name, inlen, invalp, outlenp, in rts_opt_set()
744 conn_t *connp = Q_TO_CONN(q); in rts_tpi_opt_set() local
746 rts_t *rts = connp->conn_rts; in rts_tpi_opt_set()
750 error = rts_opt_set(connp, optset_context, level, name, inlen, invalp, in rts_tpi_opt_set()
841 conn_t *connp = Q_TO_CONN(q); in rts_wrw() local
842 rts_t *rts = connp->conn_rts; in rts_wrw()
925 conn_t *connp = Q_TO_CONN(q); in rts_wput() local
926 rts_t *rts = connp->conn_rts; in rts_wput()
975 conn_t *connp = Q_TO_CONN(q); in rts_wput_other() local
976 rts_t *rts = connp->conn_rts; in rts_wput_other()
1143 conn_t *connp = (conn_t *)arg1; in rts_input() local
1144 rts_t *rts = connp->conn_rts; in rts_input()
1154 ASSERT(!IPCL_IS_NONSTR(connp)); in rts_input()
1162 qenable(connp->conn_rq); in rts_input()
1189 if (IPCL_IS_NONSTR(connp)) { in rts_input()
1190 if ((*connp->conn_upcalls->su_recv) in rts_input()
1191 (connp->conn_upper_handle, mp, msgdsize(mp), 0, in rts_input()
1199 if ((*connp->conn_upcalls->su_recv) in rts_input()
1200 (connp->conn_upper_handle, NULL, 0, 0, in rts_input()
1203 connp->conn_flow_cntrld = B_TRUE; in rts_input()
1208 putnext(connp->conn_rq, mp); in rts_input()
1352 conn_t *connp = (conn_t *)proto_handle; in rts_getsockopt() local
1353 rts_t *rts = connp->conn_rts; in rts_getsockopt()
1371 len = rts_opt_get(connp, level, option_name, optvalp_buf); in rts_getsockopt()
1393 conn_t *connp = (conn_t *)proto_handle; in rts_setsockopt() local
1394 rts_t *rts = connp->conn_rts; in rts_setsockopt()
1409 error = rts_opt_set(connp, SETFN_OPTCOM_NEGOTIATE, level, option_name, in rts_setsockopt()
1424 conn_t *connp = (conn_t *)proto_handle; in rts_send() local
1450 error = ip_rts_request_common(mp, connp, cr); in rts_send()
1459 conn_t *connp; in rts_create() local
1467 connp = rts_open(flags, credp); in rts_create()
1468 ASSERT(connp != NULL); in rts_create()
1469 connp->conn_flags |= IPCL_NONSTR; in rts_create()
1471 connp->conn_proto = proto; in rts_create()
1473 mutex_enter(&connp->conn_lock); in rts_create()
1474 connp->conn_state_flags &= ~CONN_INCIPIENT; in rts_create()
1475 mutex_exit(&connp->conn_lock); in rts_create()
1480 return ((sock_lower_handle_t)connp); in rts_create()
1488 conn_t *connp = (conn_t *)proto_handle; in rts_activate() local
1491 connp->conn_upcalls = sock_upcalls; in rts_activate()
1492 connp->conn_upper_handle = sock_handle; in rts_activate()
1497 sopp.sopp_rxhiwat = connp->conn_rcvbuf; in rts_activate()
1498 sopp.sopp_rxlowat = connp->conn_rcvlowat; in rts_activate()
1504 (*connp->conn_upcalls->su_set_proto_props) in rts_activate()
1505 (connp->conn_upper_handle, &sopp); in rts_activate()
1510 (*connp->conn_upcalls->su_connected) in rts_activate()
1511 (connp->conn_upper_handle, 0, NULL, -1); in rts_activate()
1514 ip_rts_register(connp); in rts_activate()
1521 conn_t *connp = (conn_t *)proto_handle; in rts_close() local
1523 ASSERT(connp != NULL && IPCL_IS_RTS(connp)); in rts_close()
1524 return (rts_common_close(NULL, connp)); in rts_close()
1531 conn_t *connp = (conn_t *)proto_handle; in rts_shutdown() local
1535 (*connp->conn_upcalls->su_opctl)(connp->conn_upper_handle, in rts_shutdown()
1539 (*connp->conn_upcalls->su_opctl)(connp->conn_upper_handle, in rts_shutdown()
1547 conn_t *connp = (conn_t *)proto_handle; in rts_clr_flowctrl() local
1548 rts_t *rts = connp->conn_rts; in rts_clr_flowctrl()
1551 connp->conn_flow_cntrld = B_FALSE; in rts_clr_flowctrl()
1559 conn_t *connp = (conn_t *)proto_handle; in rts_ioctl() local
1567 if (connp->conn_helper_info == NULL) { in rts_ioctl()
1568 rts_stack_t *rtss = connp->conn_rts->rts_rtss; in rts_ioctl()
1575 error = ip_create_helper_stream(connp, rtss->rtss_ldi_ident); in rts_ioctl()
1598 error = ldi_ioctl(connp->conn_helper_info->iphs_handle, in rts_ioctl()