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