zmq

Class SocketBase

java.lang.Object

zmq.ZObject

zmq.Own

zmq.SocketBase

All Implemented Interfaces:

IPollEvents, Pipe.IPipeEvents

Direct Known Subclasses:

Dealer, Pair, Pull, Push, Router, XPub, XSub

public abstract class SocketBase
extends Own
implements IPollEvents, Pipe.IPipeEvents

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
private static class	SocketBase.SimpleURI

Field Summary

Fields

Modifier and Type	Field and Description
private boolean	ctxTerminated
private boolean	destroyed
private java.util.Map<java.lang.String,Own>	endpoints
protected ValueReference<java.lang.Integer>	errno
private java.nio.channels.SelectableChannel	handle
private java.util.Map<java.lang.String,Pipe>	inprocs
private long	lastTsc
private Mailbox	mailbox
private int	monitorEvents
private SocketBase	monitorSocket
private java.util.List<Pipe>	pipes
private Poller	poller
private boolean	rcvmore
private int	tag
private int	ticks

Fields inherited from class zmq.Own

options

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	SocketBase(Ctx parent, int tid, int sid)

Method Summary

Modifier and Type	Method and Description
void	acceptEvent()
private void	addEndpoint(java.lang.String addr, Own endpoint)
private void	attachPipe(Pipe pipe)
private void	attachPipe(Pipe pipe, boolean icanhasall)
boolean	bind(java.lang.String addr)
private void	checkDestroy()
private void	checkProtocol(java.lang.String protocol)
boolean	checkTag()
void	close()
boolean	connect(java.lang.String addr)
void	connectEvent()
static SocketBase	create(int type, Ctx parent, int tid, int sid)
void	destroy()
int	errno()
void	eventAccepted(java.lang.String addr, java.nio.channels.SelectableChannel ch)
void	eventAcceptFailed(java.lang.String addr, int errno)
void	eventBindFailed(java.lang.String addr, int errno)
void	eventClosed(java.lang.String addr, java.nio.channels.SelectableChannel ch)
void	eventCloseFailed(java.lang.String addr, int errno)
void	eventConnectDelayed(java.lang.String addr, int errno)
void	eventConnected(java.lang.String addr, java.nio.channels.SelectableChannel ch)
void	eventConnectRetried(java.lang.String addr, int interval)
void	eventDisconnected(java.lang.String addr, java.nio.channels.SelectableChannel ch)
void	eventListening(java.lang.String addr, java.nio.channels.SelectableChannel ch)
private void	extractFlags(Msg msg)
java.nio.channels.SelectableChannel	getFD()
Mailbox	getMailbox()
int	getSocketOpt(int option)
java.lang.Object	getsockoptx(int option)
(package private) boolean	hasIn()
(package private) boolean	hasOut()
void	hiccuped(Pipe pipe)
void	inEvent()
boolean	monitor(java.lang.String addr, int events)
protected void	monitorEvent(ZMQ.Event event)
void	outEvent()
void	pipeTerminated(Pipe pipe)
protected void	processBind(Pipe pipe)
private boolean	processCommands(int timeout, boolean throttle)
protected void	processDestroy()
protected void	processStop()
protected void	processTerm(int linger)
void	readActivated(Pipe pipe)
Msg	recv(int flags)
boolean	send(Msg msg, int flags)
void	setSocketOpt(int option, java.lang.Object optval)
void	startReaping(Poller poller)
void	stop()
protected void	stopMonitor()
boolean	termEndpoint(java.lang.String addr)
void	timerEvent(int id)
java.lang.String	toString()
java.lang.String	typeString()
void	writeActivated(Pipe pipe)
protected abstract void	xattachPipe(Pipe pipe, boolean icanhasall)
protected boolean	xhasIn()
protected boolean	xhasOut()
protected void	xhiccuped(Pipe pipe)
protected abstract void	xpipeTerminated(Pipe pipe)
protected void	xreadActivated(Pipe pipe)
protected Msg	xrecv()
protected boolean	xsend(Msg msg)
protected boolean	xsetsockopt(int option, java.lang.Object optval)
protected void	xwriteActivated(Pipe pipe)

Methods inherited from class zmq.Own

incSeqnum, isTerminating, launchChild, processOwn, processSeqnum, processTermAck, processTermReq, registerTermAcks, termChild, terminate, unregisterTermAck

Methods inherited from class zmq.ZObject

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

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Detail

endpoints

private final java.util.Map<java.lang.String,Own> endpoints

inprocs

private final java.util.Map<java.lang.String,Pipe> inprocs

tag

private int tag

ctxTerminated

private boolean ctxTerminated

destroyed

private boolean destroyed

mailbox

private final Mailbox mailbox

pipes

private final java.util.List<Pipe> pipes

poller

private Poller poller

handle

private java.nio.channels.SelectableChannel handle

lastTsc

private long lastTsc

ticks

private int ticks

rcvmore

private boolean rcvmore

monitorSocket

private SocketBase monitorSocket

monitorEvents

private int monitorEvents

errno

protected ValueReference<java.lang.Integer> errno

Constructor Detail

SocketBase

protected SocketBase(Ctx parent,
                     int tid,
                     int sid)

Method Detail

xattachPipe

protected abstract void xattachPipe(Pipe pipe,
                                    boolean icanhasall)

xpipeTerminated

protected abstract void xpipeTerminated(Pipe pipe)

checkTag

public boolean checkTag()

create

public static SocketBase create(int type,
                                Ctx parent,
                                int tid,
                                int sid)

destroy

public void destroy()

Specified by:

destroy in class Own

getMailbox

public Mailbox getMailbox()

stop

public void stop()

checkProtocol

private void checkProtocol(java.lang.String protocol)

attachPipe

private void attachPipe(Pipe pipe)

attachPipe

private void attachPipe(Pipe pipe,
                        boolean icanhasall)

setSocketOpt

public void setSocketOpt(int option,
                         java.lang.Object optval)

getSocketOpt

public int getSocketOpt(int option)

getsockoptx

public java.lang.Object getsockoptx(int option)

bind

public boolean bind(java.lang.String addr)

connect

public boolean connect(java.lang.String addr)

addEndpoint

private void addEndpoint(java.lang.String addr,
                         Own endpoint)

termEndpoint

public boolean termEndpoint(java.lang.String addr)

send

public boolean send(Msg msg,
                    int flags)

recv

public Msg recv(int flags)

close

public void close()

hasIn

boolean hasIn()

hasOut

boolean hasOut()

startReaping

public void startReaping(Poller poller)

processCommands

private boolean processCommands(int timeout,
                                boolean throttle)

processStop

protected void processStop()

Overrides:

processStop in class ZObject

processBind

protected void processBind(Pipe pipe)

Overrides:

processBind in class ZObject

processTerm

protected void processTerm(int linger)

Overrides:

processTerm in class Own

processDestroy

protected void processDestroy()

Overrides:

processDestroy in class Own

xsetsockopt

protected boolean xsetsockopt(int option,
                              java.lang.Object optval)

xhasOut

protected boolean xhasOut()

xsend

protected boolean xsend(Msg msg)

xhasIn

protected boolean xhasIn()

xrecv

protected Msg xrecv()

xreadActivated

protected void xreadActivated(Pipe pipe)

xwriteActivated

protected void xwriteActivated(Pipe pipe)

xhiccuped

protected void xhiccuped(Pipe pipe)

inEvent

public void inEvent()

Specified by:

inEvent in interface IPollEvents

outEvent

public void outEvent()

Specified by:

outEvent in interface IPollEvents

connectEvent

public void connectEvent()

Specified by:

connectEvent in interface IPollEvents

acceptEvent

public void acceptEvent()

Specified by:

acceptEvent in interface IPollEvents

timerEvent

public void timerEvent(int id)

Specified by:

timerEvent in interface IPollEvents

checkDestroy

private void checkDestroy()

readActivated

public void readActivated(Pipe pipe)

Specified by:

readActivated in interface Pipe.IPipeEvents

writeActivated

public void writeActivated(Pipe pipe)

Specified by:

writeActivated in interface Pipe.IPipeEvents

hiccuped

public void hiccuped(Pipe pipe)

Specified by:

hiccuped in interface Pipe.IPipeEvents

pipeTerminated

public void pipeTerminated(Pipe pipe)

Specified by:

pipeTerminated in interface Pipe.IPipeEvents

extractFlags

private void extractFlags(Msg msg)

monitor

public boolean monitor(java.lang.String addr,
                       int events)

eventConnected

public void eventConnected(java.lang.String addr,
                           java.nio.channels.SelectableChannel ch)

eventConnectDelayed

public void eventConnectDelayed(java.lang.String addr,
                                int errno)

eventConnectRetried

public void eventConnectRetried(java.lang.String addr,
                                int interval)

eventListening

public void eventListening(java.lang.String addr,
                           java.nio.channels.SelectableChannel ch)

eventBindFailed

public void eventBindFailed(java.lang.String addr,
                            int errno)

eventAccepted

public void eventAccepted(java.lang.String addr,
                          java.nio.channels.SelectableChannel ch)

eventAcceptFailed

public void eventAcceptFailed(java.lang.String addr,
                              int errno)

eventClosed

public void eventClosed(java.lang.String addr,
                        java.nio.channels.SelectableChannel ch)

eventCloseFailed

public void eventCloseFailed(java.lang.String addr,
                             int errno)

eventDisconnected

public void eventDisconnected(java.lang.String addr,
                              java.nio.channels.SelectableChannel ch)

monitorEvent

protected void monitorEvent(ZMQ.Event event)

stopMonitor

protected void stopMonitor()

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object

getFD

public java.nio.channels.SelectableChannel getFD()

typeString

public java.lang.String typeString()

errno

public int errno()