250
251
252
253
254
255
256
257
258
259
260
261
262
263
264
|
while ((events = select(_maxFD + 1, &readFDs, &writeFDs, NULL,
(timeInterval != -1 ? &timeout : NULL))) < 0) {
int errNo = _OFSocketErrNo();
if (errNo != EINTR)
@throw [OFObserveKernelEventsFailedException
exceptionWithObserver: self
errNo: errNo)];
}
if (FD_ISSET(_cancelFD[0], &readFDs)) {
char buffer;
# ifdef OF_HAVE_PIPE
OFEnsure(read(_cancelFD[0], &buffer, 1) == 1);
|
|
|
250
251
252
253
254
255
256
257
258
259
260
261
262
263
264
|
while ((events = select(_maxFD + 1, &readFDs, &writeFDs, NULL,
(timeInterval != -1 ? &timeout : NULL))) < 0) {
int errNo = _OFSocketErrNo();
if (errNo != EINTR)
@throw [OFObserveKernelEventsFailedException
exceptionWithObserver: self
errNo: errNo];
}
if (FD_ISSET(_cancelFD[0], &readFDs)) {
char buffer;
# ifdef OF_HAVE_PIPE
OFEnsure(read(_cancelFD[0], &buffer, 1) == 1);
|