161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
|
struct kevent eventList[EVENTLIST_SIZE];
int events;
if ([self of_processReadBuffers])
return;
timeout.tv_sec = (time_t)timeInterval;
timeout.tv_nsec = (timeInterval - timeout.tv_sec) * 1000000000;
events = kevent(_kernelQueue, NULL, 0, eventList, EVENTLIST_SIZE,
(timeInterval != -1 ? &timeout : NULL));
if (events < 0)
@throw [OFObserveFailedException exceptionWithObserver: self
errNo: errno];
|
|
|
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
|
struct kevent eventList[EVENTLIST_SIZE];
int events;
if ([self of_processReadBuffers])
return;
timeout.tv_sec = (time_t)timeInterval;
timeout.tv_nsec = (long)((timeInterval - timeout.tv_sec) * 1000000000);
events = kevent(_kernelQueue, NULL, 0, eventList, EVENTLIST_SIZE,
(timeInterval != -1 ? &timeout : NULL));
if (events < 0)
@throw [OFObserveFailedException exceptionWithObserver: self
errNo: errno];
|