Package zmq

Class Ctx

java.lang.Object

zmq.Ctx

public class Ctx
extends java.lang.Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	Ctx.Endpoint
private static class	Ctx.PendingConnection
private static class	Ctx.Side

Field Summary

Fields

Modifier and Type	Field	Description
private boolean	active
private boolean	blocky
private java.util.Deque<java.lang.Integer>	emptySlots
private java.util.Map<java.lang.String,Ctx.Endpoint>	endpoints
private java.util.concurrent.locks.Lock	endpointsSync
private Errno	errno
private int	ioThreadCount
private java.util.List<IOThread>	ioThreads
private boolean	ipv6
private static java.util.concurrent.atomic.AtomicInteger	maxSocketId
private int	maxSockets
private java.util.concurrent.locks.Lock	optSync
private MultiMap<java.lang.String,Ctx.PendingConnection>	pendingConnections
private Reaper	reaper
private static int	REAPER_TID
private java.util.List<java.nio.channels.Selector>	selectors
private java.util.concurrent.locks.Lock	selectorSync
private int	slotCount
private Mailbox[]	slots
private java.util.concurrent.locks.Lock	slotSync
private java.util.List<SocketBase>	sockets
private java.util.concurrent.atomic.AtomicBoolean	starting
(package private) static int	TERM_TID
private boolean	terminating
private Mailbox	termMailbox
private static int	WAIT_FOREVER

Constructor Summary

Constructors

Constructor	Description
Ctx()

Method Summary

Modifier and Type	Method	Description
boolean	checkTag()	Deprecated. use isActive() instead
(package private) IOThread	chooseIoThread(long affinity)
boolean	closeSelector(java.nio.channels.Selector selector)
private void	connectInprocSockets(SocketBase bindSocket, Options bindOptions, Ctx.PendingConnection pendingConnection, Ctx.Side side)
(package private) void	connectPending(java.lang.String addr, SocketBase bindSocket)
java.nio.channels.Selector	createSelector()
SocketBase	createSocket(int type)
private void	destroy()
(package private) void	destroySocket(SocketBase socket)
Errno	errno()
(package private) Ctx.Endpoint	findEndpoint(java.lang.String addr)
int	get(int option)
(package private) ZObject	getReaper()
private void	initSlots()
boolean	isActive()
(package private) void	pendConnection(java.lang.String addr, Ctx.Endpoint endpoint, Pipe[] pipes)
(package private) boolean	registerEndpoint(java.lang.String addr, Ctx.Endpoint endpoint)
(package private) void	sendCommand(int tid, Command command)
boolean	set(int option, int optval)
(package private) void	shutdown()
void	terminate()
(package private) boolean	unregisterEndpoint(java.lang.String addr, SocketBase socket)
(package private) void	unregisterEndpoints(SocketBase socket)

Methods inherited from class java.lang.Object

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

Field Detail

WAIT_FOREVER

private static final int WAIT_FOREVER

See Also:

Constant Field Values

active

private boolean active

sockets

private final java.util.List<SocketBase> sockets

emptySlots

private final java.util.Deque<java.lang.Integer> emptySlots

starting

private final java.util.concurrent.atomic.AtomicBoolean starting

terminating

private boolean terminating

slotSync

private final java.util.concurrent.locks.Lock slotSync

selectors

private final java.util.List<java.nio.channels.Selector> selectors

reaper

private Reaper reaper

ioThreads

private final java.util.List<IOThread> ioThreads

slotCount

private int slotCount

slots

private Mailbox[] slots

termMailbox

private final Mailbox termMailbox

endpoints

private final java.util.Map<java.lang.String,Ctx.Endpoint> endpoints

endpointsSync

private final java.util.concurrent.locks.Lock endpointsSync

maxSocketId

private static java.util.concurrent.atomic.AtomicInteger maxSocketId

maxSockets

private int maxSockets

ioThreadCount

private int ioThreadCount

blocky

private boolean blocky

optSync

private final java.util.concurrent.locks.Lock optSync

selectorSync

private final java.util.concurrent.locks.Lock selectorSync

TERM_TID

static final int TERM_TID

See Also:

Constant Field Values

REAPER_TID

private static final int REAPER_TID

See Also:

Constant Field Values

pendingConnections

private final MultiMap<java.lang.String,Ctx.PendingConnection> pendingConnections

ipv6

private boolean ipv6

errno

private final Errno errno

Constructor Detail

Ctx

public Ctx()

Method Detail

destroy

private void destroy()
              throws java.io.IOException

Throws:

java.io.IOException

isActive

public boolean isActive()

Returns:

false if terminate()terminate() has been called.

checkTag

@Deprecated
public boolean checkTag()

Deprecated.

use isActive() instead

Returns:

false if terminate()terminate() has been called.

terminate

public void terminate()

shutdown

final void shutdown()

set

public boolean set(int option,
                   int optval)

get

public int get(int option)

createSocket

public SocketBase createSocket(int type)

initSlots

private void initSlots()

destroySocket

void destroySocket(SocketBase socket)

createSelector

public java.nio.channels.Selector createSelector()

closeSelector

public boolean closeSelector(java.nio.channels.Selector selector)

getReaper

ZObject getReaper()

sendCommand

void sendCommand(int tid,
                 Command command)

chooseIoThread

IOThread chooseIoThread(long affinity)

registerEndpoint

boolean registerEndpoint(java.lang.String addr,
                         Ctx.Endpoint endpoint)

unregisterEndpoint

boolean unregisterEndpoint(java.lang.String addr,
                           SocketBase socket)

unregisterEndpoints

void unregisterEndpoints(SocketBase socket)

findEndpoint

Ctx.Endpoint findEndpoint(java.lang.String addr)

pendConnection

void pendConnection(java.lang.String addr,
                    Ctx.Endpoint endpoint,
                    Pipe[] pipes)

connectPending

void connectPending(java.lang.String addr,
                    SocketBase bindSocket)

connectInprocSockets

private void connectInprocSockets(SocketBase bindSocket,
                                  Options bindOptions,
                                  Ctx.PendingConnection pendingConnection,
                                  Ctx.Side side)

errno

public Errno errno()