@@ -16,19 +16,20 @@ #include "config.h" #define __NO_EXT_QNX -#include #include #include #import "OFStreamObserver_poll.h" #import "OFDataArray.h" #import "OFAutoreleasePool.h" #import "OFOutOfRangeException.h" + +#import "macros.h" @implementation OFStreamObserver_poll - init { self = [super init]; @@ -148,11 +149,11 @@ for (i = 0; i < nFDs; i++) { if (FDsCArray[i].revents & POLLIN) { if (FDsCArray[i].fd == cancelFD[0]) { char buffer; - assert(read(cancelFD[0], &buffer, 1) > 0); + OF_ENSURE(read(cancelFD[0], &buffer, 1) > 0); FDsCArray[i].revents = 0; continue; }