From 4a86704d193e67c6484f3f0aec0bc37e45b7b0dd Mon Sep 17 00:00:00 2001 From: Marcus Brinkmann Date: Thu, 11 Oct 2007 13:03:59 +0000 Subject: [PATCH] 2007-10-11 Marcus Brinkmann * kdpipeiodevice.cpp: New version from Frank Osterfeld. --- gpgme/ChangeLog | 4 ++++ gpgme/kdpipeiodevice.cpp | 9 +++++++-- 2 files changed, 11 insertions(+), 2 deletions(-) diff --git a/gpgme/ChangeLog b/gpgme/ChangeLog index 580b606..dbe43fd 100644 --- a/gpgme/ChangeLog +++ b/gpgme/ChangeLog @@ -1,3 +1,7 @@ +2007-10-11 Marcus Brinkmann + + * kdpipeiodevice.cpp: New version from Frank Osterfeld. + 2007-10-09 Marcus Brinkmann * kdpipeiodevice.cpp: New version from Frank Osterfeld and Marc diff --git a/gpgme/kdpipeiodevice.cpp b/gpgme/kdpipeiodevice.cpp index 032b62b..67f8bf5 100644 --- a/gpgme/kdpipeiodevice.cpp +++ b/gpgme/kdpipeiodevice.cpp @@ -728,7 +728,12 @@ void Reader::run() { DWORD numRead; const bool ok = ReadFile( handle, buffer + wptr, numBytes, &numRead, 0 ); mutex.lock(); - if ( !ok ) { + if ( ok ) { + if ( numRead == 0 ) { + qDebug( "%p: Reader::run: got eof (numRead==0)", this ); + eof = true; + } + } else { // !ok errorCode = static_cast( GetLastError() ); if ( errorCode == ERROR_BROKEN_PIPE ) { assert( numRead == 0 ); @@ -758,7 +763,7 @@ void Reader::run() { } #endif qDebug( "%p: Reader::run: read %ld bytes", this, static_cast(numRead) ); - qDebug( "%p (fd=%d): KDPipeIODevice::readData: %s", this, fd, buffer ); + qDebug( "%p: Reader::run(fd=%d): %s", this, fd, buffer ); if ( numRead > 0 ) { qDebug( "%p: Reader::run: buffer before: rptr=%4d, wptr=%4d", this, rptr, wptr ); -- 2.26.2