package org.xnio.nio;
import static org.xnio.nio.Log.log;
import java.io.IOException;
import java.io.InterruptedIOException;
import java.nio.channels.ClosedChannelException;
import java.nio.channels.SelectableChannel;
import java.nio.channels.SelectionKey;
import java.nio.channels.Selector;
import java.util.concurrent.TimeUnit;
import org.xnio.Xnio;
final class SelectorUtils {
private SelectorUtils() {
}
public static void await(NioXnio nioXnio, SelectableChannel channel, int op) throws IOException {
if (NioXnio.IS_HP_UX) {
await(nioXnio, channel, op, 1, TimeUnit.SECONDS);
return;
}
Xnio.checkBlockingAllowed();
final Selector selector = nioXnio.getSelector();
final SelectionKey selectionKey;
try {
selectionKey = channel.register(selector, op);
} catch (ClosedChannelException e) {
return;
}
selector.select();
selector.selectedKeys().clear();
if (Thread.currentThread().isInterrupted()) {
throw log.interruptedIO();
}
selectionKey.cancel();
selector.selectNow();
}
public static void await(NioXnio nioXnio, SelectableChannel channel, int op, long time, TimeUnit unit) throws IOException {
if (time <= 0) {
await(nioXnio, channel, op);
return;
}
Xnio.checkBlockingAllowed();
final Selector selector = nioXnio.getSelector();
final SelectionKey selectionKey;
try {
selectionKey = channel.register(selector, op);
} catch (ClosedChannelException e) {
return;
}
long timeoutInMillis = unit.toMillis(time);
selector.select(timeoutInMillis == 0 ? 1: timeoutInMillis);
selector.selectedKeys().clear();
if (Thread.currentThread().isInterrupted()) {
throw log.interruptedIO();
}
selectionKey.cancel();
selector.selectNow();
}
}