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 */
2261961e0fSrobinson
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*e8031f0aSraf * Copyright 2006 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_rcv.c and t_rcvv.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 <unistd.h>
407c478bd9Sstevel@tonic-gate #include <stropts.h>
417c478bd9Sstevel@tonic-gate #include <sys/stream.h>
427c478bd9Sstevel@tonic-gate #define _SUN_TPI_VERSION 2
437c478bd9Sstevel@tonic-gate #include <sys/tihdr.h>
447c478bd9Sstevel@tonic-gate #include <sys/timod.h>
457c478bd9Sstevel@tonic-gate #include <xti.h>
467c478bd9Sstevel@tonic-gate #include <syslog.h>
477c478bd9Sstevel@tonic-gate #include <assert.h>
487c478bd9Sstevel@tonic-gate #include "tx.h"
497c478bd9Sstevel@tonic-gate
507c478bd9Sstevel@tonic-gate int
_tx_rcv(int fd,char * buf,unsigned nbytes,int * flags,int api_semantics)517c478bd9Sstevel@tonic-gate _tx_rcv(int fd, char *buf, unsigned nbytes, int *flags, int api_semantics)
527c478bd9Sstevel@tonic-gate {
537c478bd9Sstevel@tonic-gate struct strbuf ctlbuf, databuf;
547c478bd9Sstevel@tonic-gate int retval, flg = 0;
557c478bd9Sstevel@tonic-gate int msglen;
567c478bd9Sstevel@tonic-gate union T_primitives *pptr;
577c478bd9Sstevel@tonic-gate struct _ti_user *tiptr;
587c478bd9Sstevel@tonic-gate int sv_errno;
597c478bd9Sstevel@tonic-gate int didalloc;
607c478bd9Sstevel@tonic-gate
6161961e0fSrobinson if ((tiptr = _t_checkfd(fd, 0, api_semantics)) == NULL)
627c478bd9Sstevel@tonic-gate return (-1);
637c478bd9Sstevel@tonic-gate sig_mutex_lock(&tiptr->ti_lock);
647c478bd9Sstevel@tonic-gate
657c478bd9Sstevel@tonic-gate if (tiptr->ti_servtype == T_CLTS) {
667c478bd9Sstevel@tonic-gate t_errno = TNOTSUPPORT;
677c478bd9Sstevel@tonic-gate sig_mutex_unlock(&tiptr->ti_lock);
687c478bd9Sstevel@tonic-gate return (-1);
697c478bd9Sstevel@tonic-gate }
707c478bd9Sstevel@tonic-gate
717c478bd9Sstevel@tonic-gate if (_T_IS_XTI(api_semantics)) {
727c478bd9Sstevel@tonic-gate /*
737c478bd9Sstevel@tonic-gate * User level state verification only done for XTI
747c478bd9Sstevel@tonic-gate * because doing for TLI may break existing applications
757c478bd9Sstevel@tonic-gate */
7661961e0fSrobinson if (!(tiptr->ti_state == T_DATAXFER ||
777c478bd9Sstevel@tonic-gate tiptr->ti_state == T_OUTREL)) {
787c478bd9Sstevel@tonic-gate t_errno = TOUTSTATE;
797c478bd9Sstevel@tonic-gate sig_mutex_unlock(&tiptr->ti_lock);
807c478bd9Sstevel@tonic-gate return (-1);
817c478bd9Sstevel@tonic-gate }
827c478bd9Sstevel@tonic-gate }
837c478bd9Sstevel@tonic-gate
847c478bd9Sstevel@tonic-gate /*
857c478bd9Sstevel@tonic-gate * Check in lookbuf for stuff
867c478bd9Sstevel@tonic-gate */
877c478bd9Sstevel@tonic-gate if (tiptr->ti_lookcnt > 0) {
887c478bd9Sstevel@tonic-gate /*
897c478bd9Sstevel@tonic-gate * Implied preference rules give priority to
907c478bd9Sstevel@tonic-gate * T_DISCON_IND over T_ORDREL_IND. Also certain errors like
917c478bd9Sstevel@tonic-gate * data received after T_ORDREL_IND or a duplicate T_ORDREL_IND
927c478bd9Sstevel@tonic-gate * after a T_ORDRELING have priority over TLOOK.
937c478bd9Sstevel@tonic-gate * This manifests in following code behavior.
947c478bd9Sstevel@tonic-gate *
957c478bd9Sstevel@tonic-gate * (1) If something in lookbuf then check
967c478bd9Sstevel@tonic-gate * the stream head also. This may result
977c478bd9Sstevel@tonic-gate * in retuning a TLOOK error but only if there are
987c478bd9Sstevel@tonic-gate * - message at stream head but look buffer
997c478bd9Sstevel@tonic-gate * has a T_DISCON_IND event.
1007c478bd9Sstevel@tonic-gate * - no messages are on the stream head
1017c478bd9Sstevel@tonic-gate *
1027c478bd9Sstevel@tonic-gate * (2) If there are messages on the stream head and
1037c478bd9Sstevel@tonic-gate * all of them are T_ORDREL_IND(i.e. no message in
1047c478bd9Sstevel@tonic-gate * look buffer is T_DISCON_IND), there
1057c478bd9Sstevel@tonic-gate * could be data on stream head to be picked up and
1067c478bd9Sstevel@tonic-gate * we work on the stream head and not return TLOOK.
1077c478bd9Sstevel@tonic-gate * We remove the event on the stream head and queue it.
1087c478bd9Sstevel@tonic-gate *
1097c478bd9Sstevel@tonic-gate */
1107c478bd9Sstevel@tonic-gate do {
111*e8031f0aSraf retval = ioctl(fd, I_NREAD, &msglen);
1127c478bd9Sstevel@tonic-gate } while (retval < 0 && errno == EINTR);
1137c478bd9Sstevel@tonic-gate
1147c478bd9Sstevel@tonic-gate if (retval < 0) {
1157c478bd9Sstevel@tonic-gate sv_errno = errno;
1167c478bd9Sstevel@tonic-gate
1177c478bd9Sstevel@tonic-gate t_errno = TSYSERR;
1187c478bd9Sstevel@tonic-gate sig_mutex_unlock(&tiptr->ti_lock);
1197c478bd9Sstevel@tonic-gate errno = sv_errno;
1207c478bd9Sstevel@tonic-gate return (-1);
1217c478bd9Sstevel@tonic-gate }
1227c478bd9Sstevel@tonic-gate
1237c478bd9Sstevel@tonic-gate if (retval > 0) {
1247c478bd9Sstevel@tonic-gate /*
1257c478bd9Sstevel@tonic-gate * If any T_DISCON_IND event in look buffer
1267c478bd9Sstevel@tonic-gate * list then return TLOOK. Else continue
1277c478bd9Sstevel@tonic-gate * processing as what could be on the stream
1287c478bd9Sstevel@tonic-gate * head might be a possible T_DISCON_IND (which
1297c478bd9Sstevel@tonic-gate * would have priority over the T_ORDREL_INDs
1307c478bd9Sstevel@tonic-gate * on the look buffer.)
1317c478bd9Sstevel@tonic-gate */
1327c478bd9Sstevel@tonic-gate struct _ti_lookbufs *tlbs;
1337c478bd9Sstevel@tonic-gate
1347c478bd9Sstevel@tonic-gate tlbs = &tiptr->ti_lookbufs;
1357c478bd9Sstevel@tonic-gate do {
13661961e0fSrobinson /* LINTED pointer cast */
1377c478bd9Sstevel@tonic-gate if (*((t_scalar_t *)tlbs->tl_lookcbuf)
1387c478bd9Sstevel@tonic-gate == T_DISCON_IND) {
1397c478bd9Sstevel@tonic-gate t_errno = TLOOK;
1407c478bd9Sstevel@tonic-gate sig_mutex_unlock(&tiptr->ti_lock);
1417c478bd9Sstevel@tonic-gate return (-1);
1427c478bd9Sstevel@tonic-gate }
1437c478bd9Sstevel@tonic-gate } while ((tlbs = tlbs->tl_next) != NULL);
1447c478bd9Sstevel@tonic-gate
1457c478bd9Sstevel@tonic-gate } else { /* retval == 0 */
1467c478bd9Sstevel@tonic-gate /*
1477c478bd9Sstevel@tonic-gate * Nothing on stream head so whatever in
1487c478bd9Sstevel@tonic-gate * look buffer has nothing that might override
1497c478bd9Sstevel@tonic-gate * it.
1507c478bd9Sstevel@tonic-gate */
1517c478bd9Sstevel@tonic-gate t_errno = TLOOK;
1527c478bd9Sstevel@tonic-gate sig_mutex_unlock(&tiptr->ti_lock);
1537c478bd9Sstevel@tonic-gate return (-1);
1547c478bd9Sstevel@tonic-gate }
1557c478bd9Sstevel@tonic-gate }
1567c478bd9Sstevel@tonic-gate
1577c478bd9Sstevel@tonic-gate /*
1587c478bd9Sstevel@tonic-gate * Acquire ctlbuf for use in sending/receiving control part
1597c478bd9Sstevel@tonic-gate * of the message.
1607c478bd9Sstevel@tonic-gate */
1617c478bd9Sstevel@tonic-gate if (_t_acquire_ctlbuf(tiptr, &ctlbuf, &didalloc) < 0) {
1627c478bd9Sstevel@tonic-gate sv_errno = errno;
1637c478bd9Sstevel@tonic-gate sig_mutex_unlock(&tiptr->ti_lock);
1647c478bd9Sstevel@tonic-gate errno = sv_errno;
1657c478bd9Sstevel@tonic-gate return (-1);
1667c478bd9Sstevel@tonic-gate }
1677c478bd9Sstevel@tonic-gate
1687c478bd9Sstevel@tonic-gate databuf.maxlen = nbytes;
1697c478bd9Sstevel@tonic-gate databuf.len = 0;
1707c478bd9Sstevel@tonic-gate databuf.buf = buf;
1717c478bd9Sstevel@tonic-gate
1727c478bd9Sstevel@tonic-gate *flags = 0;
1737c478bd9Sstevel@tonic-gate
1747c478bd9Sstevel@tonic-gate /*
1757c478bd9Sstevel@tonic-gate * This is a call that may block indefinitely so we drop the
1767c478bd9Sstevel@tonic-gate * lock and allow signals in MT case here and reacquire it.
1777c478bd9Sstevel@tonic-gate * Error case should roll back state changes done above
1787c478bd9Sstevel@tonic-gate * (happens to be no state change here)
1797c478bd9Sstevel@tonic-gate */
1807c478bd9Sstevel@tonic-gate sig_mutex_unlock(&tiptr->ti_lock);
1817c478bd9Sstevel@tonic-gate if ((retval = getmsg(fd, &ctlbuf, &databuf, &flg)) < 0) {
1827c478bd9Sstevel@tonic-gate if (errno == EAGAIN)
1837c478bd9Sstevel@tonic-gate t_errno = TNODATA;
1847c478bd9Sstevel@tonic-gate else
1857c478bd9Sstevel@tonic-gate t_errno = TSYSERR;
1867c478bd9Sstevel@tonic-gate sv_errno = errno;
1877c478bd9Sstevel@tonic-gate sig_mutex_lock(&tiptr->ti_lock);
1887c478bd9Sstevel@tonic-gate errno = sv_errno;
1897c478bd9Sstevel@tonic-gate goto err_out;
1907c478bd9Sstevel@tonic-gate }
1917c478bd9Sstevel@tonic-gate sig_mutex_lock(&tiptr->ti_lock);
1927c478bd9Sstevel@tonic-gate
1937c478bd9Sstevel@tonic-gate assert((retval & MORECTL) == 0); /* MORECTL should not be on */
1947c478bd9Sstevel@tonic-gate
1957c478bd9Sstevel@tonic-gate if (databuf.len == -1) databuf.len = 0;
1967c478bd9Sstevel@tonic-gate
1977c478bd9Sstevel@tonic-gate if (ctlbuf.len > 0) {
1987c478bd9Sstevel@tonic-gate if (ctlbuf.len < (int)sizeof (t_scalar_t)) {
1997c478bd9Sstevel@tonic-gate t_errno = TSYSERR;
2007c478bd9Sstevel@tonic-gate errno = EPROTO;
2017c478bd9Sstevel@tonic-gate goto err_out;
2027c478bd9Sstevel@tonic-gate }
2037c478bd9Sstevel@tonic-gate
20461961e0fSrobinson /* LINTED pointer cast */
2057c478bd9Sstevel@tonic-gate pptr = (union T_primitives *)ctlbuf.buf;
2067c478bd9Sstevel@tonic-gate
2077c478bd9Sstevel@tonic-gate switch (pptr->type) {
2087c478bd9Sstevel@tonic-gate
2097c478bd9Sstevel@tonic-gate case T_EXDATA_IND:
2107c478bd9Sstevel@tonic-gate *flags |= T_EXPEDITED;
2117c478bd9Sstevel@tonic-gate if (retval > 0)
2127c478bd9Sstevel@tonic-gate tiptr->ti_flags |= EXPEDITED;
2137c478bd9Sstevel@tonic-gate /* FALLTHROUGH */
2147c478bd9Sstevel@tonic-gate case T_DATA_IND:
2157c478bd9Sstevel@tonic-gate /*
2167c478bd9Sstevel@tonic-gate * Uses the fact T_DATA_IND and T_EXDATA_IND
2177c478bd9Sstevel@tonic-gate * are same in size
2187c478bd9Sstevel@tonic-gate */
2197c478bd9Sstevel@tonic-gate if ((ctlbuf.len < (int)sizeof (struct T_data_ind)) ||
2207c478bd9Sstevel@tonic-gate (tiptr->ti_lookcnt > 0)) {
2217c478bd9Sstevel@tonic-gate /*
2227c478bd9Sstevel@tonic-gate * ti_lookcnt > 0 implies data
2237c478bd9Sstevel@tonic-gate * received after T_DISCON_IND or
2247c478bd9Sstevel@tonic-gate * T_ORDREL_IND hence error
2257c478bd9Sstevel@tonic-gate */
2267c478bd9Sstevel@tonic-gate t_errno = TSYSERR;
2277c478bd9Sstevel@tonic-gate errno = EPROTO;
2287c478bd9Sstevel@tonic-gate goto err_out;
2297c478bd9Sstevel@tonic-gate }
2307c478bd9Sstevel@tonic-gate
2317c478bd9Sstevel@tonic-gate if ((pptr->data_ind.MORE_flag) || retval)
2327c478bd9Sstevel@tonic-gate *flags |= T_MORE;
2337c478bd9Sstevel@tonic-gate if ((pptr->data_ind.MORE_flag) && retval)
2347c478bd9Sstevel@tonic-gate tiptr->ti_flags |= MORE;
2357c478bd9Sstevel@tonic-gate /*
2367c478bd9Sstevel@tonic-gate * No real state change on T_RCV event (noop)
2377c478bd9Sstevel@tonic-gate *
2387c478bd9Sstevel@tonic-gate * We invoke the macro only for error logging
2397c478bd9Sstevel@tonic-gate * part of its capabilities when in a bad state.
2407c478bd9Sstevel@tonic-gate */
2417c478bd9Sstevel@tonic-gate _T_TX_NEXTSTATE(T_RCV, tiptr,
2427c478bd9Sstevel@tonic-gate "t_rcv: invalid state event T_RCV");
2437c478bd9Sstevel@tonic-gate if (didalloc)
2447c478bd9Sstevel@tonic-gate free(ctlbuf.buf);
2457c478bd9Sstevel@tonic-gate else
2467c478bd9Sstevel@tonic-gate tiptr->ti_ctlbuf = ctlbuf.buf;
2477c478bd9Sstevel@tonic-gate sig_mutex_unlock(&tiptr->ti_lock);
2487c478bd9Sstevel@tonic-gate return (databuf.len);
2497c478bd9Sstevel@tonic-gate
2507c478bd9Sstevel@tonic-gate case T_ORDREL_IND:
2517c478bd9Sstevel@tonic-gate if (tiptr->ti_lookcnt > 0) {
2527c478bd9Sstevel@tonic-gate /*
2537c478bd9Sstevel@tonic-gate * ti_lookcnt > 0 implies T_ORDREL_IND
2547c478bd9Sstevel@tonic-gate * received after T_DISCON_IND or
2557c478bd9Sstevel@tonic-gate * another T_ORDREL_IND hence error.
2567c478bd9Sstevel@tonic-gate */
2577c478bd9Sstevel@tonic-gate t_errno = TSYSERR;
2587c478bd9Sstevel@tonic-gate errno = EPROTO;
2597c478bd9Sstevel@tonic-gate goto err_out;
2607c478bd9Sstevel@tonic-gate }
2617c478bd9Sstevel@tonic-gate /* FALLTHROUGH */
2627c478bd9Sstevel@tonic-gate case T_DISCON_IND:
2637c478bd9Sstevel@tonic-gate /*
2647c478bd9Sstevel@tonic-gate * Post event (T_ORDREL_IND/T_DISCON_IND) to
2657c478bd9Sstevel@tonic-gate * the lookbuffer list.
2667c478bd9Sstevel@tonic-gate */
2677c478bd9Sstevel@tonic-gate
2687c478bd9Sstevel@tonic-gate if (_t_register_lookevent(tiptr, databuf.buf,
2697c478bd9Sstevel@tonic-gate databuf.len,
2707c478bd9Sstevel@tonic-gate ctlbuf.buf, ctlbuf.len) < 0) {
2717c478bd9Sstevel@tonic-gate t_errno = TSYSERR;
2727c478bd9Sstevel@tonic-gate errno = ENOMEM;
2737c478bd9Sstevel@tonic-gate goto err_out;
2747c478bd9Sstevel@tonic-gate }
2757c478bd9Sstevel@tonic-gate /*
2767c478bd9Sstevel@tonic-gate * We know that T_DISCON_IND is stored in
2777c478bd9Sstevel@tonic-gate * last look buffer. If there is more data
2787c478bd9Sstevel@tonic-gate * that follows, we try to append it to
2797c478bd9Sstevel@tonic-gate * the same look buffer
2807c478bd9Sstevel@tonic-gate */
2817c478bd9Sstevel@tonic-gate if (retval & MOREDATA) {
2827c478bd9Sstevel@tonic-gate ctlbuf.maxlen = 0; /* XXX why ? */
2837c478bd9Sstevel@tonic-gate ctlbuf.len = 0;
2847c478bd9Sstevel@tonic-gate
2857c478bd9Sstevel@tonic-gate /*
2867c478bd9Sstevel@tonic-gate * XXX Will break (-ve maxlen) for
2877c478bd9Sstevel@tonic-gate * transport provider with unbounded
2887c478bd9Sstevel@tonic-gate * T_DISCON_IND data part (-1).
2897c478bd9Sstevel@tonic-gate */
2907c478bd9Sstevel@tonic-gate databuf.maxlen =
2917c478bd9Sstevel@tonic-gate tiptr->ti_rcvsize - databuf.len;
2927c478bd9Sstevel@tonic-gate
2937c478bd9Sstevel@tonic-gate databuf.len = 0;
2947c478bd9Sstevel@tonic-gate databuf.buf =
2957c478bd9Sstevel@tonic-gate tiptr->ti_lookbufs.tl_lookdbuf +
2967c478bd9Sstevel@tonic-gate tiptr->ti_lookbufs.tl_lookdlen;
2977c478bd9Sstevel@tonic-gate *flags = 0;
2987c478bd9Sstevel@tonic-gate
2997c478bd9Sstevel@tonic-gate /*
3007c478bd9Sstevel@tonic-gate * Since MOREDATA was set, we assume
3017c478bd9Sstevel@tonic-gate * that this getmsg will not block
3027c478bd9Sstevel@tonic-gate * indefinitely
3037c478bd9Sstevel@tonic-gate */
3047c478bd9Sstevel@tonic-gate do {
3057c478bd9Sstevel@tonic-gate retval = getmsg(fd, &ctlbuf,
3067c478bd9Sstevel@tonic-gate &databuf, &flg);
3077c478bd9Sstevel@tonic-gate } while (retval < 0 && errno == EINTR);
3087c478bd9Sstevel@tonic-gate
3097c478bd9Sstevel@tonic-gate if (retval < 0) {
3107c478bd9Sstevel@tonic-gate t_errno = TSYSERR;
3117c478bd9Sstevel@tonic-gate goto err_out;
3127c478bd9Sstevel@tonic-gate }
3137c478bd9Sstevel@tonic-gate if (databuf.len == -1) databuf.len = 0;
3147c478bd9Sstevel@tonic-gate if (retval > 0) {
3157c478bd9Sstevel@tonic-gate /* MORECTL should not be on */
3167c478bd9Sstevel@tonic-gate assert((retval & MORECTL) == 0);
3177c478bd9Sstevel@tonic-gate /*
3187c478bd9Sstevel@tonic-gate * XXX - Why ?
3197c478bd9Sstevel@tonic-gate * No support for unbounded data
3207c478bd9Sstevel@tonic-gate * on T_DISCON_IND ?
3217c478bd9Sstevel@tonic-gate */
3227c478bd9Sstevel@tonic-gate t_errno = TSYSERR;
3237c478bd9Sstevel@tonic-gate errno = EPROTO;
3247c478bd9Sstevel@tonic-gate goto err_out;
3257c478bd9Sstevel@tonic-gate }
3267c478bd9Sstevel@tonic-gate tiptr->ti_lookbufs.tl_lookdlen +=
3277c478bd9Sstevel@tonic-gate databuf.len;
3287c478bd9Sstevel@tonic-gate }
3297c478bd9Sstevel@tonic-gate
3307c478bd9Sstevel@tonic-gate t_errno = TLOOK;
3317c478bd9Sstevel@tonic-gate goto err_out;
3327c478bd9Sstevel@tonic-gate
3337c478bd9Sstevel@tonic-gate default:
3347c478bd9Sstevel@tonic-gate break;
3357c478bd9Sstevel@tonic-gate }
3367c478bd9Sstevel@tonic-gate
3377c478bd9Sstevel@tonic-gate t_errno = TSYSERR;
3387c478bd9Sstevel@tonic-gate errno = EPROTO;
3397c478bd9Sstevel@tonic-gate goto err_out;
3407c478bd9Sstevel@tonic-gate
3417c478bd9Sstevel@tonic-gate } else { /* else for "if (ctlbuf.len > 0)" */
3427c478bd9Sstevel@tonic-gate if (!retval && (tiptr->ti_flags & MORE)) {
3437c478bd9Sstevel@tonic-gate *flags |= T_MORE;
3447c478bd9Sstevel@tonic-gate tiptr->ti_flags &= ~MORE;
3457c478bd9Sstevel@tonic-gate }
3467c478bd9Sstevel@tonic-gate if (retval & MOREDATA)
3477c478bd9Sstevel@tonic-gate *flags |= T_MORE;
3487c478bd9Sstevel@tonic-gate
3497c478bd9Sstevel@tonic-gate /*
3507c478bd9Sstevel@tonic-gate * If inside an ETSDU, set expedited flag and turn
3517c478bd9Sstevel@tonic-gate * of internal version when reach end of "ETIDU".
3527c478bd9Sstevel@tonic-gate */
3537c478bd9Sstevel@tonic-gate if (tiptr->ti_flags & EXPEDITED) {
3547c478bd9Sstevel@tonic-gate *flags |= T_EXPEDITED;
3557c478bd9Sstevel@tonic-gate if (!retval)
3567c478bd9Sstevel@tonic-gate tiptr->ti_flags &= ~EXPEDITED;
3577c478bd9Sstevel@tonic-gate }
3587c478bd9Sstevel@tonic-gate
3597c478bd9Sstevel@tonic-gate /*
3607c478bd9Sstevel@tonic-gate * No real state change on T_RCV events (It is a NOOP)
3617c478bd9Sstevel@tonic-gate *
3627c478bd9Sstevel@tonic-gate * We invoke the macro only for error logging
3637c478bd9Sstevel@tonic-gate * part of its capabilities when in a bad state.
3647c478bd9Sstevel@tonic-gate */
3657c478bd9Sstevel@tonic-gate _T_TX_NEXTSTATE(T_RCV, tiptr,
3667c478bd9Sstevel@tonic-gate "t_rcv: state invalid T_RCV event");
3677c478bd9Sstevel@tonic-gate if (didalloc)
3687c478bd9Sstevel@tonic-gate free(ctlbuf.buf);
3697c478bd9Sstevel@tonic-gate else
3707c478bd9Sstevel@tonic-gate tiptr->ti_ctlbuf = ctlbuf.buf;
3717c478bd9Sstevel@tonic-gate sig_mutex_unlock(&tiptr->ti_lock);
3727c478bd9Sstevel@tonic-gate return (databuf.len);
3737c478bd9Sstevel@tonic-gate }
3747c478bd9Sstevel@tonic-gate /* NOTREACHED */
3757c478bd9Sstevel@tonic-gate
3767c478bd9Sstevel@tonic-gate err_out:
3777c478bd9Sstevel@tonic-gate sv_errno = errno;
3787c478bd9Sstevel@tonic-gate if (didalloc)
3797c478bd9Sstevel@tonic-gate free(ctlbuf.buf);
3807c478bd9Sstevel@tonic-gate else
3817c478bd9Sstevel@tonic-gate tiptr->ti_ctlbuf = ctlbuf.buf;
3827c478bd9Sstevel@tonic-gate sig_mutex_unlock(&tiptr->ti_lock);
3837c478bd9Sstevel@tonic-gate
3847c478bd9Sstevel@tonic-gate errno = sv_errno;
3857c478bd9Sstevel@tonic-gate return (-1);
3867c478bd9Sstevel@tonic-gate }
387