/****************************************************************
 *								*
 * Copyright (c) 2001-2018 Fidelity National Information	*
 * Services, Inc. and/or its subsidiaries. All rights reserved.	*
 *								*
 *	This source code contains the intellectual property	*
 *	of its copyright holder(s), and is made available	*
 *	under a license.  If you do not know the terms of	*
 *	the license, please stop and do not read further.	*
 *								*
 ****************************************************************/

#include "mdef.h"

#include "gtm_string.h"
#include "gtm_fcntl.h"
#include "gtm_unistd.h"
#include "gtm_stat.h"
#include "gtm_iconv.h"
#include "gtm_netdb.h"
#include "gtm_socket.h"
#include "gtm_inet.h"
#include "gtm_stdlib.h"

#include <errno.h>
#include <sys/ioctl.h>

#include "io.h"
#include "iosp.h"
#include "iotimer.h"
#include "io_params.h"
#include "gt_timer.h"
#include "copy.h"
#include "iottdef.h"
#include "io_dev_dispatch.h"
#include "iormdef.h"
#include "eintr_wrappers.h"
#include "mmemory.h"
#include "gtm_caseconv.h"
#include "outofband.h"
#include "wake_alarm.h"
#include "stringpool.h"
#include "gtm_conv.h"
#include "gtm_utf8.h"
#include "gtmimagename.h"
#include "gtmio.h"
#include "op.h"
#include "indir_enum.h"

#define  LOGNAME_LEN 255
/* avoid calling getservbyname for shell and Kerberos shell */
#define	RSHELL_PORT		514
#define	KSHELL_PORT		544

GBLREF	dev_dispatch_struct	io_dev_dispatch[];
GBLREF	io_desc			*active_device;
GBLREF	mstr			sys_input;
GBLREF	mstr			sys_output;
GBLREF	bool			out_of_time;
GBLREF	int4			outofband;
GBLREF	int4			write_filter;

LITREF	mstr			chset_names[];
LITREF	unsigned char		io_params_size[];

error_def(ERR_GETNAMEINFO);
error_def(ERR_GTMEISDIR);
error_def(ERR_TEXT);

boolean_t io_open_try(io_log_name *naml, io_log_name *tl, mval *pp, int4 msec_timeout, mval *mspace)	/* timeout in msec */
{
	uint4		status;
	mstr		tn;		/* translated name */
	int		oflag;
	params		*param;
	unsigned char	ch;
	bool		timed = FALSE;
	int		file_des;
#	ifdef __MVS__
	int		file_des_w = -2;	/*	fifo write	*/
	uint4		status_w;
	d_rm_struct	*d_rm_out, *d_rm_in;
#	endif
	boolean_t	filecreated = FALSE;
	TID		timer_id;
	struct stat	outbuf;
	char		*buf, namebuf[LOGNAME_LEN + 1];
	unsigned char	dev_type[MAX_DEV_TYPE_LEN];
	iosb		io_status_blk;
	mstr		chset_mstr;
	int		umask_orig, umask_creat;
	int		char_or_block_special;
	int		stat_res;
	int		fstat_res;
	int		p_offset, len;
	boolean_t	mknod_err , stat_err, dir_err;
	int 		save_mknod_err, save_stat_err, save_gsn_err;
	int		gso_stat, gsn_stat, sockoptval;
	in_port_t	sockport;
	GTM_SOCKLEN_TYPE	socknamelen;
	struct sockaddr_storage	sockname;
	GTM_SOCKLEN_TYPE	sockoptlen;
	boolean_t	ichset_specified, ochset_specified;
	int		errcode;
	unsigned int	port_len;
	char		port_buffer[NI_MAXSERV], *port_ptr;
	io_desc		*iod, *temp_iod;
	DCL_THREADGBL_ACCESS;

	SETUP_THREADGBL_ACCESS;
	iod = naml->iod;
	char_or_block_special = FALSE;
	out_of_time = FALSE;
	file_des = -2;
	oflag = 0;
	mknod_err = FALSE;
	stat_err = FALSE;
	dir_err = FALSE;
	tn.len = tl->len;
	if (tn.len > LOGNAME_LEN)
		tn.len = LOGNAME_LEN;
	tn.addr = tl->dollar_io;
	memcpy(namebuf, tn.addr, tn.len);
	namebuf[tn.len] = '\0';
	buf = namebuf;
	timer_id = (TID)io_open_try;
	if (NO_M_TIMEOUT == msec_timeout)
		timed = FALSE;
	else
		timed = (0 != msec_timeout);
	if (0 == iod)
	{
		if (0 == tl->iod)
		{
			temp_iod =  (io_desc *)malloc(SIZEOF(io_desc));
			memset((char*)temp_iod, 0, SIZEOF(io_desc));
			temp_iod->pair.in  = temp_iod;
			temp_iod->pair.out = temp_iod;
			temp_iod->trans_name = tl;
			temp_iod->type = n_io_dev_types;
			p_offset = 0;
			while(iop_eol != *(pp->str.addr + p_offset))
			{
				ch = *(pp->str.addr + p_offset++);
				if (iop_fifo == ch)
					temp_iod->type = ff;
				else  if (iop_sequential == ch)
					temp_iod->type = rm;
				p_offset += ((IOP_VAR_SIZE == io_params_size[ch]) ?
					     (unsigned char)*(pp->str.addr + p_offset) + 1 : io_params_size[ch]);
			}
			if (ff == temp_iod->type)
			{
				/* fifo with RW permissions for owner, group, other */
				if ((-1 != MKNOD(buf, FIFO_PERMISSION, 0))
#					ifdef __MVS__
					|| (EEXIST == errno)
#					endif
					)
				{
#					ifdef __MVS__
					if (EEXIST != errno)
						filecreated = TRUE;
					/*	create another one for fifo write	*/
					temp_iod->pair.out = (io_desc *)malloc(SIZEOF(io_desc));
					(temp_iod->pair.out)->pair.in = temp_iod;
					(temp_iod->pair.out)->pair.out = (temp_iod->pair.out);
					(temp_iod->pair.out)->trans_name = tl;
					(temp_iod->pair.out)->type = ff;
#					else
					filecreated = TRUE;
#					endif
				} else  if (EEXIST != errno)
				{
					mknod_err = TRUE;
					save_mknod_err = errno;
					/* This save_err will be checked immediately after error_handler is set;
					 * In that way error handler will get the chance to handle any error
					 */
				}
			}
			tl->iod = temp_iod;
		}
		if ((n_io_dev_types == tl->iod->type) && mspace && mspace->str.len)
		{
			lower_to_upper(dev_type, (uchar_ptr_t)mspace->str.addr, mspace->str.len);
			if (((SIZEOF("SOCKET") - 1) == mspace->str.len) && (0 == MEMCMP_LIT(dev_type, "SOCKET")))
				tl->iod->type = gtmsocket;
			else if (((SIZEOF("PIPE") - 1) == mspace->str.len) && (0 == MEMCMP_LIT(dev_type, "PIPE")))
				tl->iod->type = pi;
			else
				tl->iod->type = us;
		}
		if (n_io_dev_types == tl->iod->type)
		{
			if (0 == memvcmp(tn.addr, tn.len, sys_input.addr, sys_input.len))
				file_des = 0;
			else if (0 == memvcmp(tn.addr, tn.len, sys_output.addr, sys_output.len))
				file_des = 1;
			if (0 == file_des || 1 == file_des)
			{
				FSTAT_FILE(file_des, &outbuf, fstat_res);
				if (-1 == fstat_res)
				{	/* save errno to be handled by exception handler if set */
					save_stat_err = errno;
					stat_err = TRUE;
				}
			}
			else if (0 == memvcmp(tn.addr, tn.len, LIT_AND_LEN("/dev/null")))
				tl->iod->type = nl;
			else
			{
				STAT_FILE(buf, &outbuf, stat_res);
				if ((-1 == stat_res) && (n_io_dev_types == tl->iod->type))
				{
					if (ENOENT == errno)
					{
						tl->iod->type = rm;
						filecreated = TRUE;
					} else
					{	/* save errno to be checked later */
						save_stat_err = errno;
						stat_err = TRUE;
					}
				}
			}
		}
		if (n_io_dev_types == tl->iod->type)
		{
			if (!stat_err)
			{
				switch(outbuf.st_mode & S_IFMT)
				{
					case S_IFCHR:
					case S_IFBLK:
						char_or_block_special = TRUE;
						break;
					case S_IFIFO:
						tl->iod->type = ff;
						break;
					case S_IFDIR:
						dir_err = TRUE;			/* directories should not be opened */
						/* no break in order to set iod->type value */
					case S_IFREG:
						tl->iod->type = rm;
						break;
					case S_IFSOCK:
						/* If SOCK_STREAM, AF_INET/AF_INET6, and not [kr]shell port assume we were
						 * started by inetd.
						 * We are not able to trigger exception until active_device set
						 * and exception parsed which is not done for fd == 0/1 which
						 * is from io_init called from gtm_startup before condition handlers
						 * are setup so we can't report errors, just will be treated as rm.
						 * Note the fall through if the above conditions are not true to
						 * maintain compatibility for rshd startup PER 3252.
						 * 28-JUL-1995 14:24:31 FERTIG REPLACE IO_OPEN_TRY.C(18)
						 * "PER 3252: fix problems starting up mumps from an ""rsh"" or ""remsh"""
						 *
						 * Different UNIX flavors behave differently when given an AF_UNIX socket,
						 * some errors and some setting sa_family to zero, so recognize each platform
						 * behavior and assume a local socket for those cases.
						 */
						sockoptlen = SIZEOF(sockoptval);
						gso_stat = getsockopt(file_des, SOL_SOCKET, SO_TYPE, &sockoptval,
								      (GTM_SOCKLEN_TYPE *)&sockoptlen);
						if (!gso_stat && SOCK_STREAM == sockoptval)
						{
							socknamelen = SIZEOF(sockname);
							gsn_stat = getsockname(file_des,
									(struct sockaddr *)&sockname,
									(GTM_SOCKLEN_TYPE *)&socknamelen);
							save_gsn_err = errno;
							if (!gsn_stat && ((AF_INET == ((sockaddr_ptr)&sockname)->sa_family)
									|| (AF_INET6 == ((sockaddr_ptr)&sockname)->sa_family)))
							{
								port_len = NI_MAXSERV;
								if (0 != (errcode = getnameinfo((struct sockaddr *)&sockname,
												socknamelen, NULL, 0,
												port_buffer, port_len,
												NI_NUMERICHOST)))
								{
									RTS_ERROR_ADDRINFO(NULL, ERR_GETNAMEINFO, errcode);
									return FALSE;
								}
								sockport=atoi(port_buffer);
								if (RSHELL_PORT != sockport && KSHELL_PORT != sockport)
								{
									tl->iod->type = gtmsocket;
									break;
								}
							}
							else if ((!gsn_stat && ((AF_UNIX == ((sockaddr_ptr)&sockname)->sa_family)
								|| (0 == socknamelen)
								|| (0 == ((sockaddr_ptr)&sockname)->sa_family)))
								|| (EOPNOTSUPP == save_gsn_err)
#								if defined(_AIX)
								|| (ENOTCONN == save_gsn_err)
#								endif
								)
							{
								tl->iod->type = gtmsocket;
								break;
							}
						}
						/* We don't expect any unusual socket types (e.g. SOCK_DGRAM) in testing,
						 * so assert instead of falling through in DEBUG.
						 */
						assert(NULL == "Unknown socket type");
						/* fall through */
					case 0:
						assert(NULL == "Zero file type");
						tl->iod->type = ff;
						break;
					default:
						assert(NULL == "Unknown value for (outbuf.st_mode & S_IFMT)");
						break;
				}
			}
		}
		naml->iod = iod = tl->iod;
	}
	assert((0 <= iod->state) && (n_io_dev_states > iod->state));
	active_device = iod;
	if ((-2 == file_des) && (dev_open != iod->state) && (us != iod->type)
	    && (gtmsocket != iod->type) && (pi != iod->type))
	{
		oflag |= (O_RDWR | O_CREAT | O_NOCTTY);
		p_offset = 0;
		ichset_specified = ochset_specified = FALSE;
		while(iop_eol != *(pp->str.addr + p_offset))
		{
			assert((params) *(pp->str.addr + p_offset) < (params)n_iops);
			switch ((ch = *(pp->str.addr + p_offset++)))
			{
				case iop_exception:
				{
					DEF_EXCEPTION(pp, p_offset, iod);
					break;
				}
				case iop_append:
					/* this deviceparameter will move the file pointer to EOF in iorm_open.c
					 * but will no longer force write to the EOF, so nothing to do here
					 */
					break;
				case iop_contiguous:
					break;
				case iop_newversion:
					if ((dev_open != iod->state) && (rm == iod->type))
						oflag |= O_TRUNC;
					break;
				case iop_readonly:
					oflag  &=  ~(O_RDWR | O_CREAT | O_WRONLY);
					oflag  |=  O_RDONLY;
					break;
				case iop_writeonly:
#					ifdef __MVS__
					if (ff != iod->type)
#					endif
					{
						oflag  &= ~(O_RDWR | O_RDONLY);
						oflag  |= O_WRONLY | O_CREAT;
					}
					break;
				case iop_ipchset:
#					ifdef KEEP_zOS_EBCDIC
					if ( (iconv_t)0 != iod->input_conv_cd )
					{
						ICONV_CLOSE_CD(iod->input_conv_cd);
					}
					SET_CODE_SET(iod->in_code_set, (char *)(pp->str.addr + p_offset + 1));
					if (DEFAULT_CODE_SET != iod->in_code_set)
						ICONV_OPEN_CD(iod->input_conv_cd,
							(char *)(pp->str.addr + p_offset + 1), INSIDE_CH_SET);
#					endif
					break;
				case iop_opchset:
#					ifdef KEEP_zOS_EBCDIC
					if ( (iconv_t)0 != iod->output_conv_cd)
					{
						ICONV_CLOSE_CD(iod->output_conv_cd);
					}
					SET_CODE_SET(iod->out_code_set, (char *)(pp->str.addr + p_offset + 1));
					if (DEFAULT_CODE_SET != iod->out_code_set)
						ICONV_OPEN_CD(iod->output_conv_cd, INSIDE_CH_SET,
							      (char *)(pp->str.addr + p_offset + 1));
#					endif
					break;
				case iop_m:
				case iop_utf8:
				case iop_utf16:
				case iop_utf16be:
				case iop_utf16le:
					break;
				default:
					break;
			}
			p_offset += ((IOP_VAR_SIZE == io_params_size[ch]) ?
				     (unsigned char)*(pp->str.addr + p_offset) + 1 : io_params_size[ch]);
		}
		/* Check the saved error from mknod() for fifo, also saved error from fstat() or stat()
		   so error handler (if set)  can handle it */
		if (ff == tl->iod->type  && mknod_err)
			rts_error_csa(CSA_ARG(NULL) VARLSTCNT(1) save_mknod_err);
		/* Error from either stat() or fstat() function */
		if (stat_err)
			rts_error_csa(CSA_ARG(NULL) VARLSTCNT(1) save_stat_err);
		/* Error from trying to open a dir */
		if (dir_err)
			rts_error_csa(CSA_ARG(NULL) VARLSTCNT(4) ERR_GTMEISDIR, 2, LEN_AND_STR(buf));
		if (timed)
			start_timer(timer_id, msec_timeout, wake_alarm, 0, NULL);
		/* RW permissions for owner and others as determined by umask. */
		umask_orig = umask(000);	/* determine umask (destructive) */
		(void)umask(umask_orig);	/* reset umask */
		umask_creat = 0666 & ~umask_orig;
		/* no OPEN EINTR macros in the following while loop  due to complex error checks and processing between
		 * top of while and calls to OPEN3
		 */
		while ((-1 == (file_des = OPEN3(buf, SETOCLOEXEC(oflag), umask_creat))) && !out_of_time)
		{
			if (timed && (0 == msec_timeout))
				out_of_time = TRUE;
			if (outofband)
				outofband_action(FALSE);
			if (EINTR == errno
					|| ETXTBSY == errno
					|| ENFILE == errno
					|| EBUSY == errno
					|| ((mb == iod->type) && (ENXIO == errno)))
				continue;
			else
			{
#				ifdef __MVS__
				if (EINVAL == errno && ff == tl->iod->type && (oflag & O_RDONLY) && (oflag & O_WRONLY))
				{
					int	oflag_clone;
					int	fcntl_res;
					/* oflag must be O_RDWR, set it to be O_RDONLY 	*/
					oflag &= ~O_WRONLY;
					oflag |= O_NONBLOCK;
					while ((-1 == (file_des = OPEN3(buf, SETOCLOEXEC(oflag), umask_creat))) && !out_of_time)
					{
						if (0 == msec_timeout)
							out_of_time = TRUE;
						if (outofband)
							outofband_action(FALSE);
						if (EINTR == errno
						       || ETXTBSY == errno
						       || ENFILE == errno
						       || EBUSY == errno
						       || ((mb == iod->type) && (ENXIO == errno)))
							continue;
						else
							break;
					}
					FCNTL2(file_des, F_GETFL, oflag_clone);
					FCNTL3(file_des, F_SETFL, (oflag_clone & ~O_NONBLOCK), fcntl_res);
					/* oflag was just made O_RDONLY, now set it to be O_WRONLY */
					oflag |= O_WRONLY;
					oflag &= ~O_RDONLY;
					while ((-1 == (file_des_w = OPEN3(buf, SETOCLOEXEC(oflag), umask_creat))) && !out_of_time)
					{
						if (0 == msec_timeout)
							out_of_time = TRUE;
						if (outofband)
							outofband_action(FALSE);
						if (EINTR == errno
						       || ETXTBSY == errno
						       || ENFILE == errno
						       || EBUSY == errno
						       || ((mb == iod->type) && (ENXIO == errno)))
							continue;
						else
							break;
					}
				}
#				endif
				break;
			}
		}
		SETFDCLOEXEC(file_des);
		if (timed && !out_of_time)
			cancel_timer(timer_id);
		if (out_of_time && (-1 == file_des))
		{
			if ((ff == tl->iod->type) && filecreated)
			{	/* The FIFO didn't really exist so remove all traces of it */
				status = UNLINK(tl->iod->trans_name->dollar_io);
				assert(!status);
				tl->iod->type = rm;
				remove_rms(tl->iod);
			}
			return FALSE;
		}
	}
#	ifdef KEEP_zOS_EBCDIC
	if (gtmsocket != iod->type)
	{
		SET_CODE_SET(iod->in_code_set, OUTSIDE_CH_SET);
		if (DEFAULT_CODE_SET != iod->in_code_set)
			ICONV_OPEN_CD(iod->input_conv_cd, OUTSIDE_CH_SET, INSIDE_CH_SET);
		SET_CODE_SET(iod->out_code_set, OUTSIDE_CH_SET);
		if (DEFAULT_CODE_SET != iod->out_code_set)
			ICONV_OPEN_CD(iod->output_conv_cd, INSIDE_CH_SET, OUTSIDE_CH_SET);
	} else
	{
		SET_CODE_SET(iod->out_code_set, INSIDE_CH_SET);
		if (DEFAULT_CODE_SET != iod->out_code_set)
			ICONV_OPEN_CD(iod->output_conv_cd, OUTSIDE_CH_SET, INSIDE_CH_SET);
		SET_CODE_SET(iod->in_code_set, INSIDE_CH_SET);
		if (DEFAULT_CODE_SET != iod->in_code_set)
			ICONV_OPEN_CD(iod->input_conv_cd, INSIDE_CH_SET, OUTSIDE_CH_SET);
	}
#	endif
	if (-1 == file_des)
		rts_error_csa(CSA_ARG(NULL) VARLSTCNT(1) errno);
	if (n_io_dev_types == iod->type)
	{
		/* On AIX, /dev/{,*}random are of 'terminal type'.Hence define its type before
		 * calling isatty()
		 */
		if ((0 == memvcmp(tn.addr, tn.len, LIT_AND_LEN("/dev/random")))
			|| (0 == memvcmp(tn.addr, tn.len, LIT_AND_LEN("/dev/urandom"))))
				tl->iod->type = rm;
		else if (isatty(file_des))
			iod->type = tt;
		else if (char_or_block_special && file_des > 2)
			if (0 == memvcmp(tn.addr, tn.len, LIT_AND_LEN("/dev/zero")))
				tl->iod->type = rm;
			else
				/* assume mag tape */
				iod->type = mt;
		else
			iod->type = rm;
	}
	assert(iod->type < n_io_dev_types);
	iod->disp_ptr = &io_dev_dispatch[iod->type];
	/* Do this deviceparameter check only if type is rm, it is closed, and no_destroy is defined. If a deviceparameter other
	 * than SEEK or APPEND is defined, then clear no_destroy as state will not be restored.
	 */
	if ((rm == iod->type) && (dev_closed == iod->state) && ((d_rm_struct *)iod->dev_sp)->no_destroy)
	{
		for (p_offset = 0; iop_eol != *(pp->str.addr + p_offset); p_offset += ((IOP_VAR_SIZE == io_params_size[ch])
				? (unsigned char)*(pp->str.addr + p_offset) + 1 : io_params_size[ch]))
		{
			ch = *(pp->str.addr + p_offset++);
			assert((params)ch < (params)n_iops);
			if ((iop_seek != ch) && (iop_append != ch))
			{
				((d_rm_struct *)iod->dev_sp)->no_destroy = FALSE;
				break;
			}
		}
	}
	if (dev_never_opened == iod->state)
	{
		iod->wrap = DEFAULT_IOD_WRAP;
		iod->width = DEFAULT_IOD_WIDTH;
		iod->length = DEFAULT_IOD_LENGTH;
		iod->write_filter = write_filter;
	}
	if (dev_open != iod->state)
	{	/* initialize x and y unless it is closed and rm and no_destroy is TRUE */
		if (!((dev_closed == iod->state) && (rm == iod->type) &&
		    ((d_rm_struct *)iod->dev_sp)->no_destroy))
		{
			iod->dollar.x = 0;
			iod->dollar.y = 0;
		}
		iod->dollar.za = 0;
		iod->dollar.zb[0] = 0;
		iod->dollar.key[0] = 0;
		iod->dollar.device[0] = 0;
		if (iod->dollar.devicebuffer)
			free(iod->dollar.devicebuffer);
		iod->dollar.devicebuffer = NULL;
	}
#	ifdef __MVS__
	/*	copy over the content of tl->iod(iod) to (tl->iod->pair.out)	*/
	if (ff == tl->iod->type)
	{
		*(tl->iod->pair.out) = *(tl->iod);
		(tl->iod->pair.out)->pair.in = tl->iod;
		(tl->iod->pair.out)->pair.out = (tl->iod->pair.out);
		assert((0 <= tl->iod->pair.out->state) && (n_io_dev_states > tl->iod->pair.out->state));
		if (-1 < file_des_w)
		{
			io_desc		*io_ptr;
			io_log_name	dev_name;	/*	dummy	*/
			io_ptr = (tl->iod->pair.out);
			assert(io_ptr != tl->iod->pair.in);
			assert(NULL != io_ptr);
			assert(io_ptr->state >= 0 && io_ptr->state < n_io_dev_states);
			assert(ff == io_ptr->type);
			dev_name.iod = tl->iod->pair.out;
			if (TRUE == ioff_open(&dev_name, pp, file_des_w, mspace, msec_timeout))
				(tl->iod->pair.out)->state = dev_open;
			else if (dev_open == (tl->iod->pair.out)->state)
				(tl->iod->pair.out)->state = dev_closed;
		}
		else if ((-2 == file_des_w) && (O_WRONLY == (oflag & O_ACCMODE)))
			active_device = naml->iod = iod = tl->iod->pair.out;
		if (0 == file_des_w)
			(tl->iod->pair.out)->dollar.zeof = TRUE;
	}
#	endif
	iod->newly_created = filecreated;
	status = (iod->disp_ptr->open)(naml, pp, file_des, mspace, msec_timeout);
	if (TRUE == status)
		iod->state = dev_open;
	else
	{
		if ((dev_open == iod->state) && (gtmsocket != iod->type))
			iod->state = dev_closed;
		if ((gtmsocket == iod->type) && iod->newly_created)
		{
			assert (iod->state != dev_open);
			iosocket_destroy(iod);
			active_device = 0;
			return status;
		}
	}
#	ifdef __MVS__
	d_rm_out = tl->iod->pair.out->dev_sp;
	d_rm_in = tl->iod->pair.in->dev_sp;
	if ((ff == tl->iod->pair.in->type) || (ff == tl->iod->pair.out->type))
	{
		if (NULL == d_rm_in)
		{
			tl->iod->pair.in->type = rm;
			tl->iod->pair.in->state = tl->iod->pair.out->state;
			tl->iod->pair.in->dev_sp = d_rm_out;
		}
		else if (NULL == d_rm_out)
		{
			tl->iod->pair.out->type = rm;
			tl->iod->pair.out->state = tl->iod->pair.in->state;
			tl->iod->pair.out->dev_sp = d_rm_in;
			d_rm_in->read_fildes = FD_INVALID;
		}
	}
	if (-1 < file_des_w)
	{
		d_rm_out->read_fildes = d_rm_in->fildes;
		d_rm_out->read_filstr = d_rm_in->filstr;
		free(d_rm_in);
		tl->iod->pair.in->dev_sp = d_rm_out;
	}
#	endif
	if (1 == file_des)
		iod->dollar.zeof = TRUE;
	active_device = 0;
	iod->newly_created = FALSE;
	if ((NO_M_TIMEOUT != msec_timeout) && IS_MCODE_RUNNING)
		return (status);
	else
		return TRUE;
}