Uses of Class
zmq.pipe.Pipe
-
Packages that use Pipe 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 -
-
Uses of Pipe in zmq
Fields in zmq declared as Pipe Modifier and Type Field Description private Pipe
Ctx.PendingConnection. bindPipe
private Pipe
Ctx.PendingConnection. connectPipe
private Pipe
SocketBase.EndpointPipe. pipe
Fields in zmq with type parameters of type Pipe Modifier and Type Field Description private MultiMap<java.lang.String,Pipe>
SocketBase. inprocs
private java.util.Set<Pipe>
SocketBase. pipes
Methods in zmq with parameters of type Pipe Modifier and Type Method 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)
(package private) void
Ctx. pendConnection(java.lang.String addr, Ctx.Endpoint endpoint, Pipe[] pipes)
protected void
ZObject. 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)
Constructors in zmq with parameters of type Pipe Constructor Description EndpointPipe(Own endpoint, Pipe pipe)
PendingConnection(Ctx.Endpoint endpoint, Pipe connectPipe, Pipe bindPipe)
-
Uses of Pipe in zmq.io
Fields in zmq.io declared as Pipe Modifier and Type Field Description private Pipe
SessionBase. pipe
private Pipe
SessionBase. zapPipe
Fields in zmq.io with type parameters of type Pipe Modifier and Type Field Description private java.util.Set<Pipe>
SessionBase. terminatingPipes
Methods in zmq.io with parameters of type Pipe Modifier and Type Method 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)
-
Uses of Pipe in zmq.pipe
Fields in zmq.pipe declared as Pipe Modifier and Type Field Description private Pipe
Pipe. peer
Methods in zmq.pipe that return Pipe Modifier and Type Method Description static Pipe[]
Pipe. pair(ZObject[] parents, int[] hwms, boolean[] conflates)
Methods in zmq.pipe with parameters of type Pipe Modifier and Type Method 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)
-
Uses of Pipe in zmq.socket
Fields in zmq.socket declared as Pipe Modifier and Type Field Description private Pipe
Stream. currentOut
private Pipe
Channel. lastIn
private Pipe
FQ. lastIn
private Pipe
Pair. lastIn
private Pipe
Channel. pipe
private Pipe
Pair. pipe
private Pipe
Stream.Outpipe. pipe
Fields in zmq.socket with type parameters of type Pipe Modifier and Type Field Description private java.util.List<Pipe>
FQ. pipes
private java.util.List<Pipe>
LB. pipes
Methods in zmq.socket with parameters of type Pipe Modifier and Type Method Description void
FQ. activated(Pipe pipe)
void
LB. activated(Pipe pipe)
void
FQ. attach(Pipe pipe)
void
LB. attach(Pipe pipe)
private void
Stream. identifyPeer(Pipe pipe, boolean isLocallyInitiated)
void
FQ. terminated(Pipe pipe)
void
LB. terminated(Pipe pipe)
protected void
Channel. xattachPipe(Pipe pipe, boolean subscribe2all, boolean isLocallyInitiated)
protected void
Pair. xattachPipe(Pipe pipe, boolean subscribe2all, boolean isLocallyInitiated)
void
Peer. xattachPipe(Pipe pipe, boolean subscribe2all, boolean isLocallyInitiated)
protected void
Stream. xattachPipe(Pipe pipe, boolean icanhasall, boolean isLocallyInitiated)
protected void
Channel. xpipeTerminated(Pipe pipe)
protected void
Pair. xpipeTerminated(Pipe pipe)
protected void
Stream. xpipeTerminated(Pipe pipe)
protected void
Channel. xreadActivated(Pipe pipe)
protected void
Pair. xreadActivated(Pipe pipe)
protected void
Stream. xreadActivated(Pipe pipe)
protected void
Channel. xwriteActivated(Pipe pipe)
protected void
Pair. xwriteActivated(Pipe pipe)
protected void
Stream. xwriteActivated(Pipe pipe)
Method parameters in zmq.socket with type arguments of type Pipe Modifier and Type Method Description Msg
FQ. recvPipe(Errno errno, ValueReference<Pipe> pipe)
boolean
LB. sendpipe(Msg msg, Errno errno, ValueReference<Pipe> pipe)
Constructors in zmq.socket with parameters of type Pipe Constructor Description Outpipe(Pipe pipe, boolean active)
-
Uses of Pipe in zmq.socket.clientserver
Fields in zmq.socket.clientserver declared as Pipe Modifier and Type Field Description private Pipe
Server.Outpipe. pipe
Methods in zmq.socket.clientserver with parameters of type Pipe Modifier and Type Method 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)
Constructors in zmq.socket.clientserver with parameters of type Pipe Constructor Description Outpipe(Pipe pipe, boolean active)
-
Uses of Pipe in zmq.socket.pipeline
Methods in zmq.socket.pipeline with parameters of type Pipe Modifier and Type Method Description protected void
Pull. xattachPipe(Pipe pipe, boolean subscribe2all, boolean isLocallyInitiated)
protected void
Push. xattachPipe(Pipe pipe, boolean subscribe2all, boolean isLocallyInitiated)
protected void
Pull. xpipeTerminated(Pipe pipe)
protected void
Push. xpipeTerminated(Pipe pipe)
protected void
Pull. xreadActivated(Pipe pipe)
protected void
Push. xwriteActivated(Pipe pipe)
-
Uses of Pipe in zmq.socket.pubsub
Fields in zmq.socket.pubsub declared as Pipe Modifier and Type Field Description private Pipe
XPub. lastPipe
Fields in zmq.socket.pubsub with type parameters of type Pipe Modifier and Type Field Description private java.util.Deque<Pipe>
XPub. pendingPipes
private java.util.List<Pipe>
Dist. pipes
private java.util.Set<Pipe>
Mtrie. pipes
Methods in zmq.socket.pubsub with parameters of type Pipe Modifier and Type Method 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
Mtrie.IMtrieHandler. invoke(Pipe pipe, byte[] data, int size, XPub arg)
void
XPub.MarkAsMatching. invoke(Pipe pipe, byte[] data, int size, XPub self)
void
XPub.SendUnsubscription. invoke(Pipe pipe, byte[] data, int size, XPub self)
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
Pub. xattachPipe(Pipe pipe, boolean subscribeToAll, boolean isLocallyInitiated)
protected void
XPub. 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)
-
Uses of Pipe in zmq.socket.radiodish
Fields in zmq.socket.radiodish with type parameters of type Pipe Modifier and Type Field Description private java.util.Map<java.lang.String,java.util.List<Pipe>>
Radio. subscriptions
Methods in zmq.socket.radiodish with parameters of type Pipe Modifier and Type Method 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)
-
Uses of Pipe in zmq.socket.reqrep
Fields in zmq.socket.reqrep declared as Pipe Modifier and Type Field Description private Pipe
Router. currentOut
private Pipe
Router.Outpipe. pipe
Fields in zmq.socket.reqrep with type parameters of type Pipe Modifier and Type Field Description private java.util.Set<Pipe>
Router. anonymousPipes
private ValueReference<Pipe>
Req. replyPipe
Methods in zmq.socket.reqrep with parameters of type Pipe Modifier and Type Method Description private boolean
Router. identifyPeer(Pipe pipe, boolean isLocallyInitiated)
protected void
Dealer. xattachPipe(Pipe pipe, boolean subscribe2all, boolean isLocallyInitiated)
void
Router. xattachPipe(Pipe pipe, boolean subscribe2all, boolean isLocallyInitiated)
protected void
Dealer. xpipeTerminated(Pipe pipe)
protected void
Req. xpipeTerminated(Pipe pipe)
void
Router. xpipeTerminated(Pipe pipe)
protected void
Dealer. xreadActivated(Pipe pipe)
void
Router. xreadActivated(Pipe pipe)
protected void
Dealer. xwriteActivated(Pipe pipe)
void
Router. xwriteActivated(Pipe pipe)
Method parameters in zmq.socket.reqrep with type arguments of type Pipe Modifier and Type Method Description protected Msg
Dealer. recvpipe(ValueReference<Pipe> pipe)
protected boolean
Dealer. sendpipe(Msg msg, ValueReference<Pipe> pipe)
Constructors in zmq.socket.reqrep with parameters of type Pipe Constructor Description Outpipe(Pipe pipe, boolean active)
-
Uses of Pipe in zmq.socket.scattergather
Methods in zmq.socket.scattergather with parameters of type Pipe Modifier and Type Method Description protected void
Gather. xattachPipe(Pipe pipe, boolean subscribe2all, boolean isLocallyInitiated)
protected void
Scatter. xattachPipe(Pipe pipe, boolean subscribe2all, boolean isLocallyInitiated)
protected void
Gather. xpipeTerminated(Pipe pipe)
protected void
Scatter. xpipeTerminated(Pipe pipe)
protected void
Gather. xreadActivated(Pipe pipe)
protected void
Scatter. xwriteActivated(Pipe pipe)
-