51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
|
@try {
struct epoll_event event;
#ifdef HAVE_EPOLL_CREATE1
if ((_epfd = epoll_create1(EPOLL_CLOEXEC)) == -1)
@throw [OFInitializationFailedException
exceptionWithClass: [self class]];
#else
int flags;
if ((_epfd = epoll_create(1)) == -1)
@throw [OFInitializationFailedException
exceptionWithClass: [self class]];
if ((flags = fcntl(_epfd, F_GETFD, 0)) != -1)
fcntl(_epfd, F_SETFD, flags | FD_CLOEXEC);
#endif
_FDToEvents = [[OFMapTable alloc]
initWithKeyFunctions: mapFunctions
objectFunctions: mapFunctions];
memset(&event, 0, sizeof(event));
event.events = EPOLLIN;
event.data.ptr = [OFNull null];
if (epoll_ctl(_epfd, EPOLL_CTL_ADD, _cancelFD[0], &event) == -1)
@throw [OFInitializationFailedException
exceptionWithClass: [self class]];
} @catch (id e) {
[self release];
@throw e;
}
return self;
}
|
|
|
|
|
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
|
@try {
struct epoll_event event;
#ifdef HAVE_EPOLL_CREATE1
if ((_epfd = epoll_create1(EPOLL_CLOEXEC)) == -1)
@throw [OFInitializationFailedException
exceptionWithClass: self.class];
#else
int flags;
if ((_epfd = epoll_create(1)) == -1)
@throw [OFInitializationFailedException
exceptionWithClass: self.class];
if ((flags = fcntl(_epfd, F_GETFD, 0)) != -1)
fcntl(_epfd, F_SETFD, flags | FD_CLOEXEC);
#endif
_FDToEvents = [[OFMapTable alloc]
initWithKeyFunctions: mapFunctions
objectFunctions: mapFunctions];
memset(&event, 0, sizeof(event));
event.events = EPOLLIN;
event.data.ptr = [OFNull null];
if (epoll_ctl(_epfd, EPOLL_CTL_ADD, _cancelFD[0], &event) == -1)
@throw [OFInitializationFailedException
exceptionWithClass: self.class];
} @catch (id e) {
[self release];
@throw e;
}
return self;
}
|
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
|
forKey: (void *)((intptr_t)fd + 1)];
}
}
- (void)of_addObjectForReading: (id <OFReadyForReadingObserving>)object
{
[self of_addObject: object
fileDescriptor: [object fileDescriptorForReading]
events: EPOLLIN];
}
- (void)of_addObjectForWriting: (id <OFReadyForWritingObserving>)object
{
[self of_addObject: object
fileDescriptor: [object fileDescriptorForWriting]
events: EPOLLOUT];
}
- (void)of_removeObjectForReading: (id <OFReadyForReadingObserving>)object
{
[self of_removeObject: object
fileDescriptor: [object fileDescriptorForReading]
events: EPOLLIN];
}
- (void)of_removeObjectForWriting: (id <OFReadyForWritingObserving>)object
{
[self of_removeObject: object
fileDescriptor: [object fileDescriptorForWriting]
events: EPOLLOUT];
}
- (void)observeForTimeInterval: (of_time_interval_t)timeInterval
{
OFNull *nullObject = [OFNull null];
struct epoll_event eventList[EVENTLIST_SIZE];
|
|
|
|
|
|
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
|
forKey: (void *)((intptr_t)fd + 1)];
}
}
- (void)of_addObjectForReading: (id <OFReadyForReadingObserving>)object
{
[self of_addObject: object
fileDescriptor: object.fileDescriptorForReading
events: EPOLLIN];
}
- (void)of_addObjectForWriting: (id <OFReadyForWritingObserving>)object
{
[self of_addObject: object
fileDescriptor: object.fileDescriptorForWriting
events: EPOLLOUT];
}
- (void)of_removeObjectForReading: (id <OFReadyForReadingObserving>)object
{
[self of_removeObject: object
fileDescriptor: object.fileDescriptorForReading
events: EPOLLIN];
}
- (void)of_removeObjectForWriting: (id <OFReadyForWritingObserving>)object
{
[self of_removeObject: object
fileDescriptor: object.fileDescriptorForWriting
events: EPOLLOUT];
}
- (void)observeForTimeInterval: (of_time_interval_t)timeInterval
{
OFNull *nullObject = [OFNull null];
struct epoll_event eventList[EVENTLIST_SIZE];
|