/**

 * FreeRDP: A Remote Desktop Protocol Implementation

 * File System Virtual Channel

 *

 * Copyright 2010-2011 Vic Lee

 * Copyright 2010-2012 Marc-Andre Moreau <marcandre.moreau@gmail.com>

 * Copyright 2015 Thincast Technologies GmbH

 * Copyright 2015 DI (FH) Martin Haimberger <martin.haimberger@thincast.com>

 * Copyright 2016 David PHAM-VAN <d.phamvan@inuvika.com>

 *

 * Licensed under the Apache License, Version 2.0 (the "License");

 * you may not use this file except in compliance with the License.

 * You may obtain a copy of the License at

 *

 *     http://www.apache.org/licenses/LICENSE-2.0

 *

 * Unless required by applicable law or agreed to in writing, software

 * distributed under the License is distributed on an "AS IS" BASIS,

 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.

 * See the License for the specific language governing permissions and

 * limitations under the License.

 */

#ifdef HAVE_CONFIG_H

#include "config.h"

#endif

#include <errno.h>

#include <stdio.h>

#include <stdlib.h>

#include <string.h>

#include <winpr/crt.h>

#include <winpr/path.h>

#include <winpr/file.h>

#include <winpr/string.h>

#include <winpr/synch.h>

#include <winpr/thread.h>

#include <winpr/stream.h>

#include <winpr/environment.h>

#include <winpr/interlocked.h>

#include <winpr/collections.h>

#include <winpr/shell.h>

#include <freerdp/channels/rdpdr.h>

#include "drive_file.h"

typedef struct _DRIVE_DEVICE DRIVE_DEVICE;

struct _DRIVE_DEVICE

{

	DEVICE device;

	WCHAR* path;

	BOOL automount;

	UINT32 PathLength;

	wListDictionary* files;

	HANDLE thread;

	wMessageQueue* IrpQueue;

	DEVMAN* devman;

	rdpContext* rdpcontext;

};

static UINT sys_code_page = 0;

static DWORD drive_map_windows_err(DWORD fs_errno)

{

	DWORD rc;

	/* try to return NTSTATUS version of error code */

	switch (fs_errno)

	{

		case STATUS_SUCCESS:

			rc = STATUS_SUCCESS;

			break;

		case ERROR_ACCESS_DENIED:

		case ERROR_SHARING_VIOLATION:

			rc = STATUS_ACCESS_DENIED;

			break;

		case ERROR_FILE_NOT_FOUND:

			rc = STATUS_NO_SUCH_FILE;

			break;

		case ERROR_BUSY_DRIVE:

			rc = STATUS_DEVICE_BUSY;

			break;

		case ERROR_INVALID_DRIVE:

			rc = STATUS_NO_SUCH_DEVICE;

			break;

		case ERROR_NOT_READY:

			rc = STATUS_NO_SUCH_DEVICE;

			break;

		case ERROR_FILE_EXISTS:

		case ERROR_ALREADY_EXISTS:

			rc  = STATUS_OBJECT_NAME_COLLISION;

			break;

		case ERROR_INVALID_NAME:

			rc = STATUS_NO_SUCH_FILE;

			break;

		case ERROR_INVALID_HANDLE:

			rc = STATUS_INVALID_HANDLE;

			break;

		case ERROR_NO_MORE_FILES:

			rc = STATUS_NO_MORE_FILES;

			break;

		case ERROR_DIRECTORY:

			rc = STATUS_NOT_A_DIRECTORY;

			break;

		case ERROR_PATH_NOT_FOUND:

			rc = STATUS_OBJECT_PATH_NOT_FOUND;

			break;

		default:

			rc = STATUS_UNSUCCESSFUL;

			WLog_ERR(TAG, "Error code not found: %"PRIu32"", fs_errno);

			break;

	}

	return rc;

}

static DRIVE_FILE* drive_get_file_by_id(DRIVE_DEVICE* drive, UINT32 id)

{

	DRIVE_FILE* file = NULL;

	void* key = (void*)(size_t) id;

	if (!drive)

		return NULL;

	file = (DRIVE_FILE*) ListDictionary_GetItemValue(drive->files, key);

	return file;

}

/**

 * Function description

 *

 * @return 0 on success, otherwise a Win32 error code

 */

static UINT drive_process_irp_create(DRIVE_DEVICE* drive, IRP* irp)

{

	UINT32 FileId;

	DRIVE_FILE* file;

	BYTE Information;

	UINT32 FileAttributes;

	UINT32 SharedAccess;

	UINT32 DesiredAccess;

	UINT32 CreateDisposition;

	UINT32 CreateOptions;

	UINT32 PathLength;

	UINT64 allocationSize;

	const WCHAR* path;

	if (!drive || !irp || !irp->devman || !irp->Complete)

		return ERROR_INVALID_PARAMETER;

	if (Stream_GetRemainingLength(irp->input) < 6 * 4 + 8)

		return ERROR_INVALID_DATA;

	Stream_Read_UINT32(irp->input, DesiredAccess);

	Stream_Read_UINT64(irp->input, allocationSize);

	Stream_Read_UINT32(irp->input, FileAttributes);

	Stream_Read_UINT32(irp->input, SharedAccess);

	Stream_Read_UINT32(irp->input, CreateDisposition);

	Stream_Read_UINT32(irp->input, CreateOptions);

	Stream_Read_UINT32(irp->input, PathLength);

	if (Stream_GetRemainingLength(irp->input) < PathLength)

		return ERROR_INVALID_DATA;

	path = (WCHAR*) Stream_Pointer(irp->input);

	FileId = irp->devman->id_sequence++;

	file = drive_file_new(drive->path, path, PathLength, FileId, DesiredAccess, CreateDisposition,

	                      CreateOptions, FileAttributes, SharedAccess);

	if (!file)

	{

		irp->IoStatus = drive_map_windows_err(GetLastError());

		FileId = 0;

		Information = 0;

	}

	else

	{

		void* key = (void*)(size_t) file->id;

		if (!ListDictionary_Add(drive->files, key, file))

		{

			WLog_ERR(TAG, "ListDictionary_Add failed!");

			return ERROR_INTERNAL_ERROR;

		}

		switch (CreateDisposition)

		{

			case FILE_SUPERSEDE:

			case FILE_OPEN:

			case FILE_CREATE:

			case FILE_OVERWRITE:

				Information = FILE_SUPERSEDED;

				break;

			case FILE_OPEN_IF:

				Information = FILE_OPENED;

				break;

			case FILE_OVERWRITE_IF:

				Information = FILE_OVERWRITTEN;

				break;

			default:

				Information = 0;

				break;

		}

	}

	Stream_Write_UINT32(irp->output, FileId);

	Stream_Write_UINT8(irp->output, Information);

	return irp->Complete(irp);

}

/**

 * Function description

 *

 * @return 0 on success, otherwise a Win32 error code

 */

static UINT drive_process_irp_close(DRIVE_DEVICE* drive, IRP* irp)

{

	void* key;

	DRIVE_FILE* file;

	if (!drive || !irp || !irp->Complete || !irp->output)

		return ERROR_INVALID_PARAMETER;

	file = drive_get_file_by_id(drive, irp->FileId);

	key = (void*)(size_t) irp->FileId;

	if (!file)

		irp->IoStatus = STATUS_UNSUCCESSFUL;

	else

	{

		ListDictionary_Remove(drive->files, key);

		if (drive_file_free(file))

			irp->IoStatus = STATUS_SUCCESS;

		else

			irp->IoStatus = drive_map_windows_err(GetLastError());

	}

	Stream_Zero(irp->output, 5); /* Padding(5) */

	return irp->Complete(irp);

}

/**

 * Function description

 *

 * @return 0 on success, otherwise a Win32 error code

 */

static UINT drive_process_irp_read(DRIVE_DEVICE* drive, IRP* irp)

{

	DRIVE_FILE* file;

	UINT32 Length;

	UINT64 Offset;

	if (!drive || !irp || !irp->output || !irp->Complete)

		return ERROR_INVALID_PARAMETER;

	if (Stream_GetRemainingLength(irp->input) < 12)

		return ERROR_INVALID_DATA;

	Stream_Read_UINT32(irp->input, Length);

	Stream_Read_UINT64(irp->input, Offset);

	file = drive_get_file_by_id(drive, irp->FileId);

	if (!file)

	{

		irp->IoStatus = STATUS_UNSUCCESSFUL;

		Length = 0;

	}

	else if (!drive_file_seek(file, Offset))

	{

		irp->IoStatus = drive_map_windows_err(GetLastError());

		Length = 0;

	}

	if (!Stream_EnsureRemainingCapacity(irp->output, Length + 4))

	{

		WLog_ERR(TAG, "Stream_EnsureRemainingCapacity failed!");

		return ERROR_INTERNAL_ERROR;

	}

	else if (Length == 0)

		Stream_Write_UINT32(irp->output, 0);

	else

	{

		BYTE* buffer = Stream_Pointer(irp->output) + sizeof(UINT32);

		if (!drive_file_read(file, buffer, &Length))

		{

			irp->IoStatus = drive_map_windows_err(GetLastError());

			Stream_Write_UINT32(irp->output, 0);

		}

		else

		{

			Stream_Write_UINT32(irp->output, Length);

			Stream_Seek(irp->output, Length);

		}

	}

	return irp->Complete(irp);

}

/**

 * Function description

 *

 * @return 0 on success, otherwise a Win32 error code

 */

static UINT drive_process_irp_write(DRIVE_DEVICE* drive, IRP* irp)

{

	DRIVE_FILE* file;

	UINT32 Length;

	UINT64 Offset;

	if (!drive || !irp || !irp->input || !irp->output || !irp->Complete)

		return ERROR_INVALID_PARAMETER;

	if (Stream_GetRemainingLength(irp->input) < 32)

		return ERROR_INVALID_DATA;

	Stream_Read_UINT32(irp->input, Length);

	Stream_Read_UINT64(irp->input, Offset);

	Stream_Seek(irp->input, 20); /* Padding */

	file = drive_get_file_by_id(drive, irp->FileId);

	if (!file)

	{

		irp->IoStatus = STATUS_UNSUCCESSFUL;

		Length = 0;

	}

	else if (!drive_file_seek(file, Offset))

	{

		irp->IoStatus = drive_map_windows_err(GetLastError());

		Length = 0;

	}

	else if (!drive_file_write(file, Stream_Pointer(irp->input), Length))

	{

		irp->IoStatus = drive_map_windows_err(GetLastError());

		Length = 0;

	}

	Stream_Write_UINT32(irp->output, Length);

	Stream_Write_UINT8(irp->output, 0); /* Padding */

	return irp->Complete(irp);

}

/**

 * Function description

 *

 * @return 0 on success, otherwise a Win32 error code

 */

static UINT drive_process_irp_query_information(DRIVE_DEVICE* drive, IRP* irp)

{

	DRIVE_FILE* file;

	UINT32 FsInformationClass;

	if (!drive || !irp || !irp->Complete)

		return ERROR_INVALID_PARAMETER;

	if (Stream_GetRemainingLength(irp->input) < 4)

		return ERROR_INVALID_DATA;

	Stream_Read_UINT32(irp->input, FsInformationClass);

	file = drive_get_file_by_id(drive, irp->FileId);

	if (!file)

	{

		irp->IoStatus = STATUS_UNSUCCESSFUL;

	}

	else if (!drive_file_query_information(file, FsInformationClass, irp->output))

	{

		irp->IoStatus = drive_map_windows_err(GetLastError());

	}

	return irp->Complete(irp);

}

/**

 * Function description

 *

 * @return 0 on success, otherwise a Win32 error code

 */

static UINT drive_process_irp_set_information(DRIVE_DEVICE* drive, IRP* irp)

{

	DRIVE_FILE* file;

	UINT32 FsInformationClass;

	UINT32 Length;

	if (!drive || !irp || !irp->Complete || !irp->input || !irp->output)

		return ERROR_INVALID_PARAMETER;

	if (Stream_GetRemainingLength(irp->input) < 32)

		return ERROR_INVALID_DATA;

	Stream_Read_UINT32(irp->input, FsInformationClass);

	Stream_Read_UINT32(irp->input, Length);

	Stream_Seek(irp->input, 24); /* Padding */

	file = drive_get_file_by_id(drive, irp->FileId);

	if (!file)

	{

		irp->IoStatus = STATUS_UNSUCCESSFUL;

	}

	else if (!drive_file_set_information(file, FsInformationClass, Length,

	                                     irp->input))

	{

		irp->IoStatus = drive_map_windows_err(GetLastError());

	}

	if (file && file->is_dir && !PathIsDirectoryEmptyW(file->fullpath))

		irp->IoStatus = STATUS_DIRECTORY_NOT_EMPTY;

	Stream_Write_UINT32(irp->output, Length);

	return irp->Complete(irp);

}

/**

 * Function description

 *

 * @return 0 on success, otherwise a Win32 error code

 */

static UINT drive_process_irp_query_volume_information(DRIVE_DEVICE* drive,

        IRP* irp)

{

	UINT32 FsInformationClass;

	wStream* output = NULL;

	char* volumeLabel = {"FREERDP"};

	char* diskType = {"FAT32"};

	WCHAR* outStr = NULL;

	int length;

	DWORD lpSectorsPerCluster;

	DWORD lpBytesPerSector;

	DWORD lpNumberOfFreeClusters;

	DWORD lpTotalNumberOfClusters;

	WIN32_FILE_ATTRIBUTE_DATA wfad;

	if (!drive || !irp)

		return ERROR_INVALID_PARAMETER;

	output = irp->output;

	if (Stream_GetRemainingLength(irp->input) < 4)

		return ERROR_INVALID_DATA;

	Stream_Read_UINT32(irp->input, FsInformationClass);

	GetDiskFreeSpaceW(drive->path, &lpSectorsPerCluster, &lpBytesPerSector, &lpNumberOfFreeClusters,

	                  &lpTotalNumberOfClusters);

	switch (FsInformationClass)

	{

		case FileFsVolumeInformation:

			/* http://msdn.microsoft.com/en-us/library/cc232108.aspx */

			if ((length = ConvertToUnicode(sys_code_page, 0, volumeLabel, -1, &outStr, 0) * 2) <= 0)

			{

				WLog_ERR(TAG, "ConvertToUnicode failed!");

				return CHANNEL_RC_NO_MEMORY;

			}

			Stream_Write_UINT32(output, 17 + length); /* Length */

			if (!Stream_EnsureRemainingCapacity(output, 17 + length))

			{

				WLog_ERR(TAG, "Stream_EnsureRemainingCapacity failed!");

				free(outStr);

				return CHANNEL_RC_NO_MEMORY;

			}

			GetFileAttributesExW(drive->path, GetFileExInfoStandard, &wfad);

			Stream_Write_UINT32(output, wfad.ftCreationTime.dwLowDateTime); /* VolumeCreationTime */

			Stream_Write_UINT32(output, wfad.ftCreationTime.dwHighDateTime); /* VolumeCreationTime */

			Stream_Write_UINT32(output, lpNumberOfFreeClusters & 0xffff); /* VolumeSerialNumber */

			Stream_Write_UINT32(output, length); /* VolumeLabelLength */

			Stream_Write_UINT8(output, 0); /* SupportsObjects */

			/* Reserved(1), MUST NOT be added! */

			Stream_Write(output, outStr, length); /* VolumeLabel (Unicode) */

			free(outStr);

			break;

		case FileFsSizeInformation:

			/* http://msdn.microsoft.com/en-us/library/cc232107.aspx */

			Stream_Write_UINT32(output, 24); /* Length */

			if (!Stream_EnsureRemainingCapacity(output, 24))

			{

				WLog_ERR(TAG, "Stream_EnsureRemainingCapacity failed!");

				return CHANNEL_RC_NO_MEMORY;

			}

			Stream_Write_UINT64(output, lpTotalNumberOfClusters); /* TotalAllocationUnits */

			Stream_Write_UINT64(output, lpNumberOfFreeClusters); /* AvailableAllocationUnits */

			Stream_Write_UINT32(output, lpSectorsPerCluster); /* SectorsPerAllocationUnit */

			Stream_Write_UINT32(output, lpBytesPerSector); /* BytesPerSector */

			break;

		case FileFsAttributeInformation:

			/* http://msdn.microsoft.com/en-us/library/cc232101.aspx */

			if ((length = ConvertToUnicode(sys_code_page, 0, diskType, -1, &outStr, 0) * 2) <= 0)

			{

				WLog_ERR(TAG, "ConvertToUnicode failed!");

				return CHANNEL_RC_NO_MEMORY;

			}

			Stream_Write_UINT32(output, 12 + length); /* Length */

			if (!Stream_EnsureRemainingCapacity(output, 12 + length))

			{

				free(outStr);

				WLog_ERR(TAG, "Stream_EnsureRemainingCapacity failed!");

				return CHANNEL_RC_NO_MEMORY;

			}

			Stream_Write_UINT32(output,

			                    FILE_CASE_SENSITIVE_SEARCH |

			                    FILE_CASE_PRESERVED_NAMES |

			                    FILE_UNICODE_ON_DISK); /* FileSystemAttributes */

			Stream_Write_UINT32(output, MAX_PATH); /* MaximumComponentNameLength */

			Stream_Write_UINT32(output, length); /* FileSystemNameLength */

			Stream_Write(output, outStr, length); /* FileSystemName (Unicode) */

			free(outStr);

			break;

		case FileFsFullSizeInformation:

			/* http://msdn.microsoft.com/en-us/library/cc232104.aspx */

			Stream_Write_UINT32(output, 32); /* Length */

			if (!Stream_EnsureRemainingCapacity(output, 32))

			{

				WLog_ERR(TAG, "Stream_EnsureRemainingCapacity failed!");

				return CHANNEL_RC_NO_MEMORY;

			}

			Stream_Write_UINT64(output, lpTotalNumberOfClusters); /* TotalAllocationUnits */

			Stream_Write_UINT64(output, lpNumberOfFreeClusters); /* CallerAvailableAllocationUnits */

			Stream_Write_UINT64(output, lpNumberOfFreeClusters); /* AvailableAllocationUnits */

			Stream_Write_UINT32(output, lpSectorsPerCluster); /* SectorsPerAllocationUnit */

			Stream_Write_UINT32(output, lpBytesPerSector); /* BytesPerSector */

			break;

		case FileFsDeviceInformation:

			/* http://msdn.microsoft.com/en-us/library/cc232109.aspx */

			Stream_Write_UINT32(output, 8); /* Length */

			if (!Stream_EnsureRemainingCapacity(output, 8))

			{

				WLog_ERR(TAG, "Stream_EnsureRemainingCapacity failed!");

				return CHANNEL_RC_NO_MEMORY;

			}

			Stream_Write_UINT32(output, FILE_DEVICE_DISK); /* DeviceType */

			Stream_Write_UINT32(output, 0); /* Characteristics */

			break;

		default:

			irp->IoStatus = STATUS_UNSUCCESSFUL;

			Stream_Write_UINT32(output, 0); /* Length */

			break;

	}

	return irp->Complete(irp);

}

/* http://msdn.microsoft.com/en-us/library/cc241518.aspx */

/**

 * Function description

 *

 * @return 0 on success, otherwise a Win32 error code

 */

static UINT drive_process_irp_silent_ignore(DRIVE_DEVICE* drive, IRP* irp)

{

	UINT32 FsInformationClass;

	if (!drive || !irp || !irp->output || !irp->Complete)

		return ERROR_INVALID_PARAMETER;

	if (Stream_GetRemainingLength(irp->input) < 4)

		return ERROR_INVALID_DATA;

	Stream_Read_UINT32(irp->input, FsInformationClass);

	Stream_Write_UINT32(irp->output, 0); /* Length */

	return irp->Complete(irp);

}

/**

 * Function description

 *

 * @return 0 on success, otherwise a Win32 error code

 */

static UINT drive_process_irp_query_directory(DRIVE_DEVICE* drive, IRP* irp)

{

	const WCHAR* path;

	DRIVE_FILE* file;

	BYTE InitialQuery;

	UINT32 PathLength;

	UINT32 FsInformationClass;

	if (!drive || !irp || !irp->Complete)

		return ERROR_INVALID_PARAMETER;

	if (Stream_GetRemainingLength(irp->input) < 32)

		return ERROR_INVALID_DATA;

	Stream_Read_UINT32(irp->input, FsInformationClass);

	Stream_Read_UINT8(irp->input, InitialQuery);

	Stream_Read_UINT32(irp->input, PathLength);

	Stream_Seek(irp->input, 23); /* Padding */

	path = (WCHAR*) Stream_Pointer(irp->input);

	file = drive_get_file_by_id(drive, irp->FileId);

	if (file == NULL)

	{

		irp->IoStatus = STATUS_UNSUCCESSFUL;

		Stream_Write_UINT32(irp->output, 0); /* Length */

	}

	else if (!drive_file_query_directory(file, FsInformationClass, InitialQuery, path, PathLength,

	                                     irp->output))

	{

		irp->IoStatus = drive_map_windows_err(GetLastError());

	}

	return irp->Complete(irp);

}

/**

 * Function description

 *

 * @return 0 on success, otherwise a Win32 error code

 */

static UINT drive_process_irp_directory_control(DRIVE_DEVICE* drive, IRP* irp)

{

	if (!drive || !irp)

		return ERROR_INVALID_PARAMETER;

	switch (irp->MinorFunction)

	{

		case IRP_MN_QUERY_DIRECTORY:

			return drive_process_irp_query_directory(drive, irp);

		case IRP_MN_NOTIFY_CHANGE_DIRECTORY: /* TODO */

			return irp->Discard(irp);

		default:

			irp->IoStatus = STATUS_NOT_SUPPORTED;

			Stream_Write_UINT32(irp->output, 0); /* Length */

			return irp->Complete(irp);

	}

	return CHANNEL_RC_OK;

}

/**

 * Function description

 *

 * @return 0 on success, otherwise a Win32 error code

 */

static UINT drive_process_irp_device_control(DRIVE_DEVICE* drive, IRP* irp)

{

	if (!drive || !irp)

		return ERROR_INVALID_PARAMETER;

	Stream_Write_UINT32(irp->output, 0); /* OutputBufferLength */

	return irp->Complete(irp);

}

/**

 * Function description

 *

 * @return 0 on success, otherwise a Win32 error code

 */

static UINT drive_process_irp(DRIVE_DEVICE* drive, IRP* irp)

{

	UINT error;

	if (!drive || !irp)

		return ERROR_INVALID_PARAMETER;

	irp->IoStatus = STATUS_SUCCESS;

	switch (irp->MajorFunction)

	{

		case IRP_MJ_CREATE:

			error = drive_process_irp_create(drive, irp);

			break;

		case IRP_MJ_CLOSE:

			error = drive_process_irp_close(drive, irp);

			break;

		case IRP_MJ_READ:

			error = drive_process_irp_read(drive, irp);

			break;

		case IRP_MJ_WRITE:

			error = drive_process_irp_write(drive, irp);

			break;

		case IRP_MJ_QUERY_INFORMATION:

			error = drive_process_irp_query_information(drive, irp);

			break;

		case IRP_MJ_SET_INFORMATION:

			error = drive_process_irp_set_information(drive, irp);

			break;

		case IRP_MJ_QUERY_VOLUME_INFORMATION:

			error = drive_process_irp_query_volume_information(drive, irp);

			break;

		case IRP_MJ_LOCK_CONTROL:

			error = drive_process_irp_silent_ignore(drive, irp);

			break;

		case IRP_MJ_DIRECTORY_CONTROL:

			error = drive_process_irp_directory_control(drive, irp);

			break;

		case IRP_MJ_DEVICE_CONTROL:

			error = drive_process_irp_device_control(drive, irp);

			break;

		default:

			irp->IoStatus = STATUS_NOT_SUPPORTED;

			error = irp->Complete(irp);

			break;

	}

	return error;

}

static DWORD WINAPI drive_thread_func(LPVOID arg)

{

	IRP* irp;

	wMessage message;

	DRIVE_DEVICE* drive = (DRIVE_DEVICE*) arg;

	UINT error = CHANNEL_RC_OK;

	if (!drive)

	{

		error = ERROR_INVALID_PARAMETER;

		goto fail;

	}

	while (1)

	{

		if (!MessageQueue_Wait(drive->IrpQueue))

		{

			WLog_ERR(TAG, "MessageQueue_Wait failed!");

			error = ERROR_INTERNAL_ERROR;

			break;

		}

		if (!MessageQueue_Peek(drive->IrpQueue, &message, TRUE))

		{

			WLog_ERR(TAG, "MessageQueue_Peek failed!");

			error = ERROR_INTERNAL_ERROR;

			break;

		}

		if (message.id == WMQ_QUIT)

			break;

		irp = (IRP*) message.wParam;

		if (irp)

		{

			if ((error = drive_process_irp(drive, irp)))

			{

				WLog_ERR(TAG, "drive_process_irp failed with error %"PRIu32"!", error);

				break;

			}

		}

	}

fail:

	if (error && drive && drive->rdpcontext)

		setChannelError(drive->rdpcontext, error, "drive_thread_func reported an error");

	ExitThread(error);

	return error;

}

/**

 * Function description

 *

 * @return 0 on success, otherwise a Win32 error code

 */

static UINT drive_irp_request(DEVICE* device, IRP* irp)

{

	DRIVE_DEVICE* drive = (DRIVE_DEVICE*) device;

	if (!drive)

		return ERROR_INVALID_PARAMETER;

	if (!MessageQueue_Post(drive->IrpQueue, NULL, 0, (void*) irp, NULL))

	{

		WLog_ERR(TAG, "MessageQueue_Post failed!");

		return ERROR_INTERNAL_ERROR;

	}

	return CHANNEL_RC_OK;

}

static UINT drive_free_int(DRIVE_DEVICE* drive)

{

	UINT error = CHANNEL_RC_OK;

	if (!drive)

		return ERROR_INVALID_PARAMETER;

	CloseHandle(drive->thread);

	ListDictionary_Free(drive->files);

	MessageQueue_Free(drive->IrpQueue);

	Stream_Free(drive->device.data, TRUE);

	free(drive->path);

	free(drive);

	return error;

}

/**

 * Function description

 *

 * @return 0 on success, otherwise a Win32 error code

 */

static UINT drive_free(DEVICE* device)

{

	DRIVE_DEVICE* drive = (DRIVE_DEVICE*) device;

	UINT error = CHANNEL_RC_OK;

	if (!drive)

		return ERROR_INVALID_PARAMETER;

	if (MessageQueue_PostQuit(drive->IrpQueue, 0)

	    && (WaitForSingleObject(drive->thread, INFINITE) == WAIT_FAILED))

	{

		error = GetLastError();

		WLog_ERR(TAG, "WaitForSingleObject failed with error %"PRIu32"", error);

		return error;

	}

	return drive_free_int(drive);

}

/**

 * Helper function used for freeing list dictionary value object

 */

static void drive_file_objfree(void* obj)

{

	drive_file_free((DRIVE_FILE*) obj);

}

/**

 * Function description

 *

 * @return 0 on success, otherwise a Win32 error code

 */