17c478bd9Sstevel@tonic-gate /*
27c478bd9Sstevel@tonic-gate * CDDL HEADER START
37c478bd9Sstevel@tonic-gate *
47c478bd9Sstevel@tonic-gate * The contents of this file are subject to the terms of the
57c478bd9Sstevel@tonic-gate * Common Development and Distribution License, Version 1.0 only
67c478bd9Sstevel@tonic-gate * (the "License"). You may not use this file except in compliance
77c478bd9Sstevel@tonic-gate * with the License.
87c478bd9Sstevel@tonic-gate *
97c478bd9Sstevel@tonic-gate * You can obtain a copy of the license at usr/src/OPENSOLARIS.LICENSE
107c478bd9Sstevel@tonic-gate * or http://www.opensolaris.org/os/licensing.
117c478bd9Sstevel@tonic-gate * See the License for the specific language governing permissions
127c478bd9Sstevel@tonic-gate * and limitations under the License.
137c478bd9Sstevel@tonic-gate *
147c478bd9Sstevel@tonic-gate * When distributing Covered Code, include this CDDL HEADER in each
157c478bd9Sstevel@tonic-gate * file and include the License file at usr/src/OPENSOLARIS.LICENSE.
167c478bd9Sstevel@tonic-gate * If applicable, add the following below this CDDL HEADER, with the
177c478bd9Sstevel@tonic-gate * fields enclosed by brackets "[]" replaced with your own identifying
187c478bd9Sstevel@tonic-gate * information: Portions Copyright [yyyy] [name of copyright owner]
197c478bd9Sstevel@tonic-gate *
207c478bd9Sstevel@tonic-gate * CDDL HEADER END
217c478bd9Sstevel@tonic-gate */
22*61961e0fSrobinson
237c478bd9Sstevel@tonic-gate /* Copyright (c) 1984, 1986, 1987, 1988, 1989 AT&T */
247c478bd9Sstevel@tonic-gate /* All Rights Reserved */
257c478bd9Sstevel@tonic-gate
267c478bd9Sstevel@tonic-gate /*
27*61961e0fSrobinson * Copyright 2005 Sun Microsystems, Inc. All rights reserved.
287c478bd9Sstevel@tonic-gate * Use is subject to license terms.
297c478bd9Sstevel@tonic-gate */
307c478bd9Sstevel@tonic-gate
317c478bd9Sstevel@tonic-gate /*
327c478bd9Sstevel@tonic-gate * t_rcvrel.c and t_rcvreldata.c are very similar and contain common code.
337c478bd9Sstevel@tonic-gate * Any changes to either of them should be reviewed to see whether they
347c478bd9Sstevel@tonic-gate * are applicable to the other file.
357c478bd9Sstevel@tonic-gate */
367c478bd9Sstevel@tonic-gate #include "mt.h"
377c478bd9Sstevel@tonic-gate #include <stdlib.h>
387c478bd9Sstevel@tonic-gate #include <errno.h>
397c478bd9Sstevel@tonic-gate #include <stropts.h>
407c478bd9Sstevel@tonic-gate #include <sys/stream.h>
417c478bd9Sstevel@tonic-gate #define _SUN_TPI_VERSION 2
427c478bd9Sstevel@tonic-gate #include <sys/tihdr.h>
437c478bd9Sstevel@tonic-gate #include <sys/timod.h>
447c478bd9Sstevel@tonic-gate #include <xti.h>
457c478bd9Sstevel@tonic-gate #include <signal.h>
467c478bd9Sstevel@tonic-gate #include <syslog.h>
477c478bd9Sstevel@tonic-gate #include "tx.h"
487c478bd9Sstevel@tonic-gate
497c478bd9Sstevel@tonic-gate int
_tx_rcvrel(int fd,int api_semantics)507c478bd9Sstevel@tonic-gate _tx_rcvrel(int fd, int api_semantics)
517c478bd9Sstevel@tonic-gate {
527c478bd9Sstevel@tonic-gate struct strbuf ctlbuf;
537c478bd9Sstevel@tonic-gate struct strbuf databuf;
547c478bd9Sstevel@tonic-gate int retval;
557c478bd9Sstevel@tonic-gate union T_primitives *pptr;
567c478bd9Sstevel@tonic-gate struct _ti_user *tiptr;
577c478bd9Sstevel@tonic-gate int sv_errno;
587c478bd9Sstevel@tonic-gate int didalloc, didralloc;
597c478bd9Sstevel@tonic-gate
607c478bd9Sstevel@tonic-gate int flg = 0;
617c478bd9Sstevel@tonic-gate
62*61961e0fSrobinson if ((tiptr = _t_checkfd(fd, 0, api_semantics)) == 0)
637c478bd9Sstevel@tonic-gate return (-1);
647c478bd9Sstevel@tonic-gate sig_mutex_lock(&tiptr->ti_lock);
657c478bd9Sstevel@tonic-gate
667c478bd9Sstevel@tonic-gate if (tiptr->ti_servtype != T_COTS_ORD) {
677c478bd9Sstevel@tonic-gate t_errno = TNOTSUPPORT;
687c478bd9Sstevel@tonic-gate sig_mutex_unlock(&tiptr->ti_lock);
697c478bd9Sstevel@tonic-gate return (-1);
707c478bd9Sstevel@tonic-gate }
717c478bd9Sstevel@tonic-gate
727c478bd9Sstevel@tonic-gate if (_T_IS_XTI(api_semantics)) {
737c478bd9Sstevel@tonic-gate /*
747c478bd9Sstevel@tonic-gate * User level state verification only done for XTI
757c478bd9Sstevel@tonic-gate * because doing for TLI may break existing applications
767c478bd9Sstevel@tonic-gate */
77*61961e0fSrobinson if (!(tiptr->ti_state == T_DATAXFER ||
787c478bd9Sstevel@tonic-gate tiptr->ti_state == T_OUTREL)) {
797c478bd9Sstevel@tonic-gate t_errno = TOUTSTATE;
807c478bd9Sstevel@tonic-gate sig_mutex_unlock(&tiptr->ti_lock);
817c478bd9Sstevel@tonic-gate return (-1);
827c478bd9Sstevel@tonic-gate }
837c478bd9Sstevel@tonic-gate }
847c478bd9Sstevel@tonic-gate
857c478bd9Sstevel@tonic-gate if ((retval = _t_look_locked(fd, tiptr, 0, api_semantics)) < 0) {
867c478bd9Sstevel@tonic-gate sv_errno = errno;
877c478bd9Sstevel@tonic-gate sig_mutex_unlock(&tiptr->ti_lock);
887c478bd9Sstevel@tonic-gate errno = sv_errno;
897c478bd9Sstevel@tonic-gate return (-1);
907c478bd9Sstevel@tonic-gate }
917c478bd9Sstevel@tonic-gate
927c478bd9Sstevel@tonic-gate if (retval == T_DISCONNECT) {
937c478bd9Sstevel@tonic-gate /*
947c478bd9Sstevel@tonic-gate * This ensures preference to T_DISCON_IND which is
957c478bd9Sstevel@tonic-gate * the design model for TPI
967c478bd9Sstevel@tonic-gate */
977c478bd9Sstevel@tonic-gate t_errno = TLOOK;
987c478bd9Sstevel@tonic-gate sig_mutex_unlock(&tiptr->ti_lock);
997c478bd9Sstevel@tonic-gate return (-1);
1007c478bd9Sstevel@tonic-gate }
1017c478bd9Sstevel@tonic-gate
1027c478bd9Sstevel@tonic-gate if ((tiptr->ti_lookcnt > 0) &&
103*61961e0fSrobinson /* LINTED pointer cast */
1047c478bd9Sstevel@tonic-gate (*((t_scalar_t *)tiptr->ti_lookbufs.tl_lookcbuf) == T_ORDREL_IND)) {
1057c478bd9Sstevel@tonic-gate /*
1067c478bd9Sstevel@tonic-gate * Current look buffer event is T_ORDREL_IND.
1077c478bd9Sstevel@tonic-gate * Remove it from look buffer event list.
1087c478bd9Sstevel@tonic-gate */
1097c478bd9Sstevel@tonic-gate _t_free_looklist_head(tiptr);
1107c478bd9Sstevel@tonic-gate _T_TX_NEXTSTATE(T_RCVREL, tiptr,
1117c478bd9Sstevel@tonic-gate "t_rcv: invalid state event T_RCVREL");
1127c478bd9Sstevel@tonic-gate sig_mutex_unlock(&tiptr->ti_lock);
1137c478bd9Sstevel@tonic-gate return (0);
1147c478bd9Sstevel@tonic-gate } else {
1157c478bd9Sstevel@tonic-gate if (retval != T_ORDREL) {
1167c478bd9Sstevel@tonic-gate t_errno = TNOREL;
1177c478bd9Sstevel@tonic-gate sig_mutex_unlock(&tiptr->ti_lock);
1187c478bd9Sstevel@tonic-gate return (-1);
1197c478bd9Sstevel@tonic-gate }
1207c478bd9Sstevel@tonic-gate }
1217c478bd9Sstevel@tonic-gate
1227c478bd9Sstevel@tonic-gate /*
1237c478bd9Sstevel@tonic-gate * get ordrel off read queue.
1247c478bd9Sstevel@tonic-gate * use ctl and rcv buffers
1257c478bd9Sstevel@tonic-gate *
1267c478bd9Sstevel@tonic-gate * Acquire ctlbuf for use in sending/receiving control part
1277c478bd9Sstevel@tonic-gate * of the message.
1287c478bd9Sstevel@tonic-gate */
1297c478bd9Sstevel@tonic-gate if (_t_acquire_ctlbuf(tiptr, &ctlbuf, &didalloc) < 0) {
1307c478bd9Sstevel@tonic-gate sv_errno = errno;
1317c478bd9Sstevel@tonic-gate sig_mutex_unlock(&tiptr->ti_lock);
1327c478bd9Sstevel@tonic-gate errno = sv_errno;
1337c478bd9Sstevel@tonic-gate return (-1);
1347c478bd9Sstevel@tonic-gate }
1357c478bd9Sstevel@tonic-gate
1367c478bd9Sstevel@tonic-gate /*
1377c478bd9Sstevel@tonic-gate * Acquire databuf for use in sending/receiving data part
1387c478bd9Sstevel@tonic-gate */
1397c478bd9Sstevel@tonic-gate if (_t_acquire_databuf(tiptr, &databuf, &didralloc) < 0) {
1407c478bd9Sstevel@tonic-gate sv_errno = errno;
1417c478bd9Sstevel@tonic-gate if (didalloc)
1427c478bd9Sstevel@tonic-gate free(ctlbuf.buf);
1437c478bd9Sstevel@tonic-gate else
1447c478bd9Sstevel@tonic-gate tiptr->ti_ctlbuf = ctlbuf.buf;
1457c478bd9Sstevel@tonic-gate sig_mutex_unlock(&tiptr->ti_lock);
1467c478bd9Sstevel@tonic-gate errno = sv_errno;
1477c478bd9Sstevel@tonic-gate return (-1);
1487c478bd9Sstevel@tonic-gate }
1497c478bd9Sstevel@tonic-gate
1507c478bd9Sstevel@tonic-gate /*
1517c478bd9Sstevel@tonic-gate * Since we have verified above that an orderly release event
1527c478bd9Sstevel@tonic-gate * is pending on this endpoint, we assume that this getmsg()
1537c478bd9Sstevel@tonic-gate * cannot block forever.
1547c478bd9Sstevel@tonic-gate */
1557c478bd9Sstevel@tonic-gate do {
1567c478bd9Sstevel@tonic-gate retval = getmsg(fd, &ctlbuf, &databuf, &flg);
1577c478bd9Sstevel@tonic-gate } while (retval < 0 && errno == EINTR);
1587c478bd9Sstevel@tonic-gate
1597c478bd9Sstevel@tonic-gate if (retval < 0) {
1607c478bd9Sstevel@tonic-gate t_errno = TSYSERR;
1617c478bd9Sstevel@tonic-gate goto err_out;
1627c478bd9Sstevel@tonic-gate }
1637c478bd9Sstevel@tonic-gate
1647c478bd9Sstevel@tonic-gate /*
1657c478bd9Sstevel@tonic-gate * did I get entire message?
1667c478bd9Sstevel@tonic-gate */
1677c478bd9Sstevel@tonic-gate if (retval > 0) {
1687c478bd9Sstevel@tonic-gate t_errno = TSYSERR;
1697c478bd9Sstevel@tonic-gate errno = EIO;
1707c478bd9Sstevel@tonic-gate goto err_out;
1717c478bd9Sstevel@tonic-gate }
172*61961e0fSrobinson /* LINTED pointer cast */
1737c478bd9Sstevel@tonic-gate pptr = (union T_primitives *)ctlbuf.buf;
1747c478bd9Sstevel@tonic-gate
1757c478bd9Sstevel@tonic-gate if (ctlbuf.len < (int)sizeof (struct T_ordrel_ind)) {
1767c478bd9Sstevel@tonic-gate t_errno = TSYSERR;
1777c478bd9Sstevel@tonic-gate errno = EPROTO;
1787c478bd9Sstevel@tonic-gate goto err_out;
1797c478bd9Sstevel@tonic-gate }
1807c478bd9Sstevel@tonic-gate if (pptr->type != T_ORDREL_IND) {
1817c478bd9Sstevel@tonic-gate if (pptr->type == T_DISCON_IND) {
1827c478bd9Sstevel@tonic-gate /*
1837c478bd9Sstevel@tonic-gate * T_DISCON_IND gets priority following
1847c478bd9Sstevel@tonic-gate * TPI design philosphy.
1857c478bd9Sstevel@tonic-gate *
1867c478bd9Sstevel@tonic-gate * Add it to the events in the "look buffer"
1877c478bd9Sstevel@tonic-gate * list of events. This routine may defer signals.
1887c478bd9Sstevel@tonic-gate */
1897c478bd9Sstevel@tonic-gate if (_t_register_lookevent(tiptr, databuf.buf,
1907c478bd9Sstevel@tonic-gate databuf.len, ctlbuf.buf,
1917c478bd9Sstevel@tonic-gate ctlbuf.len) < 0) {
1927c478bd9Sstevel@tonic-gate t_errno = TSYSERR;
1937c478bd9Sstevel@tonic-gate errno = ENOMEM;
1947c478bd9Sstevel@tonic-gate goto err_out;
1957c478bd9Sstevel@tonic-gate }
1967c478bd9Sstevel@tonic-gate t_errno = TLOOK;
1977c478bd9Sstevel@tonic-gate goto err_out;
1987c478bd9Sstevel@tonic-gate } else {
1997c478bd9Sstevel@tonic-gate t_errno = TSYSERR;
2007c478bd9Sstevel@tonic-gate errno = EPROTO;
2017c478bd9Sstevel@tonic-gate goto err_out;
2027c478bd9Sstevel@tonic-gate }
2037c478bd9Sstevel@tonic-gate }
2047c478bd9Sstevel@tonic-gate
2057c478bd9Sstevel@tonic-gate _T_TX_NEXTSTATE(T_RCVREL, tiptr,
2067c478bd9Sstevel@tonic-gate "t_rcvrel: invalid state event T_RCVREL");
2077c478bd9Sstevel@tonic-gate
2087c478bd9Sstevel@tonic-gate if (didalloc)
2097c478bd9Sstevel@tonic-gate free(ctlbuf.buf);
2107c478bd9Sstevel@tonic-gate else
2117c478bd9Sstevel@tonic-gate tiptr->ti_ctlbuf = ctlbuf.buf;
2127c478bd9Sstevel@tonic-gate if (didralloc)
2137c478bd9Sstevel@tonic-gate free(databuf.buf);
2147c478bd9Sstevel@tonic-gate else
2157c478bd9Sstevel@tonic-gate tiptr->ti_rcvbuf = databuf.buf;
2167c478bd9Sstevel@tonic-gate sig_mutex_unlock(&tiptr->ti_lock);
2177c478bd9Sstevel@tonic-gate return (0);
2187c478bd9Sstevel@tonic-gate
2197c478bd9Sstevel@tonic-gate err_out:
2207c478bd9Sstevel@tonic-gate sv_errno = errno;
2217c478bd9Sstevel@tonic-gate
2227c478bd9Sstevel@tonic-gate if (didalloc)
2237c478bd9Sstevel@tonic-gate free(ctlbuf.buf);
2247c478bd9Sstevel@tonic-gate else
2257c478bd9Sstevel@tonic-gate tiptr->ti_ctlbuf = ctlbuf.buf;
2267c478bd9Sstevel@tonic-gate if (didralloc)
2277c478bd9Sstevel@tonic-gate free(databuf.buf);
2287c478bd9Sstevel@tonic-gate else
2297c478bd9Sstevel@tonic-gate tiptr->ti_rcvbuf = databuf.buf;
2307c478bd9Sstevel@tonic-gate sig_mutex_unlock(&tiptr->ti_lock);
2317c478bd9Sstevel@tonic-gate errno = sv_errno;
2327c478bd9Sstevel@tonic-gate return (-1);
2337c478bd9Sstevel@tonic-gate }
234