Package | Description |
---|---|
zmq |
Provides low-level bindings for ØMQ.
|
zmq.io | |
zmq.pipe | |
zmq.socket | |
zmq.socket.clientserver | |
zmq.socket.pipeline | |
zmq.socket.pubsub | |
zmq.socket.radiodish | |
zmq.socket.reqrep | |
zmq.socket.scattergather |
Modifier and Type | Field and Description |
---|---|
private Pipe |
Ctx.PendingConnection.bindPipe |
private Pipe |
Ctx.PendingConnection.connectPipe |
private Pipe |
SocketBase.EndpointPipe.pipe |
Modifier and Type | Field and Description |
---|---|
private MultiMap<java.lang.String,Pipe> |
SocketBase.inprocs |
private java.util.Set<Pipe> |
SocketBase.pipes |
Modifier and Type | Method and Description |
---|---|
private void |
SocketBase.addEndpoint(java.lang.String addr,
Own endpoint,
Pipe pipe) |
private void |
SocketBase.attachPipe(Pipe pipe,
boolean isLocallyInitiated) |
private void |
SocketBase.attachPipe(Pipe pipe,
boolean subscribe2all,
boolean isLocallyInitiated) |
void |
SocketBase.hiccuped(Pipe pipe) |
protected void |
ZObject.pendConnection(java.lang.String addr,
Ctx.Endpoint endpoint,
Pipe[] pipes) |
(package private) void |
Ctx.pendConnection(java.lang.String addr,
Ctx.Endpoint endpoint,
Pipe[] pipes) |
void |
SocketBase.pipeTerminated(Pipe pipe) |
protected void |
SocketBase.processBind(Pipe pipe) |
protected void |
ZObject.processBind(Pipe pipe) |
void |
SocketBase.readActivated(Pipe pipe) |
protected void |
ZObject.sendActivateRead(Pipe destination) |
protected void |
ZObject.sendActivateWrite(Pipe destination,
long msgsRead) |
protected void |
ZObject.sendBind(Own destination,
Pipe pipe) |
protected void |
ZObject.sendBind(Own destination,
Pipe pipe,
boolean incSeqnum) |
protected void |
ZObject.sendHiccup(Pipe destination,
YPipeBase<Msg> pipe) |
protected void |
ZObject.sendPipeTerm(Pipe destination) |
protected void |
ZObject.sendPipeTermAck(Pipe destination) |
void |
SocketBase.writeActivated(Pipe pipe) |
protected abstract void |
SocketBase.xattachPipe(Pipe pipe,
boolean subscribe2all,
boolean isLocallyInitiated) |
protected void |
SocketBase.xhiccuped(Pipe pipe) |
protected abstract void |
SocketBase.xpipeTerminated(Pipe pipe) |
protected void |
SocketBase.xreadActivated(Pipe pipe) |
protected void |
SocketBase.xwriteActivated(Pipe pipe) |
Constructor and Description |
---|
EndpointPipe(Own endpoint,
Pipe pipe) |
PendingConnection(Ctx.Endpoint endpoint,
Pipe connectPipe,
Pipe bindPipe) |
Modifier and Type | Field and Description |
---|---|
private Pipe |
SessionBase.pipe |
private Pipe |
SessionBase.zapPipe |
Modifier and Type | Field and Description |
---|---|
private java.util.Set<Pipe> |
SessionBase.terminatingPipes |
Modifier and Type | Method and Description |
---|---|
void |
SessionBase.attachPipe(Pipe pipe) |
void |
SessionBase.hiccuped(Pipe pipe) |
void |
SessionBase.pipeTerminated(Pipe pipe) |
void |
SessionBase.readActivated(Pipe pipe) |
void |
SessionBase.writeActivated(Pipe pipe) |
Modifier and Type | Field and Description |
---|---|
private Pipe |
Pipe.peer |
Modifier and Type | Method and Description |
---|---|
static Pipe[] |
Pipe.pair(ZObject[] parents,
int[] hwms,
boolean[] conflates) |
Modifier and Type | Method and Description |
---|---|
void |
Pipe.IPipeEvents.hiccuped(Pipe pipe) |
void |
Pipe.IPipeEvents.pipeTerminated(Pipe pipe) |
void |
Pipe.IPipeEvents.readActivated(Pipe pipe) |
private void |
Pipe.setPeer(Pipe peer) |
void |
Pipe.IPipeEvents.writeActivated(Pipe pipe) |
Modifier and Type | Field and Description |
---|---|
private Pipe |
Stream.currentOut |
private Pipe |
Pair.lastIn |
private Pipe |
FQ.lastIn |
private Pipe |
Channel.lastIn |
private Pipe |
Pair.pipe |
private Pipe |
Channel.pipe |
private Pipe |
Stream.Outpipe.pipe |
Modifier and Type | Field and Description |
---|---|
private java.util.List<Pipe> |
LB.pipes |
private java.util.List<Pipe> |
FQ.pipes |
Modifier and Type | Method and Description |
---|---|
void |
LB.activated(Pipe pipe) |
void |
FQ.activated(Pipe pipe) |
void |
LB.attach(Pipe pipe) |
void |
FQ.attach(Pipe pipe) |
private void |
Stream.identifyPeer(Pipe pipe,
boolean isLocallyInitiated) |
void |
LB.terminated(Pipe pipe) |
void |
FQ.terminated(Pipe pipe) |
void |
Peer.xattachPipe(Pipe pipe,
boolean subscribe2all,
boolean isLocallyInitiated) |
protected void |
Pair.xattachPipe(Pipe pipe,
boolean subscribe2all,
boolean isLocallyInitiated) |
protected void |
Channel.xattachPipe(Pipe pipe,
boolean subscribe2all,
boolean isLocallyInitiated) |
protected void |
Stream.xattachPipe(Pipe pipe,
boolean icanhasall,
boolean isLocallyInitiated) |
protected void |
Pair.xpipeTerminated(Pipe pipe) |
protected void |
Channel.xpipeTerminated(Pipe pipe) |
protected void |
Stream.xpipeTerminated(Pipe pipe) |
protected void |
Pair.xreadActivated(Pipe pipe) |
protected void |
Channel.xreadActivated(Pipe pipe) |
protected void |
Stream.xreadActivated(Pipe pipe) |
protected void |
Pair.xwriteActivated(Pipe pipe) |
protected void |
Channel.xwriteActivated(Pipe pipe) |
protected void |
Stream.xwriteActivated(Pipe pipe) |
Modifier and Type | Method and Description |
---|---|
Msg |
FQ.recvPipe(Errno errno,
ValueReference<Pipe> pipe) |
boolean |
LB.sendpipe(Msg msg,
Errno errno,
ValueReference<Pipe> pipe) |
Constructor and Description |
---|
Outpipe(Pipe pipe,
boolean active) |
Modifier and Type | Field and Description |
---|---|
private Pipe |
Server.Outpipe.pipe |
Modifier and Type | Method and Description |
---|---|
protected void |
Client.xattachPipe(Pipe pipe,
boolean subscribe2all,
boolean isLocallyInitiated) |
void |
Server.xattachPipe(Pipe pipe,
boolean subscribe2all,
boolean isLocallyInitiated) |
protected void |
Client.xpipeTerminated(Pipe pipe) |
void |
Server.xpipeTerminated(Pipe pipe) |
protected void |
Client.xreadActivated(Pipe pipe) |
void |
Server.xreadActivated(Pipe pipe) |
protected void |
Client.xwriteActivated(Pipe pipe) |
void |
Server.xwriteActivated(Pipe pipe) |
Constructor and Description |
---|
Outpipe(Pipe pipe,
boolean active) |
Modifier and Type | Method and Description |
---|---|
protected void |
Push.xattachPipe(Pipe pipe,
boolean subscribe2all,
boolean isLocallyInitiated) |
protected void |
Pull.xattachPipe(Pipe pipe,
boolean subscribe2all,
boolean isLocallyInitiated) |
protected void |
Push.xpipeTerminated(Pipe pipe) |
protected void |
Pull.xpipeTerminated(Pipe pipe) |
protected void |
Pull.xreadActivated(Pipe pipe) |
protected void |
Push.xwriteActivated(Pipe pipe) |
Modifier and Type | Field and Description |
---|---|
private Pipe |
XPub.lastPipe |
Modifier and Type | Field and Description |
---|---|
private java.util.Deque<Pipe> |
XPub.pendingPipes |
private java.util.Set<Pipe> |
Mtrie.pipes |
private java.util.List<Pipe> |
Dist.pipes |
Modifier and Type | Method and Description |
---|---|
void |
Dist.activated(Pipe pipe) |
boolean |
Mtrie.add(Msg msg,
Pipe pipe) |
void |
Trie.ITrieHandler.added(byte[] data,
int size,
Pipe arg) |
void |
XSub.SendSubscription.added(byte[] data,
int size,
Pipe pipe) |
private boolean |
Mtrie.addHelper(Msg msg,
int start,
int size,
Pipe pipe) |
(package private) boolean |
Mtrie.addOnTop(Pipe pipe) |
void |
Trie.apply(Trie.ITrieHandler func,
Pipe arg) |
private void |
Trie.applyHelper(byte[] buff,
int buffsize,
int maxBuffsize,
Trie.ITrieHandler func,
Pipe pipe) |
void |
Dist.attach(Pipe pipe) |
void |
XPub.SendUnsubscription.invoke(Pipe pipe,
byte[] data,
int size,
XPub self) |
void |
XPub.MarkAsMatching.invoke(Pipe pipe,
byte[] data,
int size,
XPub self) |
void |
Mtrie.IMtrieHandler.invoke(Pipe pipe,
byte[] data,
int size,
XPub arg) |
private void |
XPub.markAsMatching(Pipe pipe) |
void |
Dist.match(Pipe pipe) |
boolean |
Mtrie.rm(Msg msg,
Pipe pipe) |
boolean |
Mtrie.rm(Pipe pipe,
Mtrie.IMtrieHandler func,
XPub pub) |
private boolean |
Mtrie.rmHelper(Msg msg,
int start,
int size,
Pipe pipe) |
private boolean |
Mtrie.rmHelper(Pipe pipe,
byte[] buff,
int buffsize,
int maxBuffSize,
Mtrie.IMtrieHandler func,
XPub pub) |
private boolean |
XSub.sendSubscription(byte[] data,
int size,
Pipe pipe) |
void |
Dist.terminated(Pipe pipe) |
private boolean |
Dist.write(Pipe pipe,
Msg msg) |
protected void |
XPub.xattachPipe(Pipe pipe,
boolean subscribeToAll,
boolean isLocallyInitiated) |
protected void |
Pub.xattachPipe(Pipe pipe,
boolean subscribeToAll,
boolean isLocallyInitiated) |
protected void |
XSub.xattachPipe(Pipe pipe,
boolean subscribe2all,
boolean isLocallyInitiated) |
protected void |
XSub.xhiccuped(Pipe pipe) |
protected void |
XPub.xpipeTerminated(Pipe pipe) |
protected void |
XSub.xpipeTerminated(Pipe pipe) |
protected void |
XPub.xreadActivated(Pipe pipe) |
protected void |
XSub.xreadActivated(Pipe pipe) |
protected void |
XPub.xwriteActivated(Pipe pipe) |
protected void |
XSub.xwriteActivated(Pipe pipe) |
Modifier and Type | Field and Description |
---|---|
private java.util.Map<java.lang.String,java.util.List<Pipe>> |
Radio.subscriptions |
Modifier and Type | Method and Description |
---|---|
private void |
Dish.sendSubscriptions(Pipe pipe) |
protected void |
Dish.xattachPipe(Pipe pipe,
boolean subscribe2all,
boolean isLocallyInitiated) |
void |
Radio.xattachPipe(Pipe pipe,
boolean subscribe2all,
boolean isLocallyInitiated) |
protected void |
Dish.xhiccuped(Pipe pipe) |
protected void |
Dish.xpipeTerminated(Pipe pipe) |
void |
Radio.xpipeTerminated(Pipe pipe) |
protected void |
Dish.xreadActivated(Pipe pipe) |
void |
Radio.xreadActivated(Pipe pipe) |
protected void |
Dish.xwriteActivated(Pipe pipe) |
void |
Radio.xwriteActivated(Pipe pipe) |
Modifier and Type | Field and Description |
---|---|
private Pipe |
Router.currentOut |
private Pipe |
Router.Outpipe.pipe |
Modifier and Type | Field and Description |
---|---|
private java.util.Set<Pipe> |
Router.anonymousPipes |
private ValueReference<Pipe> |
Req.replyPipe |
Modifier and Type | Method and Description |
---|---|
private boolean |
Router.identifyPeer(Pipe pipe,
boolean isLocallyInitiated) |
void |
Router.xattachPipe(Pipe pipe,
boolean subscribe2all,
boolean isLocallyInitiated) |
protected void |
Dealer.xattachPipe(Pipe pipe,
boolean subscribe2all,
boolean isLocallyInitiated) |
void |
Router.xpipeTerminated(Pipe pipe) |
protected void |
Dealer.xpipeTerminated(Pipe pipe) |
protected void |
Req.xpipeTerminated(Pipe pipe) |
void |
Router.xreadActivated(Pipe pipe) |
protected void |
Dealer.xreadActivated(Pipe pipe) |
void |
Router.xwriteActivated(Pipe pipe) |
protected void |
Dealer.xwriteActivated(Pipe pipe) |
Modifier and Type | Method and Description |
---|---|
protected Msg |
Dealer.recvpipe(ValueReference<Pipe> pipe) |
protected boolean |
Dealer.sendpipe(Msg msg,
ValueReference<Pipe> pipe) |
Constructor and Description |
---|
Outpipe(Pipe pipe,
boolean active) |
Modifier and Type | Method and Description |
---|---|
protected void |
Scatter.xattachPipe(Pipe pipe,
boolean subscribe2all,
boolean isLocallyInitiated) |
protected void |
Gather.xattachPipe(Pipe pipe,
boolean subscribe2all,
boolean isLocallyInitiated) |
protected void |
Scatter.xpipeTerminated(Pipe pipe) |
protected void |
Gather.xpipeTerminated(Pipe pipe) |
protected void |
Gather.xreadActivated(Pipe pipe) |
protected void |
Scatter.xwriteActivated(Pipe pipe) |