Cross Reference: /illumos-gate/usr/src/uts/common/inet/ip/rts.c

Lines Matching defs:rts
90 	64 * 1024,	/* TIDU_size. rts allows maximum size messages. */
91 	T_COTS,		/* SERV_type. rts supports connection oriented. */
97  * Table of ND variables supported by rts. These are loaded into rts_g_nd
139 	129, "rts", 1, INFPSZ, 512, 128
198  * This routine closes rts stream, by disabling
259 	rts_t   *rts;
281 	rts = connp->conn_rts;
282 	rw_enter(&rts->rts_rwlock, RW_WRITER);
297 	rw_exit(&rts->rts_rwlock);
313 	rts_t	*rts;
332 	rts = connp->conn_rts;
340 	rw_enter(&rts->rts_rwlock, RW_WRITER);
341 	ASSERT(connp->conn_rts == rts);
342 	ASSERT(rts->rts_connp == connp);
350 	rts->rts_rtss = rtss;
375 	 * rts sockets start out as bound and connected
379 	rts->rts_state = TS_DATA_XFER;
380 	rw_exit(&rts->rts_rwlock);
412 	rts_t	*rts = connp->conn_rts;
415 	if (rts->rts_state != TS_IDLE) {
419 	rts->rts_state = TS_UNBND;
433 	rts_t	*rts = connp->conn_rts;
438 		    "rts_tpi_bind: bad data, %d", rts->rts_state);
442 	if (rts->rts_state != TS_UNBND) {
444 		    "rts_tpi_bind: bad state, %d", rts->rts_state);
460 	rts->rts_state = TS_IDLE;
465 rts_copy_info(struct T_info_ack *tap, rts_t *rts)
468 	tap->CURRENT_state = rts->rts_state;
482 	rts_t	*rts = connp->conn_rts;
497 		rts_copy_info(&tcap->INFO_ack, rts);
513 	rts_t	*rts = connp->conn_rts;
519 	rts_copy_info((struct T_info_ack *)mp->b_rptr, rts);
539 	rts_t	*rts = connp->conn_rts;
543 	ASSERT(RW_READ_HELD(&rts->rts_rwlock));
573 	rts_t	*rts = connp->conn_rts;
574 	rts_stack_t	*rtss = rts->rts_rtss;
582 	ASSERT(RW_WRITE_HELD(&rts->rts_rwlock));
585 	 * For rts, we should have no ancillary data sent down
725 	rts_t	*rts;
728 	rts = Q_TO_RTS(q);
729 	rw_enter(&rts->rts_rwlock, RW_READER);
731 	rw_exit(&rts->rts_rwlock);
746 	rts_t	*rts = connp->conn_rts;
749 	rw_enter(&rts->rts_rwlock, RW_WRITER);
752 	rw_exit(&rts->rts_rwlock);
831  * It uses the RTS_WRW_PENDING to ensure that each rts instance has only
842 	rts_t	*rts = connp->conn_rts;
844 	while (rts->rts_flag & RTS_WRW_PENDING) {
846 			rts->rts_error = EINTR;
850 	rts->rts_flag |= RTS_WRW_PENDING;
856 		rts->rts_error = error;
873 			rts->rts_error = EINVAL;
890 				rts->rts_error = EINVAL;
901 	rts->rts_flag |= RTS_WPUT_PENDING;
903 	while (rts->rts_flag & RTS_WPUT_PENDING)
906 			rts->rts_error = EINTR;
910 	rts->rts_flag &= ~(RTS_WPUT_PENDING | RTS_WRW_PENDING);
911 	return (rts->rts_error);
926 	rts_t	*rts = connp->conn_rts;
955 		ASSERT(rts != NULL);
957 		if (rts->rts_flag & RTS_WPUT_PENDING) {
958 			rts->rts_error = ENOMEM;
959 			rts->rts_flag &= ~RTS_WPUT_PENDING;
976 	rts_t	*rts = connp->conn_rts;
982 	rtss = rts->rts_rtss;
1034 			/* Not supported by rts. */
1040 			/* Illegal for rts. */
1144 	rts_t	*rts = connp->conn_rts;
1155 		if (rts->rts_flag & (RTS_WPUT_PENDING)) {
1156 			rts->rts_flag &= ~RTS_WPUT_PENDING;
1157 			rts->rts_error = iocp->ioc_error;
1198 			mutex_enter(&rts->rts_recv_mutex);
1205 			mutex_exit(&rts->rts_recv_mutex);
1318 	 * rts sockets start out as bound and connected
1353 	rts_t		*rts = connp->conn_rts;
1370 	rw_enter(&rts->rts_rwlock, RW_READER);
1372 	rw_exit(&rts->rts_rwlock);
1394 	rts_t	*rts = connp->conn_rts;
1408 	rw_enter(&rts->rts_rwlock, RW_WRITER);
1412 	rw_exit(&rts->rts_rwlock);
1548 	rts_t	*rts = connp->conn_rts;
1550 	mutex_enter(&rts->rts_recv_mutex);
1552 	mutex_exit(&rts->rts_recv_mutex);