seda.sandStorm.lib.aDisk
Class AFileTPTM

java.lang.Object
  seda.sandStorm.internal.TPSThreadManager
      seda.sandStorm.lib.aDisk.AFileTPTM

All Implemented Interfaces:

ThreadManagerIF, ProfilableIF, sandStormConst

 class AFileTPTM
extends TPSThreadManager
implements ThreadManagerIF, ProfilableIF

This is the ThreadManager implementation for AFileTPImpl. It manages a pool of threads which perform blocking I/O on disk files; this is a portable implementation and is not meant to be high performance.

Nested Class Summary

(package private) class	AFileTPTM.AFileTPThread Internal class representing a single AFileTPTM-managed thread.
(package private) class	AFileTPTM.fileQueueEntry

Nested classes/interfaces inherited from class seda.sandStorm.internal.TPSThreadManager

TPSThreadManager.stageRunnable

Field Summary

private static boolean	DEBUG
private FiniteQueue	fileQ
private static int	MAX_REQUESTS_PER_FILE
private int	numOutstandingRequests
private static int	QUEUE_BLOCK_TIME

Fields inherited from class seda.sandStorm.internal.TPSThreadManager

config, mgr, sizeController, srTbl

Fields inherited from interface seda.sandStorm.internal.sandStormConst

MAJOR_VERSION, MINOR_VERSION, VERSION_STRING, WELCOME_STRING

Constructor Summary

AFileTPTM(ManagerIF mgr, SystemManagerIF sysmgr)

Method Summary

void	fileReady(AFileTPImpl impl) Indicate that a file has pending events.
int	profileSize() Return the size of the object being profiled.
void	register(StageWrapperIF stage) Register a stage with this thread manager.

Methods inherited from class seda.sandStorm.internal.TPSThreadManager

deregister, deregisterAll

Methods inherited from class java.lang.Object

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

Methods inherited from interface seda.sandStorm.api.internal.ThreadManagerIF

deregister, deregisterAll

Field Detail

DEBUG

private static final boolean DEBUG

See Also:

Constant Field Values

fileQ

private FiniteQueue fileQ

numOutstandingRequests

private int numOutstandingRequests

MAX_REQUESTS_PER_FILE

private static final int MAX_REQUESTS_PER_FILE

See Also:

Constant Field Values

QUEUE_BLOCK_TIME

private static final int QUEUE_BLOCK_TIME

See Also:

Constant Field Values

Constructor Detail

AFileTPTM

AFileTPTM(ManagerIF mgr,
          SystemManagerIF sysmgr)
    throws java.lang.Exception

Throws:

java.lang.Exception

Method Detail

register

public void register(StageWrapperIF stage)

Register a stage with this thread manager.

Specified by:

register in interface ThreadManagerIF

Overrides:

register in class TPSThreadManager

fileReady

public void fileReady(AFileTPImpl impl)

Indicate that a file has pending events.

profileSize

public int profileSize()

Description copied from interface: ProfilableIF

Return the size of the object being profiled.

Specified by:

profileSize in interface ProfilableIF