Lines Matching refs:rts
259 rts_t *rts; in rts_stream_open() local
281 rts = connp->conn_rts; in rts_stream_open()
282 rw_enter(&rts->rts_rwlock, RW_WRITER); in rts_stream_open()
297 rw_exit(&rts->rts_rwlock); in rts_stream_open()
313 rts_t *rts; in rts_open() local
332 rts = connp->conn_rts; in rts_open()
340 rw_enter(&rts->rts_rwlock, RW_WRITER); in rts_open()
341 ASSERT(connp->conn_rts == rts); in rts_open()
342 ASSERT(rts->rts_connp == connp); in rts_open()
350 rts->rts_rtss = rtss; in rts_open()
379 rts->rts_state = TS_DATA_XFER; in rts_open()
380 rw_exit(&rts->rts_rwlock); in rts_open()
412 rts_t *rts = connp->conn_rts; in rts_tpi_unbind() local
415 if (rts->rts_state != TS_IDLE) { in rts_tpi_unbind()
419 rts->rts_state = TS_UNBND; in rts_tpi_unbind()
433 rts_t *rts = connp->conn_rts; in rts_tpi_bind() local
438 "rts_tpi_bind: bad data, %d", rts->rts_state); in rts_tpi_bind()
442 if (rts->rts_state != TS_UNBND) { in rts_tpi_bind()
444 "rts_tpi_bind: bad state, %d", rts->rts_state); in rts_tpi_bind()
460 rts->rts_state = TS_IDLE; in rts_tpi_bind()
465 rts_copy_info(struct T_info_ack *tap, rts_t *rts) in rts_copy_info() argument
468 tap->CURRENT_state = rts->rts_state; in rts_copy_info()
482 rts_t *rts = connp->conn_rts; in rts_capability_req() local
497 rts_copy_info(&tcap->INFO_ack, rts); in rts_capability_req()
513 rts_t *rts = connp->conn_rts; in rts_info_req() local
519 rts_copy_info((struct T_info_ack *)mp->b_rptr, rts); in rts_info_req()
539 rts_t *rts = connp->conn_rts; in rts_opt_get() local
543 ASSERT(RW_READ_HELD(&rts->rts_rwlock)); in rts_opt_get()
573 rts_t *rts = connp->conn_rts; in rts_do_opt_set() local
574 rts_stack_t *rtss = rts->rts_rtss; in rts_do_opt_set()
582 ASSERT(RW_WRITE_HELD(&rts->rts_rwlock)); in rts_do_opt_set()
725 rts_t *rts; in rts_tpi_opt_get() local
728 rts = Q_TO_RTS(q); in rts_tpi_opt_get()
729 rw_enter(&rts->rts_rwlock, RW_READER); in rts_tpi_opt_get()
731 rw_exit(&rts->rts_rwlock); in rts_tpi_opt_get()
746 rts_t *rts = connp->conn_rts; in rts_tpi_opt_set() local
749 rw_enter(&rts->rts_rwlock, RW_WRITER); in rts_tpi_opt_set()
752 rw_exit(&rts->rts_rwlock); in rts_tpi_opt_set()
842 rts_t *rts = connp->conn_rts; in rts_wrw() local
844 while (rts->rts_flag & RTS_WRW_PENDING) { in rts_wrw()
846 rts->rts_error = EINTR; in rts_wrw()
850 rts->rts_flag |= RTS_WRW_PENDING; in rts_wrw()
856 rts->rts_error = error; in rts_wrw()
873 rts->rts_error = EINVAL; in rts_wrw()
890 rts->rts_error = EINVAL; in rts_wrw()
901 rts->rts_flag |= RTS_WPUT_PENDING; in rts_wrw()
903 while (rts->rts_flag & RTS_WPUT_PENDING) in rts_wrw()
906 rts->rts_error = EINTR; in rts_wrw()
910 rts->rts_flag &= ~(RTS_WPUT_PENDING | RTS_WRW_PENDING); in rts_wrw()
911 return (rts->rts_error); in rts_wrw()
926 rts_t *rts = connp->conn_rts; in rts_wput() local
955 ASSERT(rts != NULL); in rts_wput()
957 if (rts->rts_flag & RTS_WPUT_PENDING) { in rts_wput()
958 rts->rts_error = ENOMEM; in rts_wput()
959 rts->rts_flag &= ~RTS_WPUT_PENDING; in rts_wput()
976 rts_t *rts = connp->conn_rts; in rts_wput_other() local
982 rtss = rts->rts_rtss; in rts_wput_other()
1144 rts_t *rts = connp->conn_rts; in rts_input() local
1155 if (rts->rts_flag & (RTS_WPUT_PENDING)) { in rts_input()
1156 rts->rts_flag &= ~RTS_WPUT_PENDING; in rts_input()
1157 rts->rts_error = iocp->ioc_error; in rts_input()
1198 mutex_enter(&rts->rts_recv_mutex); in rts_input()
1205 mutex_exit(&rts->rts_recv_mutex); in rts_input()
1353 rts_t *rts = connp->conn_rts; in rts_getsockopt() local
1370 rw_enter(&rts->rts_rwlock, RW_READER); in rts_getsockopt()
1372 rw_exit(&rts->rts_rwlock); in rts_getsockopt()
1394 rts_t *rts = connp->conn_rts; in rts_setsockopt() local
1408 rw_enter(&rts->rts_rwlock, RW_WRITER); in rts_setsockopt()
1412 rw_exit(&rts->rts_rwlock); in rts_setsockopt()
1548 rts_t *rts = connp->conn_rts; in rts_clr_flowctrl() local
1550 mutex_enter(&rts->rts_recv_mutex); in rts_clr_flowctrl()
1552 mutex_exit(&rts->rts_recv_mutex); in rts_clr_flowctrl()