org.trafodion.dcs.servermt.serverHandler

Class ServerHandler

java.lang.Object

org.trafodion.dcs.servermt.serverHandler.ServerHandler

All Implemented Interfaces:

Callable

public final class ServerHandler
extends Object
implements Callable

Field Summary

Fields

Modifier and Type	Field and Description
byte[]	cert
String	extHostAddress
int	fport
String	hostName
int	instance
String	parentZnode
String	serverName
int	serverState
int	serverThread

Constructor Summary

Constructors

Constructor and Description
ServerHandler(org.apache.hadoop.conf.Configuration conf, ZkClient zkc, DcsNetworkConfiguration netConf, int instance, int infoPort, String masterHostName, RetryCounterFactory retryCounterFactory, int assignedPort, byte[] cert, int serverThread)

Method Summary

Methods

Modifier and Type	Method and Description
Integer	call()
int	getConnectingTimeout()
void	send(org.trafodion.dcs.servermt.serverHandler.PendingRequest preq)
void	setConnectingTimeout()

Methods inherited from class java.lang.Object

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

Field Detail

parentZnode

public String parentZnode

fport

public int fport

hostName

public String hostName

instance

public int instance

serverThread

public int serverThread

serverName

public String serverName

extHostAddress

public String extHostAddress

serverState

public int serverState

cert

public byte[] cert

Constructor Detail

ServerHandler

public ServerHandler(org.apache.hadoop.conf.Configuration conf,
             ZkClient zkc,
             DcsNetworkConfiguration netConf,
             int instance,
             int infoPort,
             String masterHostName,
             RetryCounterFactory retryCounterFactory,
             int assignedPort,
             byte[] cert,
             int serverThread)
              throws Exception

Throws:

Exception

Method Detail

send

public void send(org.trafodion.dcs.servermt.serverHandler.PendingRequest preq)

setConnectingTimeout

public void setConnectingTimeout()

getConnectingTimeout

public int getConnectingTimeout()

call

public Integer call()
             throws Exception

Specified by:

call in interface Callable

Throws:

Exception