Package zmq
Class Signaler
- java.lang.Object
-
- zmq.Signaler
-
- All Implemented Interfaces:
java.io.Closeable
,java.lang.AutoCloseable
final class Signaler extends java.lang.Object implements java.io.Closeable
-
-
Field Summary
Fields Modifier and Type Field 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
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
close()
(package private) java.nio.channels.SelectableChannel
getFd()
(package private) void
recv()
(package private) void
send()
java.lang.String
toString()
(package private) boolean
waitEvent(long timeout)
-
-
-
Field Detail
-
w
private final java.nio.channels.Pipe.SinkChannel w
-
r
private final java.nio.channels.Pipe.SourceChannel r
-
selector
private final java.nio.channels.Selector selector
-
wdummy
private final java.nio.ByteBuffer wdummy
-
rdummy
private final java.nio.ByteBuffer rdummy
-
wcursor
private final java.util.concurrent.atomic.AtomicLong wcursor
-
rcursor
private long rcursor
-
errno
private final Errno errno
-
pid
private final int pid
-
ctx
private final Ctx ctx
-
-
Method Detail
-
close
public void close() throws java.io.IOException
- Specified by:
close
in interfacejava.lang.AutoCloseable
- Specified by:
close
in interfacejava.io.Closeable
- Throws:
java.io.IOException
-
getFd
java.nio.channels.SelectableChannel getFd()
-
send
void send()
-
waitEvent
boolean waitEvent(long timeout)
-
recv
void recv()
-
toString
public java.lang.String toString()
- Overrides:
toString
in classjava.lang.Object
-
-