Package zmq
Class Ctx
java.lang.Object
zmq.Ctx
-
Nested Class Summary
Nested ClassesModifier and TypeClassDescriptionstatic class
private static class
private static enum
-
Field Summary
FieldsModifier and TypeFieldDescriptionprivate boolean
private boolean
private final Map
<String, Ctx.Endpoint> private final Lock
private final Errno
private int
private boolean
private static AtomicInteger
private int
private final Lock
private final MultiMap
<String, Ctx.PendingConnection> private Reaper
private static final int
private final Lock
private int
private Mailbox[]
private final Lock
private final List
<SocketBase> private final AtomicBoolean
(package private) static final int
private boolean
private final Mailbox
private static final int
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionboolean
checkTag()
Deprecated.(package private) IOThread
chooseIoThread
(long affinity) boolean
closeSelector
(Selector selector) private void
connectInprocSockets
(SocketBase bindSocket, Options bindOptions, Ctx.PendingConnection pendingConnection, Ctx.Side side) (package private) void
connectPending
(String addr, SocketBase bindSocket) createSocket
(int type) private void
destroy()
(package private) void
destroySocket
(SocketBase socket) errno()
(package private) Ctx.Endpoint
findEndpoint
(String addr) int
get
(int option) (package private) ZObject
private void
boolean
isActive()
(package private) void
pendConnection
(String addr, Ctx.Endpoint endpoint, Pipe[] pipes) (package private) boolean
registerEndpoint
(String addr, Ctx.Endpoint endpoint) (package private) void
sendCommand
(int tid, Command command) boolean
set
(int option, int optval) (package private) final void
shutdown()
void
(package private) boolean
unregisterEndpoint
(String addr, SocketBase socket) (package private) void
unregisterEndpoints
(SocketBase socket)
-
Field Details
-
WAIT_FOREVER
private static final int WAIT_FOREVER- See Also:
-
active
private boolean active -
sockets
-
emptySlots
-
starting
-
terminating
private boolean terminating -
slotSync
-
selectors
-
reaper
-
ioThreads
-
slotCount
private int slotCount -
slots
-
termMailbox
-
endpoints
-
endpointsSync
-
maxSocketId
-
maxSockets
private int maxSockets -
ioThreadCount
private int ioThreadCount -
blocky
private boolean blocky -
optSync
-
selectorSync
-
TERM_TID
static final int TERM_TID- See Also:
-
REAPER_TID
private static final int REAPER_TID- See Also:
-
pendingConnections
-
ipv6
private boolean ipv6 -
errno
-
-
Constructor Details
-
Ctx
public Ctx()
-
-
Method Details
-
destroy
- Throws:
IOException
-
isActive
public boolean isActive()- Returns:
- false if
terminate()
terminate() has been called.
-
checkTag
Deprecated.useisActive()
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
-
initSlots
private void initSlots() -
destroySocket
-
createSelector
-
closeSelector
-
getReaper
ZObject getReaper() -
sendCommand
-
chooseIoThread
-
registerEndpoint
-
unregisterEndpoint
-
unregisterEndpoints
-
findEndpoint
-
pendConnection
-
connectPending
-
connectInprocSockets
private void connectInprocSockets(SocketBase bindSocket, Options bindOptions, Ctx.PendingConnection pendingConnection, Ctx.Side side) -
errno
-
isActive()
instead