Add additional IOStatus codes for file I/O.

Author: s-ludwig

source/eventcore/driver.d

@@ -1167,11 +1167,17 @@ enum IOMode {
 }
 
 enum IOStatus {
-	ok,           /// The data has been transferred normally
-	disconnected, /// The connection was closed before all data could be transterred
-	error,        /// An error occured while transferring the data
-	wouldBlock,    /// Returned for `IOMode.immediate` when no data is readily readable/writable
-	invalidHandle, /// The passed handle is not valid
+	ok,                    /// The data has been transferred normally
+	disconnected,          /// The connection was closed before all data could be transterred
+	error,                 /// An error occured while transferring the data
+	wouldBlock,            /// Returned for `IOMode.immediate` when no data is readily readable/writable
+	invalidHandle,         /// The passed handle is not valid
+	readPastEOF,           /// An attempt was made to read data past the end of the file
+	noSpaceLeft,           /// Data could not be written, because the target volume is full
+	operationNotSupported, /// The underlying file system does not support the I/O operation
+	tooLarge,              /// The size of the file written to is too large for the file system
+	ioError,               /// An error occurred while physically writing data
+	notAllowed             /// The operation failed due to insufficient permissions
 }
 
 enum DNSStatus {

source/eventcore/drivers/threadedfile.d

@@ -471,28 +471,46 @@ log("start processing");
 			assert(false, "File slot not in initiated state when processor task is started.");
 
 		auto bytes = buffer;
+		ulong seekret;
 		version (Windows) {
-			._lseeki64(cast(int)file, offset, SEEK_SET);
+			seekret = ._lseeki64(cast(int)file, offset, SEEK_SET);
 		} else version (linux) {
-			.lseek64(cast(int)file, offset, SEEK_SET);
+			seekret = .lseek64(cast(int)file, offset, SEEK_SET);
 		} else version (OSX) {
-			.lseek64(cast(int)file, offset, SEEK_SET);
+			seekret = .lseek64(cast(int)file, offset, SEEK_SET);
 		} else {
-			.lseek(cast(int)file, offset, SEEK_SET);
+			seekret = .lseek(cast(int)file, offset, SEEK_SET);
 		}
 
 		scope (exit) {
 log("trigger event");
 			files.m_events.trigger(files.m_readyEvent, true);
 		}
 
+		if (seekret != offset) {
+			safeAtomicStore(f.ioStatus, IOStatus.error);
+			safeAtomicStore(f.bytesWritten, buffer.length - bytes.length);
+			return;
+		}
+
 		if (bytes.length == 0) safeAtomicStore(f.ioStatus, IOStatus.ok);
 
 		while (bytes.length > 0) {
 			auto sz = min(bytes.length, 512*1024);
 			auto ret = () @trusted { return mixin("."~op)(cast(int)file, bytes.ptr, cast(uint)sz); } ();
 			if (ret != sz) {
-				safeAtomicStore(f.ioStatus, IOStatus.error);
+				IOStatus st;
+				switch (errno) {
+					default: st = ret < 0 ? IOStatus.error : IOStatus.readPastEOF; break;
+					case EBADF, EINVAL: st = IOStatus.invalidHandle; break;
+					case ENOSPC: st = IOStatus.noSpaceLeft; break;
+					case EOPNOTSUPP: st = IOStatus.operationNotSupported; break;
+					case EFBIG: st = IOStatus.tooLarge; break;
+					case EIO: st = IOStatus.ioError; break;
+					case EPERM: st = IOStatus.notAllowed; break;
+				}
+
+				safeAtomicStore(f.ioStatus, st);
 log("error");
 				break;
 			}

source/eventcore/drivers/winapi/files.d

@@ -338,6 +338,7 @@ final class WinAPIEventDriverFiles : EventDriverFiles {
 		return m_core.rawUserDataImpl(idToHandle(descriptor), size, initialize, destroy);
 	}
 
+import eventcore.internal.utils : print;
 	private static void startIO(alias fun, bool RO)(HANDLE h, FileSlot.Direction!RO* slot)
 	{
 		import std.algorithm.comparison : min;
@@ -354,6 +355,7 @@ final class WinAPIEventDriverFiles : EventDriverFiles {
 		auto handler = &overlappedIOHandler!(onIOFinished!(fun, RO));
 		if (!() @trusted { return fun(h, &slot.buffer[0], nbytes, &slot.overlapped.overlapped, handler); } ()) {
 			slot.overlapped.driver.removeWaiter();
+			print("ERR: %s", GetLastError());
 			slot.invokeCallback(IOStatus.error, slot.bytesTransferred);
 		}
 	}
@@ -389,6 +391,7 @@ final class WinAPIEventDriverFiles : EventDriverFiles {
 
 		if (error != 0) {
 			overlapped.driver.removeWaiter();
+			print("AERR: %s", error);
 			slot.invokeCallback(IOStatus.error, slot.bytesTransferred + bytes_transferred);
 			return;
 		}
@@ -423,3 +426,17 @@ private static struct CloseParams {
 	CloseStatus status;
 	WinAPIEventDriverCore core;
 }
+
+private IOStatus toIOStatus(DWORD error)
+@safe pure nothrow @nogc {
+	switch (error) {
+		default: return IOStatus.error;
+		case ERROR_INVALID_HANDLE: st = IOStatus.invalidHandle; break;
+		case ERROR_HANDLE_DISK_FULL, ERROR_DISK_FULL: st = IOStatus.noSpaceLeft; break;
+		case ERROR_NOT_SUPPORTED: st = IOStatus.operationNotSupported; break;
+		case ERROR_FILE_TOO_LARGE: st = IOStatus.tooLarge; break;
+		case ERROR_READ_FAULT, ERROR_WRITE_FAULT, ERROR_NET_WRITE_FAULT: st = IOStatus.ioError; break;
+		case ERROR_WRITE_PROTECT, ERROR_SHARING_VIOLATION, ERROR_LOCK_VIOLATION: st = IOStatus.notAllowed; break;
+		case ERROR_HANDLE_EOF: st = IOStatus.readPastEOF; break;
+	}
+}