Class Signaler

java.lang.Object

zmq.Signaler

All Implemented Interfaces:

Closeable, AutoCloseable

final class Signaler
extends Object
implements Closeable

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
private static interface	Signaler.IoOperation<O>

Field Summary

Fields

Modifier and Type	Field	Description
private final Ctx	ctx
private final Errno	errno
private final int	pid
private final Pipe.SourceChannel	r
private long	rcursor
private final ByteBuffer	rdummy
private final Selector	selector
private final Pipe.SinkChannel	w
private final AtomicLong	wcursor
private final ByteBuffer	wdummy

Constructor Summary

Constructors

Constructor	Description
Signaler(Ctx ctx, int pid, Errno errno)

Method Summary

Modifier and Type	Method	Description
void	close()
(package private) SelectableChannel	getFd()
private <O> O	maksInterrupt(Signaler.IoOperation<O> operation)
(package private) void	recv()
(package private) void	send()
String	toString()
(package private) boolean	waitEvent(long timeout)

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Details

w

private final Pipe.SinkChannel w

r

private final Pipe.SourceChannel r

selector

private final Selector selector

wdummy

private final ByteBuffer wdummy

rdummy

private final ByteBuffer rdummy

wcursor

private final AtomicLong wcursor

rcursor

private long rcursor

errno

private final Errno errno

pid

private final int pid

ctx

private final Ctx ctx

Constructor Details

Signaler

Signaler(Ctx ctx,
 int pid,
 Errno errno)

Method Details

maksInterrupt

private <O> O maksInterrupt(Signaler.IoOperation<O> operation)
                     throws IOException

Throws:

IOException

close

public void close()
           throws IOException

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Throws:

IOException

getFd

SelectableChannel getFd()

send

void send()

waitEvent

boolean waitEvent(long timeout)

recv

void recv()

toString

public String toString()

Overrides:

toString in class Object