equal
deleted
inserted
replaced
140 // register events for outstanding I/O operations, caller already owns updateLock |
140 // register events for outstanding I/O operations, caller already owns updateLock |
141 private void updateEvents() { |
141 private void updateEvents() { |
142 assert Thread.holdsLock(updateLock); |
142 assert Thread.holdsLock(updateLock); |
143 int events = 0; |
143 int events = 0; |
144 if (readPending) |
144 if (readPending) |
145 events |= Port.POLLIN; |
145 events |= Net.POLLIN; |
146 if (connectPending || writePending) |
146 if (connectPending || writePending) |
147 events |= Port.POLLOUT; |
147 events |= Net.POLLOUT; |
148 if (events != 0) |
148 if (events != 0) |
149 port.startPoll(fdVal, events); |
149 port.startPoll(fdVal, events); |
150 } |
150 } |
151 |
151 |
152 // register events for outstanding I/O operations |
152 // register events for outstanding I/O operations |
202 /** |
202 /** |
203 * Invoked by event handler thread when file descriptor is polled |
203 * Invoked by event handler thread when file descriptor is polled |
204 */ |
204 */ |
205 @Override |
205 @Override |
206 public void onEvent(int events, boolean mayInvokeDirect) { |
206 public void onEvent(int events, boolean mayInvokeDirect) { |
207 boolean readable = (events & Port.POLLIN) > 0; |
207 boolean readable = (events & Net.POLLIN) > 0; |
208 boolean writable = (events & Port.POLLOUT) > 0; |
208 boolean writable = (events & Net.POLLOUT) > 0; |
209 if ((events & (Port.POLLERR | Port.POLLHUP)) > 0) { |
209 if ((events & (Net.POLLERR | Net.POLLHUP)) > 0) { |
210 readable = true; |
210 readable = true; |
211 writable = true; |
211 writable = true; |
212 } |
212 } |
213 finish(mayInvokeDirect, readable, writable); |
213 finish(mayInvokeDirect, readable, writable); |
214 } |
214 } |