zmq

Class Ctx

java.lang.Object

zmq.Ctx

public class Ctx
extends java.lang.Object

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
(package private) static class	Ctx.Endpoint

Field Summary

Fields

Modifier and Type	Field and Description
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 int	ioThreadCount
private java.util.List<IOThread>	ioThreads
private static java.util.concurrent.atomic.AtomicInteger	maxSocketId
private int	maxSockets
private java.util.concurrent.locks.Lock	optSync
private Reaper	reaper
static int	REAPER_TID
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
private int	tag
static int	TERM_TID
private boolean	terminating
private Mailbox	termMailbox

Constructor Summary

Constructors

Constructor and Description
Ctx()

Method Summary

Modifier and Type	Method and Description
boolean	checkTag()
(package private) IOThread	chooseIoThread(long affinity)
SocketBase	createSocket(int type)
private void	destroy()
void	destroySocket(SocketBase socket)
(package private) Ctx.Endpoint	findEndpoint(java.lang.String addr)
int	get(int option)
(package private) ZObject	getReaper()
(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)
void	terminate()
(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

tag

private int tag

sockets

private final java.util.List<SocketBase> sockets

emptySlots

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

starting

private java.util.concurrent.atomic.AtomicBoolean starting

terminating

private boolean terminating

slotSync

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

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

TERM_TID

public static final int TERM_TID

See Also:

Constant Field Values

REAPER_TID

public static final int REAPER_TID

See Also:

Constant Field Values

Constructor Detail

Ctx

public Ctx()

Method Detail

destroy

private void destroy()
              throws java.io.IOException

Throws:

java.io.IOException

checkTag

public boolean checkTag()

terminate

public void terminate()

set

public boolean set(int option,
                   int optval)

get

public int get(int option)

createSocket

public SocketBase createSocket(int type)

destroySocket

public void destroySocket(SocketBase socket)

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)

unregisterEndpoints

void unregisterEndpoints(SocketBase socket)

findEndpoint

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