Package com.cosylab.epics.caj.impl

Class CAJNameClient

java.lang.Object

com.cosylab.epics.caj.impl.CAJNameClient

All Implemented Interfaces:

Request, TransportClient, Timer.TimerRunnable

public class CAJNameClient
extends Object
implements TransportClient, Timer.TimerRunnable, Request

Field Summary

Fields

Modifier and Type	Field	Description
ByteBuffer	sendBuffer

Fields inherited from interface com.cosylab.epics.caj.impl.Request

DEFAULT_USER_PRIORITY, MAX_USER_PRIORITY, MIN_USER_PRIORITY, SEND_IMMEDIATELY_PRIORITY

Constructor Summary

Constructors

Constructor	Description
CAJNameClient(CAJContext ctxt, InetSocketAddress ep)

Method Summary

Modifier and Type	Method	Description
void	cancel()
void	connect()
byte	getPriority()	Get request priority, higher view higher priority.
ByteBuffer	getRequestMessage()	Get request message to be sent.
void	initBuffer()
void	submit()	Submit this request message to the corresponding transport.
void	timeout(long timeToRun)	Method invoked by timer at requested time.
void	transportChanged()	Notification of network change (server restarted).
void	transportClosed()	Notification of forcefully closed transport.
void	transportResponsive(Transport transport)	Notification of responsive transport (e.g.
void	transportUnresponsive()	Notification of unresponsive transport (e.g.

Methods inherited from class java.lang.Object

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

Field Detail

sendBuffer

public final ByteBuffer sendBuffer

Constructor Detail

CAJNameClient

public CAJNameClient(CAJContext ctxt,
                     InetSocketAddress ep)

Method Detail

initBuffer

public void initBuffer()

connect

public void connect()

cancel

public void cancel()

timeout

public void timeout(long timeToRun)

Description copied from interface: Timer.TimerRunnable

Method invoked by timer at requested time.

Specified by:

timeout in interface Timer.TimerRunnable

Parameters:

timeToRun - time in ms to run.

transportUnresponsive

public void transportUnresponsive()

Description copied from interface: TransportClient

Notification of unresponsive transport (e.g. no heartbeat detected) .

Specified by:

transportUnresponsive in interface TransportClient

transportResponsive

public void transportResponsive(Transport transport)

Description copied from interface: TransportClient

Notification of responsive transport (e.g. heartbeat detected again), called to discard transportUnresponsive notification.

Specified by:

transportResponsive in interface TransportClient

Parameters:

transport - responsive transport.

transportChanged

public void transportChanged()

Description copied from interface: TransportClient

Notification of network change (server restarted).

Specified by:

transportChanged in interface TransportClient

transportClosed

public void transportClosed()

Description copied from interface: TransportClient

Notification of forcefully closed transport.

Specified by:

transportClosed in interface TransportClient

getPriority

public byte getPriority()

Description copied from interface: Request

Get request priority, higher view higher priority.

Specified by:

getPriority in interface Request

Returns:

request priority.

getRequestMessage

public ByteBuffer getRequestMessage()

Description copied from interface: Request

Get request message to be sent.

Specified by:

getRequestMessage in interface Request

Returns:

request message to be sent.

submit

public void submit()
            throws IOException

Description copied from interface: Request

Submit this request message to the corresponding transport.

Specified by:

submit in interface Request

Throws:

IOException