Changeset 16:d70b0c40fe4a in xplcommon for src/xplcommon/posix/ReadingBuffer.cc
- Timestamp:
- 12/29/12 10:24:28 (11 years ago)
- Branch:
- default
- Phase:
- public
- File:
-
- 1 edited
Legend:
- Unmodified
- Added
- Removed
-
src/xplcommon/posix/ReadingBuffer.cc
r14 r16 32 32 #include "ReadingBuffer.h" 33 33 34 #include "Buffered Waitable.h"34 #include "BufferedStream.h" 35 35 36 36 #include <poll.h> … … 47 47 48 48 if (getLength()>0) { 49 waitable.events &= ~POLLIN;49 stream.events &= ~POLLIN; 50 50 return true; 51 51 } 52 52 53 ssize_t result = waitable.read(getData(), getCapacity());53 ssize_t result = stream.read(getData(), getCapacity()); 54 54 if (result<0) { 55 if ( waitable.failed()) {56 waitable.events &= ~POLLIN;55 if (stream.failed()) { 56 stream.events &= ~POLLIN; 57 57 } else { 58 waitable.events |= POLLIN;58 stream.events |= POLLIN; 59 59 } 60 60 } else { 61 waitable.events &= ~POLLIN;61 stream.events &= ~POLLIN; 62 62 addLength(result); 63 63 }
Note:
See TracChangeset
for help on using the changeset viewer.