Package org.apache.tvm.rpc

Class ConnectTrackerServerProcessor

java.lang.Object

org.apache.tvm.rpc.ConnectTrackerServerProcessor

All Implemented Interfaces:

Runnable, ServerProcessor

public class ConnectTrackerServerProcessor
extends Object
implements ServerProcessor

Server processor with tracker connection (based on standalone). This RPC Server registers itself with an RPC Tracker for a specific queue (using its device key) and listens for incoming requests.

Field Summary

Fields

Modifier and Type	Field	Description
static final int	HARD_TIMEOUT_DEFAULT
static final int	MAX_SERVER_PORT
static final int	RETRY_PERIOD
static final int	STALE_TRACKER_TIMEOUT
static final int	TRACKER_TIMEOUT

Constructor Summary

Constructors

Constructor	Description
ConnectTrackerServerProcessor(String trackerHost, int trackerPort, String key, RPCWatchdog watchdog)	Construct tracker server processor.

Method Summary

Modifier and Type	Method	Description
String	getMatchKey()
void	run()
void	terminate()

Methods inherited from class java.lang.Object

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

Field Details

MAX_SERVER_PORT

public static final int MAX_SERVER_PORT

See Also:

• Constant Field Values

TRACKER_TIMEOUT

public static final int TRACKER_TIMEOUT

See Also:

• Constant Field Values

RETRY_PERIOD

public static final int RETRY_PERIOD

See Also:

• Constant Field Values

STALE_TRACKER_TIMEOUT

public static final int STALE_TRACKER_TIMEOUT

See Also:

• Constant Field Values

HARD_TIMEOUT_DEFAULT

public static final int HARD_TIMEOUT_DEFAULT

See Also:

• Constant Field Values

Constructor Details

ConnectTrackerServerProcessor

public ConnectTrackerServerProcessor(String trackerHost,
 int trackerPort,
 String key,
 RPCWatchdog watchdog)
                              throws IOException

Construct tracker server processor.

Parameters:

trackerHost - Tracker host.

trackerPort - Tracker port.

key - Device key.

watchdog - watch for timeout, etc.

Throws:

IOException - when socket fails to open.

Method Details

getMatchKey

public String getMatchKey()

terminate

public void terminate()

Specified by:

terminate in interface ServerProcessor

run

public void run()

Specified by:

run in interface Runnable