125 |
|
|
126 |
if ((key.interestOps () & ops) != 0) |
if ((key.interestOps () & ops) != 0) |
127 |
{ |
{ |
128 |
result[counter] = key.fd; |
result[counter] = key.getNativeFD(); |
129 |
counter++; |
counter++; |
130 |
} |
} |
131 |
} |
} |
172 |
// Set new ready read/accept ops |
// Set new ready read/accept ops |
173 |
for (int i = 0; i < read.length; i++) |
for (int i = 0; i < read.length; i++) |
174 |
{ |
{ |
175 |
if (key.fd == read[i]) |
if (key.getNativeFD() == read[i]) |
176 |
{ |
{ |
177 |
if (key.channel () instanceof ServerSocketChannelImpl) |
if (key.channel () instanceof ServerSocketChannelImpl) |
178 |
{ |
{ |
188 |
// Set new ready write ops |
// Set new ready write ops |
189 |
for (int i = 0; i < write.length; i++) |
for (int i = 0; i < write.length; i++) |
190 |
{ |
{ |
191 |
if (key.fd == write[i]) |
if (key.getNativeFD() == write[i]) |
192 |
{ |
{ |
193 |
ops = ops | SelectionKey.OP_WRITE; |
ops = ops | SelectionKey.OP_WRITE; |
194 |
|
|
253 |
if (ch instanceof SocketChannelImpl) |
if (ch instanceof SocketChannelImpl) |
254 |
{ |
{ |
255 |
SocketChannelImpl sc = (SocketChannelImpl) ch; |
SocketChannelImpl sc = (SocketChannelImpl) ch; |
256 |
result = new SelectionKeyImpl (ch, this, 0); // FIXME: last argument |
result = new SocketChannelSelectionKey (ch, this); // FIXME: last argument |
257 |
} |
} |
258 |
else if (ch instanceof DatagramChannelImpl) |
else if (ch instanceof DatagramChannelImpl) |
259 |
{ |
{ |
260 |
DatagramChannelImpl dc = (DatagramChannelImpl) ch; |
DatagramChannelImpl dc = (DatagramChannelImpl) ch; |
261 |
result = new SelectionKeyImpl (ch, this, 0); // FIXME: last argument |
result = new DatagramChannelSelectionKey (ch, this); // FIXME: last argument |
262 |
} |
} |
263 |
else if (ch instanceof ServerSocketChannelImpl) |
else if (ch instanceof ServerSocketChannelImpl) |
264 |
{ |
{ |
265 |
ServerSocketChannelImpl ssc = (ServerSocketChannelImpl) ch; |
ServerSocketChannelImpl ssc = (ServerSocketChannelImpl) ch; |
266 |
result = new SelectionKeyImpl (ch, this, 0); // FIXME: last argument |
result = new SocketChannelSelectionKey (ch, this); // FIXME: last argument |
267 |
} |
} |
268 |
else |
else |
269 |
{ |
{ |