dist1.acb.common.transport
Class AbstractPersonalManager

java.lang.Object
  java.lang.Thread
      dist1.acb.common.transport.AbstractPersonalManager

All Implemented Interfaces:

java.lang.Runnable

Direct Known Subclasses:

AdminSocket.AdminManager, ClientSocket.ClientManager, ControlSocket.ClientManager, Primary.ClientManager, ProviderSocket.ClientManager

public abstract class AbstractPersonalManager

extends java.lang.Thread

Abstract class for threaded model of socket server. An instance of the class services one socket client.

Version:

$Revision: 1.20 $

Author:

Alexander Stasiv

Field Summary

protected java.io.ObjectInputStream	in
protected java.util.logging.Logger	log Logger for object instance
protected java.io.ObjectOutputStream	out
protected java.net.Socket	socket Socket

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

AbstractPersonalManager(java.net.Socket socket, java.lang.String name, java.lang.ThreadGroup group)
Constructor for the AbstractPersonalManager object

Method Summary

protected Response	handlerOfUnknownClass()
protected Response	handlerOfUnknownRequest(Request request)
protected abstract HandlersHive	installDafaultHandlers()
protected void	process() Main processing method for the PersonalManager object
protected Request	receiveRequest()
protected Request	receiveRequest(int timeout)
void	run() Main processing method for the PersonalManager object
protected void	sendResponse(Response response)
protected void	setHandlers(HandlersHive newHandlers) Setting new handlers (changing the phase)
java.lang.String	toString() Returns string with an information about the object

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, start, stop, stop, suspend, yield

Methods inherited from class java.lang.Object

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

Field Detail

log

protected java.util.logging.Logger log

Logger for object instance

in

protected java.io.ObjectInputStream in

out

protected java.io.ObjectOutputStream out

socket

protected java.net.Socket socket

Socket

Constructor Detail

AbstractPersonalManager

public AbstractPersonalManager(java.net.Socket socket,
                               java.lang.String name,
                               java.lang.ThreadGroup group)

Constructor for the AbstractPersonalManager object

Parameters:

socket - Connected socket

name - A name of the object

group - Thread group to which current thread will be related

Method Detail

run

public void run()

Main processing method for the PersonalManager object

toString

public java.lang.String toString()

Returns string with an information about the object

Returns:

An information about the object

setHandlers

protected void setHandlers(HandlersHive newHandlers)

Setting new handlers (changing the phase)

Parameters:

newHandlers - New set of handlers

handlerOfUnknownClass

protected Response handlerOfUnknownClass()

handlerOfUnknownRequest

protected Response handlerOfUnknownRequest(Request request)

installDafaultHandlers

protected abstract HandlersHive installDafaultHandlers()

process

protected void process()

Main processing method for the PersonalManager object

Throws:

java.lang.InterruptedException - internal exception

receiveRequest

protected Request receiveRequest()
                          throws java.lang.InterruptedException,
                                 java.io.IOException

Throws:

java.lang.InterruptedException

java.io.IOException

receiveRequest

protected Request receiveRequest(int timeout)
                          throws java.lang.InterruptedException,
                                 java.io.IOException

Throws:

java.lang.InterruptedException

java.io.IOException

sendResponse

protected void sendResponse(Response response)
                     throws java.io.IOException

Throws:

java.io.IOException