Lines Matching refs:connp

204 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()
236 ipcl_conn_destroy(connp); in rts_common_close()
244 conn_t *connp = Q_TO_CONN(q); in rts_stream_close() local
246 (void) rts_common_close(q, connp); in rts_stream_close()
259 conn_t *connp; in rts_stream_open() local
278 connp = rts_open(flag, credp); in rts_stream_open()
279 ASSERT(connp != NULL); in rts_stream_open()
283 rts = connp->conn_rts; in rts_stream_open()
285 connp->conn_dev = conn_dev; in rts_stream_open()
286 connp->conn_minor_arena = ip_minor_arena_sa; in rts_stream_open()
288 q->q_ptr = connp; in rts_stream_open()
289 WR(q)->q_ptr = connp; in rts_stream_open()
290 connp->conn_rq = q; in rts_stream_open()
291 connp->conn_wq = WR(q); in rts_stream_open()
293 WR(q)->q_hiwat = connp->conn_sndbuf; in rts_stream_open()
294 WR(q)->q_lowat = connp->conn_sndlowat; in rts_stream_open()
296 mutex_enter(&connp->conn_lock); in rts_stream_open()
297 connp->conn_state_flags &= ~CONN_INCIPIENT; in rts_stream_open()
298 mutex_exit(&connp->conn_lock); in rts_stream_open()
302 ip_rts_register(connp); in rts_stream_open()
316 conn_t *connp; in rts_open() local
333 connp = ipcl_conn_create(IPCL_RTSCONN, KM_SLEEP, ns); in rts_open()
334 rts = connp->conn_rts; in rts_open()
343 ASSERT(connp->conn_rts == rts); in rts_open()
344 ASSERT(rts->rts_connp == connp); in rts_open()
346 connp->conn_ixa->ixa_flags |= IXAF_MULTICAST_LOOP | IXAF_SET_ULP_CKSUM; in rts_open()
348 connp->conn_ixa->ixa_zoneid = zoneid; in rts_open()
349 connp->conn_zoneid = zoneid; in rts_open()
350 connp->conn_flow_cntrld = B_FALSE; in rts_open()
354 connp->conn_rcvbuf = rtss->rtss_recv_hiwat; in rts_open()
355 connp->conn_sndbuf = rtss->rtss_xmit_hiwat; in rts_open()
356 connp->conn_sndlowat = rtss->rtss_xmit_lowat; in rts_open()
357 connp->conn_rcvlowat = rts_mod_info.mi_lowat; in rts_open()
359 connp->conn_family = PF_ROUTE; in rts_open()
360 connp->conn_so_type = SOCK_RAW; in rts_open()
363 connp->conn_recv = rts_input; in rts_open()
364 connp->conn_recvicmp = rts_icmp_input; in rts_open()
367 connp->conn_cred = credp; in rts_open()
368 connp->conn_cpid = curproc->p_pid; in rts_open()
370 ASSERT(!(connp->conn_ixa->ixa_free_flags & IXA_FREE_CRED)); in rts_open()
371 connp->conn_ixa->ixa_cred = connp->conn_cred; in rts_open()
372 connp->conn_ixa->ixa_cpid = connp->conn_cpid; in rts_open()
374 connp->conn_ixa->ixa_tsl = crgetlabel(connp->conn_cred); in rts_open()
384 return (connp); in rts_open()
413 conn_t *connp = Q_TO_CONN(q); in rts_tpi_unbind() local
414 rts_t *rts = connp->conn_rts; in rts_tpi_unbind()
434 conn_t *connp = Q_TO_CONN(q); in rts_tpi_bind() local
435 rts_t *rts = connp->conn_rts; in rts_tpi_bind()
483 conn_t *connp = Q_TO_CONN(q); in rts_capability_req() local
484 rts_t *rts = connp->conn_rts; in rts_capability_req()
514 conn_t *connp = Q_TO_CONN(q); in rts_info_req() local
515 rts_t *rts = connp->conn_rts; in rts_info_req()
539 rts_opt_get(conn_t *connp, int level, int name, uchar_t *ptr) in rts_opt_get() argument
541 rts_t *rts = connp->conn_rts; in rts_opt_get()
552 mutex_enter(&connp->conn_lock); in rts_opt_get()
553 *(int *)ptr = connp->conn_rtaware; in rts_opt_get()
554 mutex_exit(&connp->conn_lock); in rts_opt_get()
559 coas.coa_connp = connp; in rts_opt_get()
560 coas.coa_ixa = connp->conn_ixa; in rts_opt_get()
561 coas.coa_ipp = &connp->conn_xmit_ipp; in rts_opt_get()
562 mutex_enter(&connp->conn_lock); in rts_opt_get()
564 mutex_exit(&connp->conn_lock); in rts_opt_get()
570 rts_do_opt_set(conn_t *connp, int level, int name, uint_t inlen, in rts_do_opt_set() argument
575 rts_t *rts = connp->conn_rts; in rts_do_opt_set()
580 coas.coa_connp = connp; in rts_do_opt_set()
581 coas.coa_ixa = connp->conn_ixa; in rts_do_opt_set()
582 coas.coa_ipp = &connp->conn_xmit_ipp; in rts_do_opt_set()
614 connp->conn_proto = *i1; in rts_do_opt_set()
640 mutex_enter(&connp->conn_lock); in rts_do_opt_set()
641 connp->conn_rtaware = *i1; in rts_do_opt_set()
642 mutex_exit(&connp->conn_lock); in rts_do_opt_set()
668 rts_opt_set(conn_t *connp, uint_t optset_context, int level, int name, in rts_opt_set() argument
715 return (rts_do_opt_set(connp, level, name, inlen, invalp, outlenp, in rts_opt_set()
746 conn_t *connp = Q_TO_CONN(q); in rts_tpi_opt_set() local
748 rts_t *rts = connp->conn_rts; in rts_tpi_opt_set()
752 error = rts_opt_set(connp, optset_context, level, name, inlen, invalp, in rts_tpi_opt_set()
844 conn_t *connp = Q_TO_CONN(q); in rts_wrw() local
845 rts_t *rts = connp->conn_rts; in rts_wrw()
928 conn_t *connp = Q_TO_CONN(q); in rts_wput() local
929 rts_t *rts = connp->conn_rts; in rts_wput()
979 conn_t *connp = Q_TO_CONN(q); in rts_wput_other() local
980 rts_t *rts = connp->conn_rts; in rts_wput_other()
1148 conn_t *connp = (conn_t *)arg1; in rts_input() local
1149 rts_t *rts = connp->conn_rts; in rts_input()
1159 ASSERT(!IPCL_IS_NONSTR(connp)); in rts_input()
1167 qenable(connp->conn_rq); in rts_input()
1194 if (IPCL_IS_NONSTR(connp)) { in rts_input()
1195 if ((*connp->conn_upcalls->su_recv) in rts_input()
1196 (connp->conn_upper_handle, mp, msgdsize(mp), 0, in rts_input()
1204 if ((*connp->conn_upcalls->su_recv) in rts_input()
1205 (connp->conn_upper_handle, NULL, 0, 0, in rts_input()
1208 connp->conn_flow_cntrld = B_TRUE; in rts_input()
1213 putnext(connp->conn_rq, mp); in rts_input()
1357 conn_t *connp = (conn_t *)proto_handle; in rts_getsockopt() local
1358 rts_t *rts = connp->conn_rts; in rts_getsockopt()
1376 len = rts_opt_get(connp, level, option_name, optvalp_buf); in rts_getsockopt()
1398 conn_t *connp = (conn_t *)proto_handle; in rts_setsockopt() local
1399 rts_t *rts = connp->conn_rts; in rts_setsockopt()
1414 error = rts_opt_set(connp, SETFN_OPTCOM_NEGOTIATE, level, option_name, in rts_setsockopt()
1429 conn_t *connp = (conn_t *)proto_handle; in rts_send() local
1455 error = ip_rts_request_common(mp, connp, cr); in rts_send()
1464 conn_t *connp; in rts_create() local
1472 connp = rts_open(flags, credp); in rts_create()
1473 ASSERT(connp != NULL); in rts_create()
1474 connp->conn_flags |= IPCL_NONSTR; in rts_create()
1476 connp->conn_proto = proto; in rts_create()
1478 mutex_enter(&connp->conn_lock); in rts_create()
1479 connp->conn_state_flags &= ~CONN_INCIPIENT; in rts_create()
1480 mutex_exit(&connp->conn_lock); in rts_create()
1485 return ((sock_lower_handle_t)connp); in rts_create()
1493 conn_t *connp = (conn_t *)proto_handle; in rts_activate() local
1496 connp->conn_upcalls = sock_upcalls; in rts_activate()
1497 connp->conn_upper_handle = sock_handle; in rts_activate()
1502 sopp.sopp_rxhiwat = connp->conn_rcvbuf; in rts_activate()
1503 sopp.sopp_rxlowat = connp->conn_rcvlowat; in rts_activate()
1509 (*connp->conn_upcalls->su_set_proto_props) in rts_activate()
1510 (connp->conn_upper_handle, &sopp); in rts_activate()
1515 (*connp->conn_upcalls->su_connected) in rts_activate()
1516 (connp->conn_upper_handle, 0, NULL, -1); in rts_activate()
1519 ip_rts_register(connp); in rts_activate()
1526 conn_t *connp = (conn_t *)proto_handle; in rts_close() local
1528 ASSERT(connp != NULL && IPCL_IS_RTS(connp)); in rts_close()
1529 return (rts_common_close(NULL, connp)); in rts_close()
1536 conn_t *connp = (conn_t *)proto_handle; in rts_shutdown() local
1540 (*connp->conn_upcalls->su_opctl)(connp->conn_upper_handle, in rts_shutdown()
1544 (*connp->conn_upcalls->su_opctl)(connp->conn_upper_handle, in rts_shutdown()
1552 conn_t *connp = (conn_t *)proto_handle; in rts_clr_flowctrl() local
1553 rts_t *rts = connp->conn_rts; in rts_clr_flowctrl()
1556 connp->conn_flow_cntrld = B_FALSE; in rts_clr_flowctrl()
1564 conn_t *connp = (conn_t *)proto_handle; in rts_ioctl() local
1572 if (connp->conn_helper_info == NULL) { in rts_ioctl()
1573 rts_stack_t *rtss = connp->conn_rts->rts_rtss; in rts_ioctl()
1580 error = ip_create_helper_stream(connp, rtss->rtss_ldi_ident); in rts_ioctl()
1603 error = ldi_ioctl(connp->conn_helper_info->iphs_handle, in rts_ioctl()