aa.transport
Class TransportSender

java.lang.Object
  java.lang.Thread
      aa.tool.SystemThread
          aa.transport.TransportSender

All Implemented Interfaces:

java.lang.Runnable

public class TransportSender

extends SystemThread

This class specifies Transport Sender to handle out-going messages.

History:

• February 19, 2004 - version 0.0.4
  • do minor modification.
• September 12, 2003 - version 0.0.3
  • modify code for continuous communication
• May 9, 2003 - version 0.0.2
  • modify internal comments.
• April 23, 2001 - version 0.0.1
  • create this file.

Version:

$Date: 2008/01/01 00:23:40 $ $Revision: 1.1 $

Author:

Myeong-Wuk Jang

Field Summary

private java.util.ArrayList	m_alSocket An array list for socket opened to send messages to actors in other platforms.
private ActorName	m_anPlatform The actor name of this actor platform.
private int	m_iPort The port number of the server socket of this actor platform.
private MessageManager	m_mmMessageManager The reference to a Message Manager.
private java.util.TreeMap	m_tmOOS A tree map for object output streams.

Fields inherited from class aa.tool.SystemThread

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

TransportSender(ActorName p_anPlatform, MessageManager p_mmMessageManager, java.lang.Integer p_intPort)
Creates a Transport Sender thread.

Method Summary

void	changePortNumber(java.lang.Integer p_intPort) Changes the port number for transprot manager.
private void	closeAll() Closes object output streams and sockets.
protected void	init() Processes some necessay routines before entering the while loop in the run method .
protected void	processMessage(ActorMessage p_amMsg) Processes a message.
void	uninit() Uninitializes this program.

Methods inherited from class aa.tool.SystemThread

deliverMessage, run

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, toString, yield

Methods inherited from class java.lang.Object

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

Field Detail

m_anPlatform

private ActorName m_anPlatform

The actor name of this actor platform.

m_iPort

private int m_iPort

The port number of the server socket of this actor platform.

m_mmMessageManager

private MessageManager m_mmMessageManager

The reference to a Message Manager.

m_alSocket

private java.util.ArrayList m_alSocket

An array list for socket opened to send messages to actors in other platforms.

m_tmOOS

private java.util.TreeMap m_tmOOS

A tree map for object output streams.
Each element in the map consists of the host address of a platform and its output stream.

Constructor Detail

TransportSender

public TransportSender(ActorName p_anPlatform,
                       MessageManager p_mmMessageManager,
                       java.lang.Integer p_intPort)

Creates a Transport Sender thread.

Parameters:

p_mmMessageManager - the reference to a Message Manager.

p_intPort - the port number of a server socket for out-going messages.

Method Detail

init

protected void init()

Processes some necessay routines before entering the while loop in the run method .
This is called by the run method of the super class.

Specified by:

init in class SystemThread

uninit

public void uninit()

Uninitializes this program.
This method is called by a Message Manager.

processMessage

protected void processMessage(ActorMessage p_amMsg)

Processes a message.
This is called by the run method of the super class.

Specified by:

processMessage in class SystemThread

Parameters:

p_amMsg - a communication message.

closeAll

private void closeAll()

Closes object output streams and sockets.

changePortNumber

public void changePortNumber(java.lang.Integer p_intPort)

Changes the port number for transprot manager.

Parameters:

p_intPort - a new port number for transport manager.