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 /*
2461961e0fSrobinson  * Copyright 2005 Sun Microsystems, Inc.  All rights reserved.
257c478bd9Sstevel@tonic-gate  * Use is subject to license terms.
267c478bd9Sstevel@tonic-gate  */
27*d00075c7SMarcel Telka /*
28*d00075c7SMarcel Telka  * Copyright 2014 Nexenta Systems, Inc.  All rights reserved.
29*d00075c7SMarcel Telka  */
307c478bd9Sstevel@tonic-gate 
317c478bd9Sstevel@tonic-gate /*
327c478bd9Sstevel@tonic-gate  * t_sndudata.c and t_sndvudata.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 <syslog.h>
467c478bd9Sstevel@tonic-gate #include <assert.h>
477c478bd9Sstevel@tonic-gate #include "tx.h"
487c478bd9Sstevel@tonic-gate 
497c478bd9Sstevel@tonic-gate int
_tx_sndvudata(int fd,const struct t_unitdata * unitdata,struct t_iovec * tiov,unsigned int tiovcount,int api_semantics)507c478bd9Sstevel@tonic-gate _tx_sndvudata(int fd, const struct t_unitdata *unitdata, struct t_iovec *tiov,
517c478bd9Sstevel@tonic-gate     unsigned int tiovcount, int api_semantics)
527c478bd9Sstevel@tonic-gate {
537c478bd9Sstevel@tonic-gate 	struct T_unitdata_req *udreq;
547c478bd9Sstevel@tonic-gate 	struct strbuf ctlbuf;
557c478bd9Sstevel@tonic-gate 	struct strbuf databuf;
567c478bd9Sstevel@tonic-gate 	int size;
577c478bd9Sstevel@tonic-gate 	struct _ti_user *tiptr;
587c478bd9Sstevel@tonic-gate 	int sv_errno;
597c478bd9Sstevel@tonic-gate 	int didalloc;
60*d00075c7SMarcel Telka 	char *dataptr = NULL;
617c478bd9Sstevel@tonic-gate 	unsigned int nbytes;
627c478bd9Sstevel@tonic-gate 
637c478bd9Sstevel@tonic-gate 	assert(api_semantics == TX_XTI_XNS5_API);
6461961e0fSrobinson 	if ((tiptr = _t_checkfd(fd, 0, api_semantics)) == NULL)
657c478bd9Sstevel@tonic-gate 		return (-1);
667c478bd9Sstevel@tonic-gate 	sig_mutex_lock(&tiptr->ti_lock);
677c478bd9Sstevel@tonic-gate 
687c478bd9Sstevel@tonic-gate 	if (tiptr->ti_servtype != T_CLTS) {
697c478bd9Sstevel@tonic-gate 		t_errno = TNOTSUPPORT;
707c478bd9Sstevel@tonic-gate 		sig_mutex_unlock(&tiptr->ti_lock);
717c478bd9Sstevel@tonic-gate 		return (-1);
727c478bd9Sstevel@tonic-gate 	}
737c478bd9Sstevel@tonic-gate 
747c478bd9Sstevel@tonic-gate 	if (tiovcount == 0 || tiovcount > T_IOV_MAX) {
757c478bd9Sstevel@tonic-gate 		t_errno = TBADDATA;
767c478bd9Sstevel@tonic-gate 		sig_mutex_unlock(&tiptr->ti_lock);
777c478bd9Sstevel@tonic-gate 		return (-1);
787c478bd9Sstevel@tonic-gate 	}
797c478bd9Sstevel@tonic-gate 
807c478bd9Sstevel@tonic-gate 	if (tiptr->ti_state != T_IDLE) {
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 	nbytes = _t_bytecount_upto_intmax(tiov, tiovcount);
877c478bd9Sstevel@tonic-gate 
887c478bd9Sstevel@tonic-gate 	if ((nbytes == 0) &&
897c478bd9Sstevel@tonic-gate 	    !(tiptr->ti_prov_flag & (SENDZERO|OLD_SENDZERO))) {
907c478bd9Sstevel@tonic-gate 		t_errno = TBADDATA;
917c478bd9Sstevel@tonic-gate 		sig_mutex_unlock(&tiptr->ti_lock);
927c478bd9Sstevel@tonic-gate 		return (-1);
937c478bd9Sstevel@tonic-gate 	}
947c478bd9Sstevel@tonic-gate 
957c478bd9Sstevel@tonic-gate 	if ((tiptr->ti_maxpsz > 0) && (nbytes > (uint32_t)tiptr->ti_maxpsz)) {
967c478bd9Sstevel@tonic-gate 		t_errno = TBADDATA;
977c478bd9Sstevel@tonic-gate 		sv_errno = errno;
987c478bd9Sstevel@tonic-gate 		sig_mutex_unlock(&tiptr->ti_lock);
997c478bd9Sstevel@tonic-gate 		errno = sv_errno;
1007c478bd9Sstevel@tonic-gate 		return (-1);
1017c478bd9Sstevel@tonic-gate 	}
1027c478bd9Sstevel@tonic-gate 
1037c478bd9Sstevel@tonic-gate 	/*
1047c478bd9Sstevel@tonic-gate 	 * Acquire ctlbuf for use in sending/receiving control part
1057c478bd9Sstevel@tonic-gate 	 * of the message.
1067c478bd9Sstevel@tonic-gate 	 */
1077c478bd9Sstevel@tonic-gate 	if (_t_acquire_ctlbuf(tiptr, &ctlbuf, &didalloc) < 0) {
1087c478bd9Sstevel@tonic-gate 		sv_errno = errno;
1097c478bd9Sstevel@tonic-gate 		sig_mutex_unlock(&tiptr->ti_lock);
1107c478bd9Sstevel@tonic-gate 		errno = sv_errno;
1117c478bd9Sstevel@tonic-gate 		return (-1);
1127c478bd9Sstevel@tonic-gate 	}
1137c478bd9Sstevel@tonic-gate 
11461961e0fSrobinson 	/* LINTED pointer cast */
1157c478bd9Sstevel@tonic-gate 	udreq = (struct T_unitdata_req *)ctlbuf.buf;
1167c478bd9Sstevel@tonic-gate 
1177c478bd9Sstevel@tonic-gate 	udreq->PRIM_type = T_UNITDATA_REQ;
1187c478bd9Sstevel@tonic-gate 	udreq->DEST_length = unitdata->addr.len;
1197c478bd9Sstevel@tonic-gate 	udreq->DEST_offset = 0;
1207c478bd9Sstevel@tonic-gate 	udreq->OPT_length = unitdata->opt.len;
1217c478bd9Sstevel@tonic-gate 	udreq->OPT_offset = 0;
1227c478bd9Sstevel@tonic-gate 	size = (int)sizeof (struct T_unitdata_req);
1237c478bd9Sstevel@tonic-gate 
1247c478bd9Sstevel@tonic-gate 	if (unitdata->addr.len) {
1257c478bd9Sstevel@tonic-gate 		if (_t_aligned_copy(&ctlbuf, unitdata->addr.len, size,
1267c478bd9Sstevel@tonic-gate 		    unitdata->addr.buf, &udreq->DEST_offset) < 0) {
1277c478bd9Sstevel@tonic-gate 			/*
1287c478bd9Sstevel@tonic-gate 			 * Aligned copy based will overflow buffer
1297c478bd9Sstevel@tonic-gate 			 * allocated based on maximum transport address
1307c478bd9Sstevel@tonic-gate 			 * size information
1317c478bd9Sstevel@tonic-gate 			 */
1327c478bd9Sstevel@tonic-gate 			t_errno = TSYSERR;
1337c478bd9Sstevel@tonic-gate 			errno = EPROTO;
1347c478bd9Sstevel@tonic-gate 			goto err_out;
1357c478bd9Sstevel@tonic-gate 		}
1367c478bd9Sstevel@tonic-gate 		size = udreq->DEST_offset + udreq->DEST_length;
1377c478bd9Sstevel@tonic-gate 	}
1387c478bd9Sstevel@tonic-gate 	if (unitdata->opt.len) {
1397c478bd9Sstevel@tonic-gate 		if (_t_aligned_copy(&ctlbuf, unitdata->opt.len, size,
1407c478bd9Sstevel@tonic-gate 		    unitdata->opt.buf, &udreq->OPT_offset) < 0) {
1417c478bd9Sstevel@tonic-gate 			/*
1427c478bd9Sstevel@tonic-gate 			 * Aligned copy based will overflow buffer
1437c478bd9Sstevel@tonic-gate 			 * allocated based on maximum transport option
1447c478bd9Sstevel@tonic-gate 			 * size information
1457c478bd9Sstevel@tonic-gate 			 */
1467c478bd9Sstevel@tonic-gate 			t_errno = TSYSERR;
1477c478bd9Sstevel@tonic-gate 			errno = EPROTO;
1487c478bd9Sstevel@tonic-gate 			goto err_out;
1497c478bd9Sstevel@tonic-gate 		}
1507c478bd9Sstevel@tonic-gate 		size = udreq->OPT_offset + udreq->OPT_length;
1517c478bd9Sstevel@tonic-gate 	}
1527c478bd9Sstevel@tonic-gate 
1537c478bd9Sstevel@tonic-gate 	if (size > (int)ctlbuf.maxlen) {
1547c478bd9Sstevel@tonic-gate 		t_errno = TSYSERR;
1557c478bd9Sstevel@tonic-gate 		errno = EIO;
1567c478bd9Sstevel@tonic-gate 		goto err_out;
1577c478bd9Sstevel@tonic-gate 	}
1587c478bd9Sstevel@tonic-gate 
1597c478bd9Sstevel@tonic-gate 	ctlbuf.len = size;
1607c478bd9Sstevel@tonic-gate 
1617c478bd9Sstevel@tonic-gate 	if (nbytes != 0) {
1627c478bd9Sstevel@tonic-gate 		if ((dataptr = malloc((size_t)nbytes)) == NULL) {
1637c478bd9Sstevel@tonic-gate 			t_errno = TSYSERR;
1647c478bd9Sstevel@tonic-gate 			goto err_out;
1657c478bd9Sstevel@tonic-gate 		}
1667c478bd9Sstevel@tonic-gate 		_t_gather(dataptr, tiov, tiovcount);
1677c478bd9Sstevel@tonic-gate 	}
1687c478bd9Sstevel@tonic-gate 	databuf.buf = dataptr;
1697c478bd9Sstevel@tonic-gate 	databuf.len = nbytes;
1707c478bd9Sstevel@tonic-gate 	databuf.maxlen = nbytes;
1717c478bd9Sstevel@tonic-gate 	/*
1727c478bd9Sstevel@tonic-gate 	 * Calls to send data (write or putmsg) can potentially
1737c478bd9Sstevel@tonic-gate 	 * block, for MT case, we drop the lock and enable signals here
1747c478bd9Sstevel@tonic-gate 	 * and acquire it back
1757c478bd9Sstevel@tonic-gate 	 */
1767c478bd9Sstevel@tonic-gate 	sig_mutex_unlock(&tiptr->ti_lock);
1777c478bd9Sstevel@tonic-gate 	if (putmsg(fd, &ctlbuf, &databuf, 0) < 0) {
1787c478bd9Sstevel@tonic-gate 		if (errno == EAGAIN)
1797c478bd9Sstevel@tonic-gate 			t_errno = TFLOW;
1807c478bd9Sstevel@tonic-gate 		else
1817c478bd9Sstevel@tonic-gate 			t_errno = TSYSERR;
1827c478bd9Sstevel@tonic-gate 		sv_errno = errno;
1837c478bd9Sstevel@tonic-gate 		sig_mutex_lock(&tiptr->ti_lock);
1847c478bd9Sstevel@tonic-gate 		errno = sv_errno;
1857c478bd9Sstevel@tonic-gate 		goto err_out;
1867c478bd9Sstevel@tonic-gate 	}
1877c478bd9Sstevel@tonic-gate 	sig_mutex_lock(&tiptr->ti_lock);
1887c478bd9Sstevel@tonic-gate 
1897c478bd9Sstevel@tonic-gate 	_T_TX_NEXTSTATE(T_SNDUDATA, tiptr,
190*d00075c7SMarcel Telka 	    "t_sndvudata: invalid state event T_SNDUDATA");
1917c478bd9Sstevel@tonic-gate 	if (didalloc)
1927c478bd9Sstevel@tonic-gate 		free(ctlbuf.buf);
1937c478bd9Sstevel@tonic-gate 	else
1947c478bd9Sstevel@tonic-gate 		tiptr->ti_ctlbuf = ctlbuf.buf;
195*d00075c7SMarcel Telka 	free(dataptr);
1967c478bd9Sstevel@tonic-gate 	sig_mutex_unlock(&tiptr->ti_lock);
1977c478bd9Sstevel@tonic-gate 	return (0);
1987c478bd9Sstevel@tonic-gate err_out:
1997c478bd9Sstevel@tonic-gate 	sv_errno = errno;
2007c478bd9Sstevel@tonic-gate 	if (didalloc)
2017c478bd9Sstevel@tonic-gate 		free(ctlbuf.buf);
2027c478bd9Sstevel@tonic-gate 	else
2037c478bd9Sstevel@tonic-gate 		tiptr->ti_ctlbuf = ctlbuf.buf;
204*d00075c7SMarcel Telka 	free(dataptr);
2057c478bd9Sstevel@tonic-gate 	sig_mutex_unlock(&tiptr->ti_lock);
2067c478bd9Sstevel@tonic-gate 	errno = sv_errno;
2077c478bd9Sstevel@tonic-gate 	return (-1);
2087c478bd9Sstevel@tonic-gate }
209