Changeset 16:d70b0c40fe4a in xplcommon for src/xplcommon/posix/WritingBuffer.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/WritingBuffer.cc
r14 r16 32 32 #include "WritingBuffer.h" 33 33 34 #include "Buffered Waitable.h"34 #include "BufferedStream.h" 35 35 36 36 #include <poll.h> … … 46 46 Buffer::reset(); 47 47 offset = 0; 48 waitable.events &= ~POLLOUT;48 stream.events &= ~POLLOUT; 49 49 } 50 50 … … 62 62 size_t toWrite = getLength() - offset; 63 63 64 ssize_t result = waitable.write(getData() + offset, toWrite);64 ssize_t result = stream.write(getData() + offset, toWrite); 65 65 if (result<static_cast<ssize_t>(toWrite)) { 66 if (result<0 && waitable.failed()) {67 waitable.events &= ~POLLOUT;66 if (result<0 && stream.failed()) { 67 stream.events &= ~POLLOUT; 68 68 } else { 69 waitable.events |= POLLOUT;69 stream.events |= POLLOUT; 70 70 if (result>0) offset += result; 71 71 }
Note:
See TracChangeset
for help on using the changeset viewer.