Blame winpr/libwinpr/comm/comm_io.c

Packit Service fa4841
/**
Packit Service fa4841
 * WinPR: Windows Portable Runtime
Packit Service fa4841
 * Serial Communication API
Packit Service fa4841
 *
Packit Service fa4841
 * Copyright 2014 Hewlett-Packard Development Company, L.P.
Packit Service fa4841
 *
Packit Service fa4841
 * Licensed under the Apache License, Version 2.0 (the "License");
Packit Service fa4841
 * you may not use this file except in compliance with the License.
Packit Service fa4841
 * You may obtain a copy of the License at
Packit Service fa4841
 *
Packit Service fa4841
 *     http://www.apache.org/licenses/LICENSE-2.0
Packit Service fa4841
 *
Packit Service fa4841
 * Unless required by applicable law or agreed to in writing, software
Packit Service fa4841
 * distributed under the License is distributed on an "AS IS" BASIS,
Packit Service fa4841
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
Packit Service fa4841
 * See the License for the specific language governing permissions and
Packit Service fa4841
 * limitations under the License.
Packit Service fa4841
 */
Packit Service fa4841
Packit Service fa4841
#ifdef HAVE_CONFIG_H
Packit Service fa4841
#include "config.h"
Packit Service fa4841
#endif
Packit Service fa4841
Packit Service fa4841
#if defined __linux__ && !defined ANDROID
Packit Service fa4841
Packit Service fa4841
#include <assert.h>
Packit Service fa4841
#include <errno.h>
Packit Service fa4841
#include <termios.h>
Packit Service fa4841
#include <unistd.h>
Packit Service fa4841
Packit Service fa4841
#include <winpr/io.h>
Packit Service fa4841
#include <winpr/wlog.h>
Packit Service fa4841
#include <winpr/wtypes.h>
Packit Service fa4841
Packit Service fa4841
#include "comm.h"
Packit Service fa4841
Packit Service fa4841
BOOL _comm_set_permissive(HANDLE hDevice, BOOL permissive)
Packit Service fa4841
{
Packit Service fa4841
	WINPR_COMM* pComm = (WINPR_COMM*)hDevice;
Packit Service fa4841
Packit Service fa4841
	if (hDevice == INVALID_HANDLE_VALUE)
Packit Service fa4841
	{
Packit Service fa4841
		SetLastError(ERROR_INVALID_HANDLE);
Packit Service fa4841
		return FALSE;
Packit Service fa4841
	}
Packit Service fa4841
Packit Service fa4841
	if (!pComm || pComm->Type != HANDLE_TYPE_COMM)
Packit Service fa4841
	{
Packit Service fa4841
		SetLastError(ERROR_INVALID_HANDLE);
Packit Service fa4841
		return FALSE;
Packit Service fa4841
	}
Packit Service fa4841
Packit Service fa4841
	pComm->permissive = permissive;
Packit Service fa4841
	return TRUE;
Packit Service fa4841
}
Packit Service fa4841
Packit Service fa4841
/* Computes VTIME in deciseconds from Ti in milliseconds */
Packit Service fa4841
static UCHAR _vtime(ULONG Ti)
Packit Service fa4841
{
Packit Service fa4841
	/* FIXME: look for an equivalent math function otherwise let
Packit Service fa4841
	 * do the compiler do the optimization */
Packit Service fa4841
	if (Ti == 0)
Packit Service fa4841
		return 0;
Packit Service fa4841
	else if (Ti < 100)
Packit Service fa4841
		return 1;
Packit Service fa4841
	else if (Ti > 25500)
Packit Service fa4841
		return 255; /* 0xFF */
Packit Service fa4841
	else
Packit Service fa4841
		return Ti / 100;
Packit Service fa4841
}
Packit Service fa4841
Packit Service fa4841
/**
Packit Service fa4841
 * ERRORS:
Packit Service fa4841
 *   ERROR_INVALID_HANDLE
Packit Service fa4841
 *   ERROR_NOT_SUPPORTED
Packit Service fa4841
 *   ERROR_INVALID_PARAMETER
Packit Service fa4841
 *   ERROR_TIMEOUT
Packit Service fa4841
 *   ERROR_IO_DEVICE
Packit Service fa4841
 *   ERROR_BAD_DEVICE
Packit Service fa4841
 */
Packit Service fa4841
BOOL CommReadFile(HANDLE hDevice, LPVOID lpBuffer, DWORD nNumberOfBytesToRead,
Packit Service fa4841
                  LPDWORD lpNumberOfBytesRead, LPOVERLAPPED lpOverlapped)
Packit Service fa4841
{
Packit Service fa4841
	WINPR_COMM* pComm = (WINPR_COMM*)hDevice;
Packit Service fa4841
	int biggestFd = -1;
Packit Service fa4841
	fd_set read_set;
Packit Service fa4841
	int nbFds;
Packit Service fa4841
	COMMTIMEOUTS* pTimeouts;
Packit Service fa4841
	UCHAR vmin = 0;
Packit Service fa4841
	UCHAR vtime = 0;
Packit Service fa4841
	ULONGLONG Tmax = 0;
Packit Service fa4841
	struct timeval tmaxTimeout, *pTmaxTimeout;
Packit Service fa4841
	struct termios currentTermios;
Packit Service fa4841
	EnterCriticalSection(&pComm->ReadLock); /* KISSer by the function's beginning */
Packit Service fa4841
Packit Service fa4841
	if (hDevice == INVALID_HANDLE_VALUE)
Packit Service fa4841
	{
Packit Service fa4841
		SetLastError(ERROR_INVALID_HANDLE);
Packit Service fa4841
		goto return_false;
Packit Service fa4841
	}
Packit Service fa4841
Packit Service fa4841
	if (!pComm || pComm->Type != HANDLE_TYPE_COMM)
Packit Service fa4841
	{
Packit Service fa4841
		SetLastError(ERROR_INVALID_HANDLE);
Packit Service fa4841
		goto return_false;
Packit Service fa4841
	}
Packit Service fa4841
Packit Service fa4841
	if (lpOverlapped != NULL)
Packit Service fa4841
	{
Packit Service fa4841
		SetLastError(ERROR_NOT_SUPPORTED);
Packit Service fa4841
		goto return_false;
Packit Service fa4841
	}
Packit Service fa4841
Packit Service fa4841
	if (lpNumberOfBytesRead == NULL)
Packit Service fa4841
	{
Packit Service fa4841
		SetLastError(ERROR_INVALID_PARAMETER); /* since we doesn't suppport lpOverlapped != NULL */
Packit Service fa4841
		goto return_false;
Packit Service fa4841
	}
Packit Service fa4841
Packit Service fa4841
	*lpNumberOfBytesRead = 0; /* will be ajusted if required ... */
Packit Service fa4841
Packit Service fa4841
	if (nNumberOfBytesToRead <= 0) /* N */
Packit Service fa4841
	{
Packit Service fa4841
		goto return_true; /* FIXME: or FALSE? */
Packit Service fa4841
	}
Packit Service fa4841
Packit Service fa4841
	if (tcgetattr(pComm->fd, &currentTermios) < 0)
Packit Service fa4841
	{
Packit Service fa4841
		SetLastError(ERROR_IO_DEVICE);
Packit Service fa4841
		goto return_false;
Packit Service fa4841
	}
Packit Service fa4841
Packit Service fa4841
	if (currentTermios.c_lflag & ICANON)
Packit Service fa4841
	{
Packit Service fa4841
		CommLog_Print(WLOG_WARN, "Canonical mode not supported"); /* the timeout could not be set */
Packit Service fa4841
		SetLastError(ERROR_NOT_SUPPORTED);
Packit Service fa4841
		goto return_false;
Packit Service fa4841
	}
Packit Service fa4841
Packit Service fa4841
	/* http://msdn.microsoft.com/en-us/library/hh439614%28v=vs.85%29.aspx
Packit Service fa4841
	 * http://msdn.microsoft.com/en-us/library/windows/hardware/hh439614%28v=vs.85%29.aspx
Packit Service fa4841
	 *
Packit Service fa4841
	 * ReadIntervalTimeout  | ReadTotalTimeoutMultiplier | ReadTotalTimeoutConstant | VMIN | VTIME |
Packit Service fa4841
	 * TMAX  | 0            |            0               |           0              |   N  |   0   |
Packit Service fa4841
	 * INDEF | Blocks for N bytes available. 0< Ti 
Packit Service fa4841
	 * N  |   Ti  | INDEF | Blocks on first byte, then use Ti between bytes. MAXULONG       | 0 | 0
Packit Service fa4841
	 * |   0  |   0   |   0   | Returns immediately with bytes available (don't block) MAXULONG |
Packit Service fa4841
	 * MAXULONG           |      0< Tc 
Packit Service fa4841
	 * during Tc or returns immediately whith bytes available MAXULONG       |            m |
Packit Service fa4841
	 * MAXULONG          |                      | Invalid 0            |            m |      0< Tc
Packit Service fa4841
	 * 
Packit Service fa4841
	 * immediately whith bytes available 0< Ti 
Packit Service fa4841
	 * Tc 
Packit Service fa4841
	 * Tmax is used for the whole system call.
Packit Service fa4841
	 */
Packit Service fa4841
	/* NB: timeouts are in milliseconds, VTIME are in deciseconds and is an unsigned char */
Packit Service fa4841
	/* FIXME: double check whether open(pComm->fd_read_event, O_NONBLOCK) doesn't conflict with
Packit Service fa4841
	 * above use cases */
Packit Service fa4841
	pTimeouts = &(pComm->timeouts);
Packit Service fa4841
Packit Service fa4841
	if ((pTimeouts->ReadIntervalTimeout == MAXULONG) &&
Packit Service fa4841
	    (pTimeouts->ReadTotalTimeoutConstant == MAXULONG))
Packit Service fa4841
	{
Packit Service fa4841
		CommLog_Print(
Packit Service fa4841
		    WLOG_WARN,
Packit Service fa4841
		    "ReadIntervalTimeout and ReadTotalTimeoutConstant cannot be both set to MAXULONG");
Packit Service fa4841
		SetLastError(ERROR_INVALID_PARAMETER);
Packit Service fa4841
		goto return_false;
Packit Service fa4841
	}
Packit Service fa4841
Packit Service fa4841
	/* VMIN */
Packit Service fa4841
Packit Service fa4841
	if ((pTimeouts->ReadIntervalTimeout == MAXULONG) &&
Packit Service fa4841
	    (pTimeouts->ReadTotalTimeoutMultiplier == 0) && (pTimeouts->ReadTotalTimeoutConstant == 0))
Packit Service fa4841
	{
Packit Service fa4841
		vmin = 0;
Packit Service fa4841
	}
Packit Service fa4841
	else
Packit Service fa4841
	{
Packit Service fa4841
		/* N */
Packit Service fa4841
		/* vmin = nNumberOfBytesToRead < 256 ? nNumberOfBytesToRead : 255;*/ /* 0xFF */
Packit Service fa4841
		/* NB: we might wait endlessly with vmin=N, prefer to
Packit Service fa4841
		 * force vmin=1 and return with bytes
Packit Service fa4841
		 * available. FIXME: is a feature disarded here? */
Packit Service fa4841
		vmin = 1;
Packit Service fa4841
	}
Packit Service fa4841
Packit Service fa4841
	/* VTIME */
Packit Service fa4841
Packit Service fa4841
	if ((pTimeouts->ReadIntervalTimeout > 0) && (pTimeouts->ReadIntervalTimeout < MAXULONG))
Packit Service fa4841
	{
Packit Service fa4841
		/* Ti */
Packit Service fa4841
		vtime = _vtime(pTimeouts->ReadIntervalTimeout);
Packit Service fa4841
	}
Packit Service fa4841
Packit Service fa4841
	/* TMAX */
Packit Service fa4841
	pTmaxTimeout = &tmaxTimeout;
Packit Service fa4841
Packit Service fa4841
	if ((pTimeouts->ReadIntervalTimeout == MAXULONG) &&
Packit Service fa4841
	    (pTimeouts->ReadTotalTimeoutMultiplier == MAXULONG))
Packit Service fa4841
	{
Packit Service fa4841
		/* Tc */
Packit Service fa4841
		Tmax = pTimeouts->ReadTotalTimeoutConstant;
Packit Service fa4841
	}
Packit Service fa4841
	else
Packit Service fa4841
	{
Packit Service fa4841
		/* Tmax */
Packit Service fa4841
		Tmax = nNumberOfBytesToRead * pTimeouts->ReadTotalTimeoutMultiplier +
Packit Service fa4841
		       pTimeouts->ReadTotalTimeoutConstant;
Packit Service fa4841
Packit Service fa4841
		/* INDEFinitely */
Packit Service fa4841
		if ((Tmax == 0) && (pTimeouts->ReadIntervalTimeout < MAXULONG) &&
Packit Service fa4841
		    (pTimeouts->ReadTotalTimeoutMultiplier == 0))
Packit Service fa4841
			pTmaxTimeout = NULL;
Packit Service fa4841
	}
Packit Service fa4841
Packit Service fa4841
	if ((currentTermios.c_cc[VMIN] != vmin) || (currentTermios.c_cc[VTIME] != vtime))
Packit Service fa4841
	{
Packit Service fa4841
		currentTermios.c_cc[VMIN] = vmin;
Packit Service fa4841
		currentTermios.c_cc[VTIME] = vtime;
Packit Service fa4841
Packit Service fa4841
		if (tcsetattr(pComm->fd, TCSANOW, &currentTermios) < 0)
Packit Service fa4841
		{
Packit Service fa4841
			CommLog_Print(WLOG_WARN,
Packit Service fa4841
			              "CommReadFile failure, could not apply new timeout values: VMIN=%" PRIu8
Packit Service fa4841
			              ", VTIME=%" PRIu8 "",
Packit Service fa4841
			              vmin, vtime);
Packit Service fa4841
			SetLastError(ERROR_IO_DEVICE);
Packit Service fa4841
			goto return_false;
Packit Service fa4841
		}
Packit Service fa4841
	}
Packit Service fa4841
Packit Service fa4841
	/* wait indefinitely if pTmaxTimeout is NULL */
Packit Service fa4841
Packit Service fa4841
	if (pTmaxTimeout != NULL)
Packit Service fa4841
	{
Packit Service fa4841
		ZeroMemory(pTmaxTimeout, sizeof(struct timeval));
Packit Service fa4841
Packit Service fa4841
		if (Tmax > 0) /* return immdiately if Tmax == 0 */
Packit Service fa4841
		{
Packit Service fa4841
			pTmaxTimeout->tv_sec = Tmax / 1000;           /* s */
Packit Service fa4841
			pTmaxTimeout->tv_usec = (Tmax % 1000) * 1000; /* us */
Packit Service fa4841
		}
Packit Service fa4841
	}
Packit Service fa4841
Packit Service fa4841
	/* FIXME: had expected eventfd_write() to return EAGAIN when
Packit Service fa4841
	 * there is no eventfd_read() but this not the case. */
Packit Service fa4841
	/* discard a possible and no more relevant event */
Packit Service fa4841
	eventfd_read(pComm->fd_read_event, NULL);
Packit Service fa4841
	biggestFd = pComm->fd_read;
Packit Service fa4841
Packit Service fa4841
	if (pComm->fd_read_event > biggestFd)
Packit Service fa4841
		biggestFd = pComm->fd_read_event;
Packit Service fa4841
Packit Service fa4841
	FD_ZERO(&read_set);
Packit Service fa4841
	assert(pComm->fd_read_event < FD_SETSIZE);
Packit Service fa4841
	assert(pComm->fd_read < FD_SETSIZE);
Packit Service fa4841
	FD_SET(pComm->fd_read_event, &read_set);
Packit Service fa4841
	FD_SET(pComm->fd_read, &read_set);
Packit Service fa4841
	nbFds = select(biggestFd + 1, &read_set, NULL, NULL, pTmaxTimeout);
Packit Service fa4841
Packit Service fa4841
	if (nbFds < 0)
Packit Service fa4841
	{
Packit Service fa4841
		CommLog_Print(WLOG_WARN, "select() failure, errno=[%d] %s\n", errno, strerror(errno));
Packit Service fa4841
		SetLastError(ERROR_IO_DEVICE);
Packit Service fa4841
		goto return_false;
Packit Service fa4841
	}
Packit Service fa4841
Packit Service fa4841
	if (nbFds == 0)
Packit Service fa4841
	{
Packit Service fa4841
		/* timeout */
Packit Service fa4841
		SetLastError(ERROR_TIMEOUT);
Packit Service fa4841
		goto return_false;
Packit Service fa4841
	}
Packit Service fa4841
Packit Service fa4841
	/* read_set */
Packit Service fa4841
Packit Service fa4841
	if (FD_ISSET(pComm->fd_read_event, &read_set))
Packit Service fa4841
	{
Packit Service fa4841
		eventfd_t event = 0;
Packit Service fa4841
Packit Service fa4841
		if (eventfd_read(pComm->fd_read_event, &event) < 0)
Packit Service fa4841
		{
Packit Service fa4841
			if (errno == EAGAIN)
Packit Service fa4841
			{
Packit Service fa4841
				assert(FALSE); /* not quite sure this should ever happen */
Packit Service fa4841
				               /* keep on */
Packit Service fa4841
			}
Packit Service fa4841
			else
Packit Service fa4841
			{
Packit Service fa4841
				CommLog_Print(WLOG_WARN,
Packit Service fa4841
				              "unexpected error on reading fd_read_event, errno=[%d] %s\n", errno,
Packit Service fa4841
				              strerror(errno));
Packit Service fa4841
				/* FIXME: goto return_false ? */
Packit Service fa4841
			}
Packit Service fa4841
Packit Service fa4841
			assert(errno == EAGAIN);
Packit Service fa4841
		}
Packit Service fa4841
Packit Service fa4841
		if (event == FREERDP_PURGE_RXABORT)
Packit Service fa4841
		{
Packit Service fa4841
			SetLastError(ERROR_CANCELLED);
Packit Service fa4841
			goto return_false;
Packit Service fa4841
		}
Packit Service fa4841
Packit Service fa4841
		assert(event == FREERDP_PURGE_RXABORT); /* no other expected event so far */
Packit Service fa4841
	}
Packit Service fa4841
Packit Service fa4841
	if (FD_ISSET(pComm->fd_read, &read_set))
Packit Service fa4841
	{
Packit Service fa4841
		ssize_t nbRead = 0;
Packit Service fa4841
		nbRead = read(pComm->fd_read, lpBuffer, nNumberOfBytesToRead);
Packit Service fa4841
Packit Service fa4841
		if (nbRead < 0)
Packit Service fa4841
		{
Packit Service fa4841
			CommLog_Print(WLOG_WARN,
Packit Service fa4841
			              "CommReadFile failed, ReadIntervalTimeout=%" PRIu32
Packit Service fa4841
			              ", ReadTotalTimeoutMultiplier=%" PRIu32
Packit Service fa4841
			              ", ReadTotalTimeoutConstant=%" PRIu32 " VMIN=%u, VTIME=%u",
Packit Service fa4841
			              pTimeouts->ReadIntervalTimeout, pTimeouts->ReadTotalTimeoutMultiplier,
Packit Service fa4841
			              pTimeouts->ReadTotalTimeoutConstant, currentTermios.c_cc[VMIN],
Packit Service fa4841
			              currentTermios.c_cc[VTIME]);
Packit Service fa4841
			CommLog_Print(WLOG_WARN,
Packit Service fa4841
			              "CommReadFile failed, nNumberOfBytesToRead=%" PRIu32 ", errno=[%d] %s",
Packit Service fa4841
			              nNumberOfBytesToRead, errno, strerror(errno));
Packit Service fa4841
Packit Service fa4841
			if (errno == EAGAIN)
Packit Service fa4841
			{
Packit Service fa4841
				/* keep on */
Packit Service fa4841
				goto return_true; /* expect a read-loop to be implemented on the server side */
Packit Service fa4841
			}
Packit Service fa4841
			else if (errno == EBADF)
Packit Service fa4841
			{
Packit Service fa4841
				SetLastError(ERROR_BAD_DEVICE); /* STATUS_INVALID_DEVICE_REQUEST */
Packit Service fa4841
				goto return_false;
Packit Service fa4841
			}
Packit Service fa4841
			else
Packit Service fa4841
			{
Packit Service fa4841
				assert(FALSE);
Packit Service fa4841
				SetLastError(ERROR_IO_DEVICE);
Packit Service fa4841
				goto return_false;
Packit Service fa4841
			}
Packit Service fa4841
		}
Packit Service fa4841
Packit Service fa4841
		if (nbRead == 0)
Packit Service fa4841
		{
Packit Service fa4841
			/* termios timeout */
Packit Service fa4841
			SetLastError(ERROR_TIMEOUT);
Packit Service fa4841
			goto return_false;
Packit Service fa4841
		}
Packit Service fa4841
Packit Service fa4841
		*lpNumberOfBytesRead = nbRead;
Packit Service fa4841
Packit Service fa4841
		EnterCriticalSection(&pComm->EventsLock);
Packit Service fa4841
		if (pComm->PendingEvents & SERIAL_EV_FREERDP_WAITING)
Packit Service fa4841
		{
Packit Service fa4841
			if (pComm->eventChar != '\0' && memchr(lpBuffer, pComm->eventChar, nbRead))
Packit Service fa4841
				pComm->PendingEvents |= SERIAL_EV_RXCHAR;
Packit Service fa4841
		}
Packit Service fa4841
		LeaveCriticalSection(&pComm->EventsLock);
Packit Service fa4841
		goto return_true;
Packit Service fa4841
	}
Packit Service fa4841
Packit Service fa4841
	assert(FALSE);
Packit Service fa4841
	*lpNumberOfBytesRead = 0;
Packit Service fa4841
return_false:
Packit Service fa4841
	LeaveCriticalSection(&pComm->ReadLock);
Packit Service fa4841
	return FALSE;
Packit Service fa4841
return_true:
Packit Service fa4841
	LeaveCriticalSection(&pComm->ReadLock);
Packit Service fa4841
	return TRUE;
Packit Service fa4841
}
Packit Service fa4841
Packit Service fa4841
/**
Packit Service fa4841
 * ERRORS:
Packit Service fa4841
 *   ERROR_INVALID_HANDLE
Packit Service fa4841
 *   ERROR_NOT_SUPPORTED
Packit Service fa4841
 *   ERROR_INVALID_PARAMETER
Packit Service fa4841
 *   ERROR_BAD_DEVICE
Packit Service fa4841
 */
Packit Service fa4841
BOOL CommWriteFile(HANDLE hDevice, LPCVOID lpBuffer, DWORD nNumberOfBytesToWrite,
Packit Service fa4841
                   LPDWORD lpNumberOfBytesWritten, LPOVERLAPPED lpOverlapped)
Packit Service fa4841
{
Packit Service fa4841
	WINPR_COMM* pComm = (WINPR_COMM*)hDevice;
Packit Service fa4841
	struct timeval tmaxTimeout, *pTmaxTimeout;
Packit Service fa4841
	EnterCriticalSection(&pComm->WriteLock); /* KISSer by the function's beginning */
Packit Service fa4841
Packit Service fa4841
	if (hDevice == INVALID_HANDLE_VALUE)
Packit Service fa4841
	{
Packit Service fa4841
		SetLastError(ERROR_INVALID_HANDLE);
Packit Service fa4841
		goto return_false;
Packit Service fa4841
	}
Packit Service fa4841
Packit Service fa4841
	if (!pComm || pComm->Type != HANDLE_TYPE_COMM)
Packit Service fa4841
	{
Packit Service fa4841
		SetLastError(ERROR_INVALID_HANDLE);
Packit Service fa4841
		goto return_false;
Packit Service fa4841
	}
Packit Service fa4841
Packit Service fa4841
	if (lpOverlapped != NULL)
Packit Service fa4841
	{
Packit Service fa4841
		SetLastError(ERROR_NOT_SUPPORTED);
Packit Service fa4841
		goto return_false;
Packit Service fa4841
	}
Packit Service fa4841
Packit Service fa4841
	if (lpNumberOfBytesWritten == NULL)
Packit Service fa4841
	{
Packit Service fa4841
		SetLastError(ERROR_INVALID_PARAMETER); /* since we doesn't suppport lpOverlapped != NULL */
Packit Service fa4841
		goto return_false;
Packit Service fa4841
	}
Packit Service fa4841
Packit Service fa4841
	*lpNumberOfBytesWritten = 0; /* will be ajusted if required ... */
Packit Service fa4841
Packit Service fa4841
	if (nNumberOfBytesToWrite <= 0)
Packit Service fa4841
	{
Packit Service fa4841
		goto return_true; /* FIXME: or FALSE? */
Packit Service fa4841
	}
Packit Service fa4841
Packit Service fa4841
	/* FIXME: had expected eventfd_write() to return EAGAIN when
Packit Service fa4841
	 * there is no eventfd_read() but this not the case. */
Packit Service fa4841
	/* discard a possible and no more relevant event */
Packit Service fa4841
	eventfd_read(pComm->fd_write_event, NULL);
Packit Service fa4841
	/* ms */
Packit Service fa4841
	ULONGLONG Tmax = nNumberOfBytesToWrite * pComm->timeouts.WriteTotalTimeoutMultiplier +
Packit Service fa4841
	                 pComm->timeouts.WriteTotalTimeoutConstant;
Packit Service fa4841
	/* NB: select() may update the timeout argument to indicate
Packit Service fa4841
	 * how much time was left. Keep the timeout variable out of
Packit Service fa4841
	 * the while() */
Packit Service fa4841
	pTmaxTimeout = &tmaxTimeout;
Packit Service fa4841
	ZeroMemory(pTmaxTimeout, sizeof(struct timeval));
Packit Service fa4841
Packit Service fa4841
	if (Tmax > 0)
Packit Service fa4841
	{
Packit Service fa4841
		pTmaxTimeout->tv_sec = Tmax / 1000;           /* s */
Packit Service fa4841
		pTmaxTimeout->tv_usec = (Tmax % 1000) * 1000; /* us */
Packit Service fa4841
	}
Packit Service fa4841
	else if ((pComm->timeouts.WriteTotalTimeoutMultiplier == 0) &&
Packit Service fa4841
	         (pComm->timeouts.WriteTotalTimeoutConstant == 0))
Packit Service fa4841
	{
Packit Service fa4841
		pTmaxTimeout = NULL;
Packit Service fa4841
	}
Packit Service fa4841
Packit Service fa4841
	/* else return immdiately */
Packit Service fa4841
Packit Service fa4841
	while (*lpNumberOfBytesWritten < nNumberOfBytesToWrite)
Packit Service fa4841
	{
Packit Service fa4841
		int biggestFd = -1;
Packit Service fa4841
		fd_set event_set, write_set;
Packit Service fa4841
		int nbFds;
Packit Service fa4841
		biggestFd = pComm->fd_write;
Packit Service fa4841
Packit Service fa4841
		if (pComm->fd_write_event > biggestFd)
Packit Service fa4841
			biggestFd = pComm->fd_write_event;
Packit Service fa4841
Packit Service fa4841
		FD_ZERO(&event_set);
Packit Service fa4841
		FD_ZERO(&write_set);
Packit Service fa4841
		assert(pComm->fd_write_event < FD_SETSIZE);
Packit Service fa4841
		assert(pComm->fd_write < FD_SETSIZE);
Packit Service fa4841
		FD_SET(pComm->fd_write_event, &event_set);
Packit Service fa4841
		FD_SET(pComm->fd_write, &write_set);
Packit Service fa4841
		nbFds = select(biggestFd + 1, &event_set, &write_set, NULL, pTmaxTimeout);
Packit Service fa4841
Packit Service fa4841
		if (nbFds < 0)
Packit Service fa4841
		{
Packit Service fa4841
			CommLog_Print(WLOG_WARN, "select() failure, errno=[%d] %s\n", errno, strerror(errno));
Packit Service fa4841
			SetLastError(ERROR_IO_DEVICE);
Packit Service fa4841
			goto return_false;
Packit Service fa4841
		}
Packit Service fa4841
Packit Service fa4841
		if (nbFds == 0)
Packit Service fa4841
		{
Packit Service fa4841
			/* timeout */
Packit Service fa4841
			SetLastError(ERROR_TIMEOUT);
Packit Service fa4841
			goto return_false;
Packit Service fa4841
		}
Packit Service fa4841
Packit Service fa4841
		/* event_set */
Packit Service fa4841
Packit Service fa4841
		if (FD_ISSET(pComm->fd_write_event, &event_set))
Packit Service fa4841
		{
Packit Service fa4841
			eventfd_t event = 0;
Packit Service fa4841
Packit Service fa4841
			if (eventfd_read(pComm->fd_write_event, &event) < 0)
Packit Service fa4841
			{
Packit Service fa4841
				if (errno == EAGAIN)
Packit Service fa4841
				{
Packit Service fa4841
					assert(FALSE); /* not quite sure this should ever happen */
Packit Service fa4841
					               /* keep on */
Packit Service fa4841
				}
Packit Service fa4841
				else
Packit Service fa4841
				{
Packit Service fa4841
					CommLog_Print(WLOG_WARN,
Packit Service fa4841
					              "unexpected error on reading fd_write_event, errno=[%d] %s\n",
Packit Service fa4841
					              errno, strerror(errno));
Packit Service fa4841
					/* FIXME: goto return_false ? */
Packit Service fa4841
				}
Packit Service fa4841
Packit Service fa4841
				assert(errno == EAGAIN);
Packit Service fa4841
			}
Packit Service fa4841
Packit Service fa4841
			if (event == FREERDP_PURGE_TXABORT)
Packit Service fa4841
			{
Packit Service fa4841
				SetLastError(ERROR_CANCELLED);
Packit Service fa4841
				goto return_false;
Packit Service fa4841
			}
Packit Service fa4841
Packit Service fa4841
			assert(event == FREERDP_PURGE_TXABORT); /* no other expected event so far */
Packit Service fa4841
		}
Packit Service fa4841
Packit Service fa4841
		/* write_set */
Packit Service fa4841
Packit Service fa4841
		if (FD_ISSET(pComm->fd_write, &write_set))
Packit Service fa4841
		{
Packit Service fa4841
			ssize_t nbWritten;
Packit Service fa4841
			nbWritten = write(pComm->fd_write, ((BYTE*)lpBuffer) + (*lpNumberOfBytesWritten),
Packit Service fa4841
			                  nNumberOfBytesToWrite - (*lpNumberOfBytesWritten));
Packit Service fa4841
Packit Service fa4841
			if (nbWritten < 0)
Packit Service fa4841
			{
Packit Service fa4841
				CommLog_Print(WLOG_WARN,
Packit Service fa4841
				              "CommWriteFile failed after %" PRIu32
Packit Service fa4841
				              " bytes written, errno=[%d] %s\n",
Packit Service fa4841
				              *lpNumberOfBytesWritten, errno, strerror(errno));
Packit Service fa4841
Packit Service fa4841
				if (errno == EAGAIN)
Packit Service fa4841
				{
Packit Service fa4841
					/* keep on */
Packit Service fa4841
					continue;
Packit Service fa4841
				}
Packit Service fa4841
				else if (errno == EBADF)
Packit Service fa4841
				{
Packit Service fa4841
					SetLastError(ERROR_BAD_DEVICE); /* STATUS_INVALID_DEVICE_REQUEST */
Packit Service fa4841
					goto return_false;
Packit Service fa4841
				}
Packit Service fa4841
				else
Packit Service fa4841
				{
Packit Service fa4841
					assert(FALSE);
Packit Service fa4841
					SetLastError(ERROR_IO_DEVICE);
Packit Service fa4841
					goto return_false;
Packit Service fa4841
				}
Packit Service fa4841
			}
Packit Service fa4841
Packit Service fa4841
			*lpNumberOfBytesWritten += nbWritten;
Packit Service fa4841
		}
Packit Service fa4841
	} /* while */
Packit Service fa4841
Packit Service fa4841
	/* FIXME: this call to tcdrain() doesn't look correct and
Packit Service fa4841
	 * might hide a bug but was required while testing a serial
Packit Service fa4841
	 * printer. Its driver was expecting the modem line status
Packit Service fa4841
	 * SERIAL_MSR_DSR true after the sending which was never
Packit Service fa4841
	 * happenning otherwise. A purge was also done before each
Packit Service fa4841
	 * Write operation. The serial port was opened with:
Packit Service fa4841
	 * DesiredAccess=0x0012019F. The printer worked fine with
Packit Service fa4841
	 * mstsc. */
Packit Service fa4841
	tcdrain(pComm->fd_write);
Packit Service fa4841
Packit Service fa4841
return_true:
Packit Service fa4841
	LeaveCriticalSection(&pComm->WriteLock);
Packit Service fa4841
	return TRUE;
Packit Service fa4841
Packit Service fa4841
return_false:
Packit Service fa4841
	LeaveCriticalSection(&pComm->WriteLock);
Packit Service fa4841
	return FALSE;
Packit Service fa4841
}
Packit Service fa4841
Packit Service fa4841
#endif /* __linux__ */