org.omegahat.Interfaces.CORBA.TaskManagement
Class HomogeneousServerTaskManager

java.lang.Object
  |
  +--org.omegahat.Environment.TaskManagement.TaskManager
        |
        +--org.omegahat.Interfaces.CORBA.TaskManagement.DistributedTaskManager
              |
              +--org.omegahat.Interfaces.CORBA.TaskManagement.HomogeneousServerTaskManager

All Implemented Interfaces:

DistributedTaskConstants, java.lang.Runnable

public class HomogeneousServerTaskManager

extends DistributedTaskManager

Field Summary

protected java.lang.String

idlType

Fields inherited from class org.omegahat.Interfaces.CORBA.TaskManagement.DistributedTaskManager

activeTaskTable, IncompleteTaskResult, lockObject, orb, results, servers, totalNumberTasks

Fields inherited from class org.omegahat.Environment.TaskManagement.TaskManager

debug, listeners, tasks

Fields inherited from interface org.omegahat.Environment.TaskManagement.DistributedTaskConstants

SERVER_DISCARD, SERVER_POOL_CLEAR, SERVER_REJECT, TASK_COMPLETED, TASK_DISPATCH, TASK_ERROR

Constructor Summary

HomogeneousServerTaskManager()

HomogeneousServerTaskManager(ServerPool servers, TaskQueue queue)

HomogeneousServerTaskManager(ServerPool servers, TaskQueue tasks, java.lang.String idlType)

HomogeneousServerTaskManager(java.lang.String idlType)

Method Summary

TaskQueue	createQueue(int size) This creates the default queue, specialized for this class to be of class HomogeneousServerTaskQueue.
java.lang.String	idlType()
java.lang.String	idlType(java.lang.String type)
CORBATaskInterface	matchTaskAndServer(org.omg.CORBA.Object server) Schedule a task to be run on the specified server.

Methods inherited from class org.omegahat.Interfaces.CORBA.TaskManagement.DistributedTaskManager

activeTaskTable, activeTaskTable, addServer, closePendingTasks, closeTask, closeTask, dispatchInitialTasks, dispatchTask, dispatchTask, dispatchTask, getAvailableServer, getTask, getTotalNumberTasks, isComplete, orb, orb, queryCurrentTasks, registerTask, removeServer, results, results, run, servers, servers, servers, tasks

Methods inherited from class org.omegahat.Environment.TaskManagement.TaskManager

addListener, addTask, getTask, listeners, listeners, notify, notify, notify, removeListener, tasks, warn

Methods inherited from class java.lang.Object

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

Field Detail

idlType

protected java.lang.String idlType

Constructor Detail

HomogeneousServerTaskManager

public HomogeneousServerTaskManager()

HomogeneousServerTaskManager

public HomogeneousServerTaskManager(java.lang.String idlType)

HomogeneousServerTaskManager

public HomogeneousServerTaskManager(ServerPool servers,
                                    TaskQueue queue)

HomogeneousServerTaskManager

public HomogeneousServerTaskManager(ServerPool servers,
                                    TaskQueue tasks,
                                    java.lang.String idlType)

Method Detail

createQueue

public TaskQueue createQueue(int size)

This creates the default queue, specialized for this class to be of class HomogeneousServerTaskQueue.

Overrides:

createQueue in class DistributedTaskManager

See Also:

HomogeneousServerTaskQueue

matchTaskAndServer

public CORBATaskInterface matchTaskAndServer(org.omg.CORBA.Object server)

Description copied from class: DistributedTaskManager

Schedule a task to be run on the specified server.

Overrides:

matchTaskAndServer in class DistributedTaskManager

idlType

public java.lang.String idlType()

idlType

public java.lang.String idlType(java.lang.String type)