@@ -83,11 +83,11 @@ close(_kernelQueue); [super dealloc]; } -- (void)OF_addObjectForReading: (id )object +- (void)of_addObjectForReading: (id )object { struct kevent event; memset(&event, 0, sizeof(event)); event.ident = [object fileDescriptorForReading]; @@ -102,11 +102,11 @@ if (kevent(_kernelQueue, &event, 1, NULL, 0, NULL) != 0) @throw [OFObserveFailedException exceptionWithObserver: self errNo: errno]; } -- (void)OF_addObjectForWriting: (id )object +- (void)of_addObjectForWriting: (id )object { struct kevent event; memset(&event, 0, sizeof(event)); event.ident = [object fileDescriptorForWriting]; @@ -121,11 +121,11 @@ if (kevent(_kernelQueue, &event, 1, NULL, 0, NULL) != 0) @throw [OFObserveFailedException exceptionWithObserver: self errNo: errno]; } -- (void)OF_removeObjectForReading: (id )object +- (void)of_removeObjectForReading: (id )object { struct kevent event; memset(&event, 0, sizeof(event)); event.ident = [object fileDescriptorForReading]; @@ -135,11 +135,11 @@ if (kevent(_kernelQueue, &event, 1, NULL, 0, NULL) != 0) @throw [OFObserveFailedException exceptionWithObserver: self errNo: errno]; } -- (void)OF_removeObjectForWriting: (id )object +- (void)of_removeObjectForWriting: (id )object { struct kevent event; memset(&event, 0, sizeof(event)); event.ident = [object fileDescriptorForWriting]; @@ -155,13 +155,13 @@ { struct timespec timeout; struct kevent eventList[EVENTLIST_SIZE]; int events; - [self OF_processQueue]; + [self of_processQueue]; - if ([self OF_processReadBuffers]) + if ([self of_processReadBuffers]) return; timeout.tv_sec = (time_t)timeInterval; timeout.tv_nsec = lrint((timeInterval - timeout.tv_sec) * 1000000000);