dist1.acb.CBLcc
Class AdminSocket

java.lang.Object
  java.lang.Thread
      dist1.acb.common.transport.AbstractClientSocket
          dist1.acb.CBLcc.AdminSocket

All Implemented Interfaces:

java.lang.Runnable

public class AdminSocket

extends AbstractClientSocket

Connection layer with the primary

Author:

Lazar Adzigogov

Nested Class Summary

Nested classes inherited from class dist1.acb.common.transport.AbstractClientSocket

AbstractClientSocket.SocketAndStreams

Field Summary

Fields inherited from class dist1.acb.common.transport.AbstractClientSocket

isShutdowned, log, objectStreamFactory, socket

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Method Summary

static AdminSocket	getInstance() Gets the instance of the ClientSocket server
protected void	handleConnectionEstablished()
protected boolean	handleConnectionLost()
protected void	handleUnrecoverableError(java.lang.Throwable e)
Response	request(Request request) Send the request and receive a response from the server in same thread.
Response	sendDirectly(java.net.InetSocketAddress addr, Request request)

Methods inherited from class dist1.acb.common.transport.AbstractClientSocket

connect, connect, connect, getResponse, getServerAddr, getServersAddresses, handleResponseToNoRequest, isConnected, receiveResponse, request, run, scheduleRequest, setServersAddresses, start

Methods inherited from class java.lang.Thread

activeCount, checkAccess, countStackFrames, currentThread, destroy, dumpStack, enumerate, getContextClassLoader, getName, getPriority, getThreadGroup, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, resume, setContextClassLoader, setDaemon, setName, setPriority, sleep, sleep, stop, stop, suspend, toString, yield

Methods inherited from class java.lang.Object

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

Method Detail

getInstance

public static AdminSocket getInstance()

Gets the instance of the ClientSocket server

Returns:

The instance value

request

public Response request(Request request)
                 throws java.lang.InterruptedException,
                        java.lang.ClassNotFoundException,
                        java.io.IOException

Send the request and receive a response from the server in same thread. So the method is blocking. The method tries to hide some errors like link brokes or crashes of the server.

Overrides:

request in class AbstractClientSocket

Parameters:

request - Request to send

Returns:

A response from a server

Throws:

java.lang.InterruptedException - The thread was interrupted.

java.lang.ClassNotFoundException - if received from the server class was not found

java.io.IOException - if handleConnectionLost() returns false

handleConnectionEstablished

protected void handleConnectionEstablished()

Specified by:

handleConnectionEstablished in class AbstractClientSocket

handleConnectionLost

protected boolean handleConnectionLost()

Specified by:

handleConnectionLost in class AbstractClientSocket

handleUnrecoverableError

protected void handleUnrecoverableError(java.lang.Throwable e)

Specified by:

handleUnrecoverableError in class AbstractClientSocket

sendDirectly

public Response sendDirectly(java.net.InetSocketAddress addr,
                             Request request)