final class Signaler
extends java.lang.Object
implements java.io.Closeable
Modifier and Type | Class and Description |
---|---|
private static interface |
Signaler.IoOperation<O> |
Modifier and Type | Field and Description |
---|---|
private Ctx |
ctx |
private Errno |
errno |
private int |
pid |
private java.nio.channels.Pipe.SourceChannel |
r |
private long |
rcursor |
private java.nio.ByteBuffer |
rdummy |
private java.nio.channels.Selector |
selector |
private java.nio.channels.Pipe.SinkChannel |
w |
private java.util.concurrent.atomic.AtomicLong |
wcursor |
private java.nio.ByteBuffer |
wdummy |
Constructor and Description |
---|
Signaler(Ctx ctx,
int pid,
Errno errno) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
(package private) java.nio.channels.SelectableChannel |
getFd() |
private <O> O |
maksInterrupt(Signaler.IoOperation<O> operation) |
(package private) void |
recv() |
(package private) void |
send() |
java.lang.String |
toString() |
(package private) boolean |
waitEvent(long timeout) |
private final java.nio.channels.Pipe.SinkChannel w
private final java.nio.channels.Pipe.SourceChannel r
private final java.nio.channels.Selector selector
private final java.nio.ByteBuffer wdummy
private final java.nio.ByteBuffer rdummy
private final java.util.concurrent.atomic.AtomicLong wcursor
private long rcursor
private final Errno errno
private final int pid
private final Ctx ctx
private <O> O maksInterrupt(Signaler.IoOperation<O> operation) throws java.io.IOException
java.io.IOException
public void close() throws java.io.IOException
close
in interface java.io.Closeable
close
in interface java.lang.AutoCloseable
java.io.IOException
java.nio.channels.SelectableChannel getFd()
void send()
boolean waitEvent(long timeout)
void recv()
public java.lang.String toString()
toString
in class java.lang.Object