Package zmq
Class Signaler
java.lang.Object
zmq.Signaler
- All Implemented Interfaces:
Closeable
,AutoCloseable
-
Nested Class Summary
Nested Classes -
Field Summary
FieldsModifier and TypeFieldDescriptionprivate final Ctx
private final Errno
private final int
private final Pipe.SourceChannel
private long
private final ByteBuffer
private final Selector
private final Pipe.SinkChannel
private final AtomicLong
private final ByteBuffer
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionvoid
close()
(package private) SelectableChannel
getFd()
private <O> O
maksInterrupt
(Signaler.IoOperation<O> operation) (package private) void
recv()
(package private) void
send()
toString()
(package private) boolean
waitEvent
(long timeout)
-
Field Details
-
w
-
r
-
selector
-
wdummy
-
rdummy
-
wcursor
-
rcursor
private long rcursor -
errno
-
pid
private final int pid -
ctx
-
-
Constructor Details
-
Signaler
-
-
Method Details
-
maksInterrupt
- Throws:
IOException
-
close
- Specified by:
close
in interfaceAutoCloseable
- Specified by:
close
in interfaceCloseable
- Throws:
IOException
-
getFd
SelectableChannel getFd() -
send
void send() -
waitEvent
boolean waitEvent(long timeout) -
recv
void recv() -
toString
-