Package org.epics.pvaccess.client.impl.remote.search

Class SimpleChannelSearchManagerImpl

java.lang.Object

org.epics.pvaccess.client.impl.remote.search.SimpleChannelSearchManagerImpl

All Implemented Interfaces:

Runnable, ChannelSearchManager, org.epics.pvdata.misc.Timer.TimerCallback

public class SimpleChannelSearchManagerImpl
extends Object
implements ChannelSearchManager, org.epics.pvdata.misc.Timer.TimerCallback, Runnable

Version:

$Id$

Author:

Matej Sekoranja

Constructor Summary

Constructors

Constructor	Description
SimpleChannelSearchManagerImpl(ClientContextImpl context)

Method Summary

Modifier and Type	Method	Description
void	callback()
void	cancel()	Cancel.
void	newServerDetected()	New server detected.
void	register(SearchInstance channel)	Register channel.
void	register(SearchInstance channel, boolean penalize)	Register channel.
int	registeredCount()	Get number of registered channels.
void	run()
void	searchResponse(GUID guid, int cid, int seqNo, byte minorRevision, InetSocketAddress serverAddress)	Search response from server (channel found).
void	timerStopped()
void	unregister(SearchInstance channel)	Unregister channel.

Methods inherited from class java.lang.Object

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

Constructor Detail

SimpleChannelSearchManagerImpl

public SimpleChannelSearchManagerImpl(ClientContextImpl context)

Method Detail

run

public void run()

Specified by:

run in interface Runnable

cancel

public void cancel()

Cancel.

Specified by:

cancel in interface ChannelSearchManager

registeredCount

public int registeredCount()

Get number of registered channels.

Specified by:

registeredCount in interface ChannelSearchManager

Returns:

number of registered channels.

register

public void register(SearchInstance channel)

Description copied from interface: ChannelSearchManager

Register channel.

Specified by:

register in interface ChannelSearchManager

Parameters:

channel - channel to register.

register

public void register(SearchInstance channel,
                     boolean penalize)

Register channel.

Specified by:

register in interface ChannelSearchManager

Parameters:

channel - channel to register.

penalize - register with penalty (do not issue search immediately).

unregister

public void unregister(SearchInstance channel)

Unregister channel.

Specified by:

unregister in interface ChannelSearchManager

Parameters:

channel - channel to unregister.

searchResponse

public void searchResponse(GUID guid,
                           int cid,
                           int seqNo,
                           byte minorRevision,
                           InetSocketAddress serverAddress)

Search response from server (channel found).

Specified by:

searchResponse in interface ChannelSearchManager

Parameters:

guid - server GUID.

cid - client channel ID.

seqNo - search sequence number.

minorRevision - server minor PVA revision.

serverAddress - server address.

newServerDetected

public void newServerDetected()

New server detected. Boost searching of all channels.

Specified by:

newServerDetected in interface ChannelSearchManager

callback

public void callback()

Specified by:

callback in interface org.epics.pvdata.misc.Timer.TimerCallback

timerStopped

public void timerStopped()

Specified by:

timerStopped in interface org.epics.pvdata.misc.Timer.TimerCallback