Lines Matching refs:connp
99 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()
218 error = tcp_do_unbind(connp); in tcp_bind()
222 error = tcp_do_bind(connp, sa, len, cr, B_TRUE); in tcp_bind()
225 squeue_synch_exit(connp, SQ_NODRAIN); in tcp_bind()
241 conn_t *connp = (conn_t *)proto_handle; in tcp_listen() local
242 tcp_t *tcp = connp->conn_tcp; in tcp_listen()
245 ASSERT(connp->conn_upper_handle != NULL); in tcp_listen()
250 error = squeue_synch_enter(connp, NULL); in tcp_listen()
256 error = tcp_do_listen(connp, NULL, 0, backlog, cr, B_FALSE); in tcp_listen()
262 (*connp->conn_upcalls->su_opctl)(connp->conn_upper_handle, in tcp_listen()
272 squeue_synch_exit(connp, SQ_NODRAIN); in tcp_listen()
280 conn_t *connp = (conn_t *)proto_handle; in tcp_connect() local
283 ASSERT(connp->conn_upper_handle != NULL); in tcp_connect()
288 error = proto_verify_ip_addr(connp->conn_family, sa, len); in tcp_connect()
293 error = squeue_synch_enter(connp, NULL); in tcp_connect()
302 error = tcp_do_connect(connp, sa, len, cr, curproc->p_pid); in tcp_connect()
304 *id = connp->conn_tcp->tcp_connid; in tcp_connect()
307 switch (connp->conn_tcp->tcp_state) { in tcp_connect()
326 if (connp->conn_tcp->tcp_loopback) { in tcp_connect()
332 (*connp->conn_upcalls->su_set_proto_props)( in tcp_connect()
333 connp->conn_upper_handle, &sopp); in tcp_connect()
342 squeue_synch_exit(connp, SQ_PROCESS); in tcp_connect()
352 conn_t *connp = (conn_t *)proto_handle; in tcp_getpeername() local
353 tcp_t *tcp = connp->conn_tcp; in tcp_getpeername()
362 return (conn_getpeername(connp, addr, addrlenp)); in tcp_getpeername()
370 conn_t *connp = (conn_t *)proto_handle; in tcp_getsockname() local
375 return (conn_getsockname(connp, addr, addrlenp)); in tcp_getsockname()
383 conn_t *connp = (conn_t *)proto_handle; in tcp_getsockopt() local
389 ASSERT(connp->conn_upper_handle != NULL); in tcp_getsockopt()
404 error = squeue_synch_enter(connp, NULL); in tcp_getsockopt()
410 len = tcp_opt_get(connp, level, option_name, optvalp_buf); in tcp_getsockopt()
411 squeue_synch_exit(connp, SQ_NODRAIN); in tcp_getsockopt()
434 conn_t *connp = (conn_t *)proto_handle; in tcp_setsockopt() local
437 ASSERT(connp->conn_upper_handle != NULL); in tcp_setsockopt()
448 mutex_enter(&connp->conn_tcp->tcp_non_sq_lock); in tcp_setsockopt()
449 connp->conn_tcp->tcp_naglim = *(int *)optvalp ? 1 : in tcp_setsockopt()
450 connp->conn_tcp->tcp_mss; in tcp_setsockopt()
451 mutex_exit(&connp->conn_tcp->tcp_non_sq_lock); in tcp_setsockopt()
458 error = squeue_synch_enter(connp, NULL); in tcp_setsockopt()
472 squeue_synch_exit(connp, SQ_NODRAIN); in tcp_setsockopt()
476 error = tcp_opt_set(connp, SETFN_OPTCOM_NEGOTIATE, level, option_name, in tcp_setsockopt()
479 squeue_synch_exit(connp, SQ_NODRAIN); in tcp_setsockopt()
493 conn_t *connp = (conn_t *)proto_handle; in tcp_sendmsg() local
499 ASSERT(connp->conn_ref >= 2); in tcp_sendmsg()
500 ASSERT(connp->conn_upper_handle != NULL); in tcp_sendmsg()
509 tcp = connp->conn_tcp; in tcp_sendmsg()
535 if (TCP_UNSENT_BYTES(tcp) > connp->conn_sndbuf) { in tcp_sendmsg()
549 CONN_INC_REF(connp); in tcp_sendmsg()
552 SQUEUE_ENTER_ONE(connp->conn_sqp, mp, tcp_output_urgent, in tcp_sendmsg()
553 connp, NULL, tcp_squeue_flag, SQTAG_TCP_OUTPUT); in tcp_sendmsg()
555 SQUEUE_ENTER_ONE(connp->conn_sqp, mp, tcp_output, in tcp_sendmsg()
556 connp, NULL, tcp_squeue_flag, SQTAG_TCP_OUTPUT); in tcp_sendmsg()
573 conn_t *connp = (conn_t *)proto_handle; in tcp_shutdown() local
574 tcp_t *tcp = connp->conn_tcp; in tcp_shutdown()
576 ASSERT(connp->conn_upper_handle != NULL); in tcp_shutdown()
592 CONN_INC_REF(connp); in tcp_shutdown()
593 SQUEUE_ENTER_ONE(connp->conn_sqp, bp, tcp_shutdown_output, in tcp_shutdown()
594 connp, NULL, SQ_NODRAIN, SQTAG_TCP_SHUTDOWN_OUTPUT); in tcp_shutdown()
596 (*connp->conn_upcalls->su_opctl)(connp->conn_upper_handle, in tcp_shutdown()
602 (*connp->conn_upcalls->su_opctl)(connp->conn_upper_handle, in tcp_shutdown()
611 conn_t *connp = (conn_t *)proto_handle; in tcp_clr_flowctrl() local
612 tcp_t *tcp = connp->conn_tcp; in tcp_clr_flowctrl()
616 ASSERT(connp->conn_upper_handle != NULL); in tcp_clr_flowctrl()
630 error = squeue_synch_enter(connp, mp); in tcp_clr_flowctrl()
640 tcp->tcp_rwnd = connp->conn_rcvbuf; in tcp_clr_flowctrl()
655 squeue_synch_exit(connp, SQ_NODRAIN); in tcp_clr_flowctrl()
663 conn_t *connp = (conn_t *)proto_handle; in tcp_ioctl() local
666 ASSERT(connp->conn_upper_handle != NULL); in tcp_ioctl()
676 if (connp->conn_helper_info == NULL) { in tcp_ioctl()
677 tcp_stack_t *tcps = connp->conn_tcp->tcp_tcps; in tcp_ioctl()
682 error = ip_create_helper_stream(connp, tcps->tcps_ldi_ident); in tcp_ioctl()
708 mutex_enter(&connp->conn_lock); in tcp_ioctl()
709 if (connp->conn_state_flags & (CONN_CLOSING)) { in tcp_ioctl()
710 mutex_exit(&connp->conn_lock); in tcp_ioctl()
714 CONN_INC_IOCTLREF_LOCKED(connp); in tcp_ioctl()
715 error = ldi_ioctl(connp->conn_helper_info->iphs_handle, in tcp_ioctl()
717 CONN_DEC_IOCTLREF(connp); in tcp_ioctl()
727 conn_t *connp = (conn_t *)proto_handle; in tcp_close() local
729 ASSERT(connp->conn_upper_handle != NULL); in tcp_close()
734 tcp_close_common(connp, flags); in tcp_close()
736 ip_free_helper_stream(connp); in tcp_close()
750 CONN_DEC_REF(connp); in tcp_close()
764 conn_t *connp; in tcp_create() local
773 connp = tcp_create_common(credp, isv6, B_TRUE, errorp); in tcp_create()
774 if (connp == NULL) { in tcp_create()
783 mutex_enter(&connp->conn_lock); in tcp_create()
784 CONN_INC_REF_LOCKED(connp); in tcp_create()
785 ASSERT(connp->conn_ref == 2); in tcp_create()
786 connp->conn_state_flags &= ~CONN_INCIPIENT; in tcp_create()
788 connp->conn_flags |= IPCL_NONSTR; in tcp_create()
789 mutex_exit(&connp->conn_lock); in tcp_create()
797 return ((sock_lower_handle_t)connp); in tcp_create()
824 conn_t *connp = tcp->tcp_connp; in tcp_fallback_noneager() local
833 connp->conn_dev = (dev_t)RD(q)->q_ptr; in tcp_fallback_noneager()
834 connp->conn_minor_arena = WR(q)->q_ptr; in tcp_fallback_noneager()
836 RD(q)->q_ptr = WR(q)->q_ptr = connp; in tcp_fallback_noneager()
838 connp->conn_rq = RD(q); in tcp_fallback_noneager()
839 connp->conn_wq = WR(q); in tcp_fallback_noneager()
849 ip_free_helper_stream(connp); in tcp_fallback_noneager()
859 stropt->so_wroff = connp->conn_ht_iphc_len + (tcp->tcp_loopback ? 0 : in tcp_fallback_noneager()
863 stropt->so_hiwat = connp->conn_rcvbuf; in tcp_fallback_noneager()
874 (void) tcp_getsockname((sock_lower_handle_t)connp, in tcp_fallback_noneager()
876 error = tcp_getpeername((sock_lower_handle_t)connp, in tcp_fallback_noneager()
882 if (connp->conn_oobinline) in tcp_fallback_noneager()
884 if (connp->conn_ixa->ixa_flags & IXAF_DONTROUTE) in tcp_fallback_noneager()
892 mp = (*quiesced_cb)(connp->conn_upper_handle, arg, &tca, in tcp_fallback_noneager()
925 conn_t *connp = eager->tcp_connp; in tcp_fallback_eager() local
936 mp = (*quiesced_cb)(connp->conn_upper_handle, arg, NULL, NULL, 0, in tcp_fallback_eager()
966 connp->conn_rq = listener->tcp_connp->conn_rq; in tcp_fallback_eager()
967 connp->conn_wq = listener->tcp_connp->conn_wq; in tcp_fallback_eager()
1002 conn_t *connp = (conn_t *)proto_handle; in tcp_fallback() local
1007 tcp = connp->conn_tcp; in tcp_fallback()
1023 error = squeue_synch_enter(connp, NULL); in tcp_fallback()
1054 connp->conn_flags &= ~IPCL_NONSTR; in tcp_fallback()
1060 ASSERT(connp->conn_ref >= 2); in tcp_fallback()
1061 squeue_synch_exit(connp, SQ_NODRAIN); in tcp_fallback()