X-Git-Url: https://www.tinc-vpn.org/git/browse?a=blobdiff_plain;f=src%2Fmingw%2Fdevice.c;h=6ee26e7bf9be125e6a683ca1c525c573c057a650;hb=5ae1ec8d80393182b6ff235062b6816b64edfa9b;hp=2ef0064189b877e925c8597f0d8176c057a6205c;hpb=1d10afd3d33f5623494d9eeb2fa8237712f8aa2e;p=tinc diff --git a/src/mingw/device.c b/src/mingw/device.c index 2ef00641..6ee26e7b 100644 --- a/src/mingw/device.c +++ b/src/mingw/device.c @@ -49,11 +49,20 @@ static void device_issue_read() { device_read_overlapped.Offset = 0; device_read_overlapped.OffsetHigh = 0; - int status = ReadFile(device_handle, (void *)device_read_packet.data, MTU, NULL, &device_read_overlapped); + int status; + for (;;) { + DWORD len; + status = ReadFile(device_handle, (void *)device_read_packet.data, MTU, &len, &device_read_overlapped); + if (!status) { + if (GetLastError() != ERROR_IO_PENDING) + logger(DEBUG_ALWAYS, LOG_ERR, "Error while reading from %s %s: %s", device_info, + device, strerror(errno)); + break; + } - if(!status && GetLastError() != ERROR_IO_PENDING) { - logger(DEBUG_ALWAYS, LOG_ERR, "Error while reading from %s %s: %s", device_info, - device, strerror(errno)); + device_read_packet.len = len; + device_read_packet.priority = 0; + route(myself, &device_read_packet); } }