Modifier | Constructor and Description |
---|---|
protected |
ZObject(Ctx ctx,
int tid) |
protected |
ZObject(ZObject parent) |
Modifier and Type | Method and Description |
---|---|
protected IOThread |
chooseIoThread(long affinity) |
protected void |
connectPending(java.lang.String addr,
SocketBase bindSocket) |
protected void |
destroySocket(SocketBase socket) |
protected Ctx.Endpoint |
findEndpoint(java.lang.String addr) |
protected Ctx |
getCtx() |
int |
getTid() |
protected void |
pendConnection(java.lang.String addr,
Ctx.Endpoint endpoint,
Pipe[] pipes) |
protected void |
processActivateRead() |
protected void |
processActivateWrite(long msgsRead) |
protected void |
processAttach(IEngine engine) |
protected void |
processBind(Pipe pipe) |
protected void |
processCancel() |
(package private) void |
processCommand(Command cmd) |
protected void |
processHiccup(YPipeBase<Msg> hiccupPipe) |
protected void |
processOwn(Own object) |
protected void |
processPipeTerm() |
protected void |
processPipeTermAck() |
protected void |
processPlug() |
protected void |
processReap(SocketBase socket) |
protected void |
processReapAck() |
protected void |
processReaped() |
protected void |
processSeqnum() |
protected void |
processStop() |
protected void |
processTerm(int linger) |
protected void |
processTermAck() |
protected void |
processTermReq(Own object) |
protected boolean |
registerEndpoint(java.lang.String addr,
Ctx.Endpoint endpoint) |
protected void |
sendActivateRead(Pipe destination) |
protected void |
sendActivateWrite(Pipe destination,
long msgsRead) |
protected void |
sendAttach(SessionBase destination,
IEngine engine) |
protected void |
sendAttach(SessionBase destination,
IEngine engine,
boolean incSeqnum) |
protected void |
sendBind(Own destination,
Pipe pipe) |
protected void |
sendBind(Own destination,
Pipe pipe,
boolean incSeqnum) |
protected void |
sendCancel() |
private void |
sendCommand(Command cmd) |
protected void |
sendDone() |
protected void |
sendHiccup(Pipe destination,
YPipeBase<Msg> pipe) |
protected void |
sendInprocConnected(SocketBase socket) |
protected void |
sendOwn(Own destination,
Own object) |
protected void |
sendPipeTerm(Pipe destination) |
protected void |
sendPipeTermAck(Pipe destination) |
protected void |
sendPlug(Own destination) |
protected void |
sendPlug(Own destination,
boolean incSeqnum) |
protected void |
sendReap(SocketBase socket) |
protected void |
sendReapAck() |
protected void |
sendReaped() |
protected void |
sendStop() |
protected void |
sendTerm(Own destination,
int linger) |
protected void |
sendTermAck(Own destination) |
protected void |
sendTermReq(Own destination,
Own object) |
protected void |
setTid(int tid) |
protected boolean |
unregisterEndpoint(java.lang.String addr,
SocketBase socket) |
protected void |
unregisterEndpoints(SocketBase socket) |
private final Ctx ctx
private int tid
protected ZObject(Ctx ctx, int tid)
protected ZObject(ZObject parent)
public final int getTid()
protected final void setTid(int tid)
protected final Ctx getCtx()
final void processCommand(Command cmd)
protected final boolean registerEndpoint(java.lang.String addr, Ctx.Endpoint endpoint)
protected final boolean unregisterEndpoint(java.lang.String addr, SocketBase socket)
protected final void unregisterEndpoints(SocketBase socket)
protected final Ctx.Endpoint findEndpoint(java.lang.String addr)
protected final void pendConnection(java.lang.String addr, Ctx.Endpoint endpoint, Pipe[] pipes)
protected final void connectPending(java.lang.String addr, SocketBase bindSocket)
protected final void destroySocket(SocketBase socket)
protected final IOThread chooseIoThread(long affinity)
protected final void sendStop()
protected final void sendPlug(Own destination)
protected final void sendPlug(Own destination, boolean incSeqnum)
protected final void sendAttach(SessionBase destination, IEngine engine)
protected final void sendAttach(SessionBase destination, IEngine engine, boolean incSeqnum)
protected final void sendActivateRead(Pipe destination)
protected final void sendActivateWrite(Pipe destination, long msgsRead)
protected final void sendPipeTerm(Pipe destination)
protected final void sendPipeTermAck(Pipe destination)
protected final void sendTerm(Own destination, int linger)
protected final void sendTermAck(Own destination)
protected final void sendReap(SocketBase socket)
protected final void sendReapAck()
protected final void sendReaped()
protected final void sendInprocConnected(SocketBase socket)
protected final void sendDone()
protected final void sendCancel()
protected void processStop()
protected void processPlug()
protected void processOwn(Own object)
protected void processAttach(IEngine engine)
protected void processBind(Pipe pipe)
protected void processActivateRead()
protected void processActivateWrite(long msgsRead)
protected void processPipeTerm()
protected void processPipeTermAck()
protected void processTermReq(Own object)
protected void processTerm(int linger)
protected void processTermAck()
protected void processReap(SocketBase socket)
protected void processReapAck()
protected void processReaped()
protected void processSeqnum()
protected void processCancel()
private void sendCommand(Command cmd)