edu.iu.dsc.tws.common.net.tcp.request

Class RRServer

java.lang.Object

edu.iu.dsc.tws.common.net.tcp.request.RRServer

public class RRServer
extends java.lang.Object

RRServer class is used by Job Master It works in request/response messaging Workers and the client always send a request message, and JobMaster sends a single response message to each request message However, sometimes job master may send messages to workers that are not response messages For example, the driver in Job Master may send messages to workers The messages that are initiated from Job Master are one-way messages They don't have response messages Message Format: RequestID (32 bytes), message type length, message type data, senderID (4 bytes), message data message type is the class name of the protocol buffer for that message RequestID is generated in request senders (workers or the client), and the same requestID is used in the response message. When job master sends a message that is not a response to a request, it uses the DUMMY_REQUEST_ID as the requestID.

Field Summary

Fields

Modifier and Type	Field and Description
static int	CLIENT_ID The client id
protected java.nio.channels.SocketChannel	clientChannel the client channel,
protected java.util.List<java.nio.channels.SocketChannel>	connectedChannels We keep track of connected channels here to make sure we close them
protected ConnectHandler	connectHandler Connection handler
protected Progress	loop The loop that executes the selector
protected java.util.Map<java.lang.String,Message.Builder>	messageBuilders Message type name to builder
protected int	pendingSendCount We keep track of pending send count to determine weather all the sends are completed
protected java.util.Map<RequestID,java.nio.channels.SocketChannel>	requestChannels Keep track of the requests
protected java.util.Map<java.lang.String,MessageHandler>	requestHandlers Keep track of the request handler using protocol buffer message types
protected Server	server
protected int	serverID Job Master ID
protected <any>	workerChannels worker channels with workerIDs

Constructor Summary

Constructors

Constructor and Description
RRServer(Config cfg, java.lang.String host, int port, Progress looper, int serverID, ConnectHandler cHandler, int backLog)

Method Summary

Modifier and Type	Method and Description
java.util.Set<java.lang.Integer>	getConnectedWorkers()
void	registerRequestHandler(Message.Builder builder, MessageHandler handler)
void	removeWorkerChannel(int workerID) remove the channel when the worker is removed
boolean	sendMessage(Message message, int targetID) Send a non-response message to a worker or to the client
protected TCPMessage	sendMessage(Message message, RequestID requestID, java.nio.channels.SocketChannel channel)
boolean	sendResponse(RequestID requestID, Message message) Send a response to a request id
void	start()
void	stop()
void	stopGraceFully(long waitTime)

Methods inherited from class java.lang.Object

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

Field Detail

server

protected Server server

connectedChannels

protected java.util.List<java.nio.channels.SocketChannel> connectedChannels

We keep track of connected channels here to make sure we close them

workerChannels

protected <any> workerChannels

worker channels with workerIDs

clientChannel

protected java.nio.channels.SocketChannel clientChannel

the client channel,

requestHandlers

protected java.util.Map<java.lang.String,MessageHandler> requestHandlers

Keep track of the request handler using protocol buffer message types

messageBuilders

protected java.util.Map<java.lang.String,Message.Builder> messageBuilders

Message type name to builder

requestChannels

protected java.util.Map<RequestID,java.nio.channels.SocketChannel> requestChannels

Keep track of the requests

serverID

protected int serverID

Job Master ID

CLIENT_ID

public static final int CLIENT_ID

The client id

See Also:

Constant Field Values

connectHandler

protected ConnectHandler connectHandler

Connection handler

loop

protected Progress loop

The loop that executes the selector

pendingSendCount

protected int pendingSendCount

We keep track of pending send count to determine weather all the sends are completed

Constructor Detail

RRServer

public RRServer(Config cfg,
                java.lang.String host,
                int port,
                Progress looper,
                int serverID,
                ConnectHandler cHandler,
                int backLog)

Method Detail

registerRequestHandler

public void registerRequestHandler(Message.Builder builder,
                                   MessageHandler handler)

start

public void start()

stop

public void stop()

stopGraceFully

public void stopGraceFully(long waitTime)

getConnectedWorkers

public java.util.Set<java.lang.Integer> getConnectedWorkers()

sendResponse

public boolean sendResponse(RequestID requestID,
                            Message message)

Send a response to a request id

Parameters:

requestID - request id

message - message

Returns:

true if response was accepted

sendMessage

public boolean sendMessage(Message message,
                           int targetID)

Send a non-response message to a worker or to the client

Parameters:

message - message

Returns:

true if response was accepted

sendMessage

protected TCPMessage sendMessage(Message message,
                                 RequestID requestID,
                                 java.nio.channels.SocketChannel channel)

removeWorkerChannel

public void removeWorkerChannel(int workerID)

remove the channel when the worker is removed

Parameters:

workerID -