public abstract class SocketBase extends ZObject implements IPollEvents
Modifier and Type | Field and Description |
---|---|
protected ValueReference<Integer> |
errno |
protected Options |
options |
Modifier | Constructor and Description |
---|---|
protected |
SocketBase(Ctx parent,
int tid,
int sid) |
Modifier and Type | Method and Description |
---|---|
void |
acceptEvent() |
boolean |
bind(String addr) |
boolean |
checkTag() |
void |
close() |
boolean |
connect(String addr) |
void |
connectEvent() |
static SocketBase |
create(int type,
Ctx parent,
int tid,
int sid) |
void |
destroy() |
int |
errno() |
void |
eventAccepted(String addr,
SelectableChannel ch) |
void |
eventAcceptFailed(String addr,
int errno) |
void |
eventBindFailed(String addr,
int errno) |
void |
eventClosed(String addr,
SelectableChannel ch) |
void |
eventCloseFailed(String addr,
int errno) |
void |
eventConnectDelayed(String addr,
int errno) |
void |
eventConnected(String addr,
SelectableChannel ch) |
void |
eventConnectRetried(String addr,
int interval) |
void |
eventDisconnected(String addr,
SelectableChannel ch) |
void |
eventListening(String addr,
SelectableChannel ch) |
SelectableChannel |
getFD() |
Mailbox |
getMailbox() |
int |
getSocketOpt(int option) |
Object |
getsockoptx(int option) |
void |
hiccuped(zmq.Pipe pipe) |
void |
inEvent() |
protected boolean |
isTerminating() |
protected void |
launchChild(zmq.Own object) |
boolean |
monitor(String addr,
int events) |
protected void |
monitorEvent(ZMQ.Event event) |
void |
outEvent() |
void |
pipeTerminated(zmq.Pipe pipe) |
protected void |
processBind(zmq.Pipe pipe) |
protected void |
processDestroy() |
protected void |
processOwn(zmq.Own object) |
protected void |
processSeqnum() |
protected void |
processStop() |
protected void |
processTerm(int linger) |
protected void |
processTermAck() |
protected void |
processTermReq(zmq.Own object) |
void |
readActivated(zmq.Pipe pipe) |
Msg |
recv(int flags) |
void |
registerTermAcks(int count) |
boolean |
send(Msg msg,
int flags) |
void |
setSocketOpt(int option,
Object optval) |
void |
startReaping(Poller poller) |
void |
stop() |
protected void |
stopMonitor() |
protected void |
termChild(zmq.Own object) |
boolean |
termEndpoint(String addr) |
protected void |
terminate() |
void |
timerEvent(int id) |
String |
toString() |
String |
typeString() |
void |
unregisterTermAck() |
void |
writeActivated(zmq.Pipe pipe) |
protected abstract void |
xattachPipe(zmq.Pipe pipe,
boolean icanhasall) |
protected boolean |
xhasIn() |
protected boolean |
xhasOut() |
protected void |
xhiccuped(zmq.Pipe pipe) |
protected abstract void |
xpipeTerminated(zmq.Pipe pipe) |
protected void |
xreadActivated(zmq.Pipe pipe) |
protected Msg |
xrecv() |
protected boolean |
xsend(Msg msg) |
protected boolean |
xsetsockopt(int option,
Object optval) |
protected void |
xwriteActivated(zmq.Pipe pipe) |
chooseIoThread, destroySocket, findEndpoint, getCtx, getTid, processActivateRead, processActivateWrite, processAttach, processCommand, processHiccup, processPipeTerm, processPipeTermAck, processPlug, processReap, processReaped, registerEndpoint, sendActivateRead, sendActivateWrite, sendAttach, sendAttach, sendBind, sendBind, sendDone, sendHiccup, sendOwn, sendPipeTerm, sendPipeTermAck, sendPlug, sendPlug, sendReap, sendReaped, sendStop, sendTerm, sendTermAck, sendTermReq, unregisterEndpoints
protected ValueReference<Integer> errno
protected final Options options
protected SocketBase(Ctx parent, int tid, int sid)
protected abstract void xattachPipe(zmq.Pipe pipe, boolean icanhasall)
protected abstract void xpipeTerminated(zmq.Pipe pipe)
public boolean checkTag()
public static SocketBase create(int type, Ctx parent, int tid, int sid)
public void destroy()
public Mailbox getMailbox()
public void stop()
public void setSocketOpt(int option, Object optval)
public int getSocketOpt(int option)
public Object getsockoptx(int option)
public boolean bind(String addr)
public boolean connect(String addr)
public boolean termEndpoint(String addr)
public boolean send(Msg msg, int flags)
public Msg recv(int flags)
public void close()
public void startReaping(Poller poller)
protected void processStop()
processStop
in class ZObject
protected void processBind(zmq.Pipe pipe)
processBind
in class ZObject
protected void processTerm(int linger)
protected void processDestroy()
protected boolean xsetsockopt(int option, Object optval)
protected boolean xhasOut()
protected boolean xsend(Msg msg)
protected boolean xhasIn()
protected Msg xrecv()
protected void xreadActivated(zmq.Pipe pipe)
protected void xwriteActivated(zmq.Pipe pipe)
protected void xhiccuped(zmq.Pipe pipe)
public void inEvent()
inEvent
in interface IPollEvents
public void outEvent()
outEvent
in interface IPollEvents
public void connectEvent()
connectEvent
in interface IPollEvents
public void acceptEvent()
acceptEvent
in interface IPollEvents
public void timerEvent(int id)
timerEvent
in interface IPollEvents
public void readActivated(zmq.Pipe pipe)
public void writeActivated(zmq.Pipe pipe)
public void hiccuped(zmq.Pipe pipe)
public void pipeTerminated(zmq.Pipe pipe)
public boolean monitor(String addr, int events)
public void eventConnected(String addr, SelectableChannel ch)
public void eventConnectDelayed(String addr, int errno)
public void eventConnectRetried(String addr, int interval)
public void eventListening(String addr, SelectableChannel ch)
public void eventBindFailed(String addr, int errno)
public void eventAccepted(String addr, SelectableChannel ch)
public void eventAcceptFailed(String addr, int errno)
public void eventClosed(String addr, SelectableChannel ch)
public void eventCloseFailed(String addr, int errno)
public void eventDisconnected(String addr, SelectableChannel ch)
protected void monitorEvent(ZMQ.Event event)
protected void stopMonitor()
public SelectableChannel getFD()
public String typeString()
public int errno()
protected void processSeqnum()
processSeqnum
in class ZObject
protected void launchChild(zmq.Own object)
protected void termChild(zmq.Own object)
protected void processTermReq(zmq.Own object)
processTermReq
in class ZObject
protected void processOwn(zmq.Own object)
processOwn
in class ZObject
protected void terminate()
protected boolean isTerminating()
public void registerTermAcks(int count)
public void unregisterTermAck()
protected void processTermAck()
processTermAck
in class ZObject
Copyright © 2023. All rights reserved.