Overview | Package | Class | Use | Tree | Deprecated | Index | Help
PREV NEXT | FRAMES NO FRAMES

A B C D E F G H I K L M N O P R S T U W

## A

AGENT - Static variable in class taskspaces.system.Communicator
  Protocol indicator for Space to accept an Agent.
Agent - class taskspaces.system.Agent.
  This class is the superclass to all TaskSpaces Agents.
Agent() - Constructor for class taskspaces.system.Agent
addURL(URL, Object) - Method in class taskspaces.system.Communicator
  Adds the URL sent to the list of URLs to look for when loading classes.
agentInfo - Variable in class taskspaces.system.Node
  Information for Agents.
app - Variable in class taskspaces.system.Receiver
  The application name of this job
appName - Variable in class taskspaces.system.TaskAgent
  The application name of this application.
append - Variable in class taskspaces.system.Receiver
  Overwrite `false` or append `true` output.
available - Variable in class taskspaces.system.TaskStore
  Indicates if a Task is available.

## B

busy - Variable in class taskspaces.system.Node
  Indicates if Worker is busy executing Task.

## C

Communicator - class taskspaces.system.Communicator.
  This class contains methods for all TaskSpaces components to communicate using object streams.
Communicator() - Constructor for class taskspaces.system.Communicator
checkClientTrusted(X509Certificate[], String) - Method in class taskspaces.system.SpaceConnection
  Required methods for the trust manager.
checkServerTrusted(X509Certificate[], String) - Method in class taskspaces.system.SpaceConnection
classLoaderPath - Variable in class taskspaces.system.Space
  The URLClassLoader of this class.
clear() - Method in class taskspaces.system.MessageStore
  Clears this store of messages and associated keys.
clearMessages() - Method in class taskspaces.system.Node
  Clears the messages from this Node's MessageStore.
client - Variable in class taskspaces.system.SpaceConnection
clientAddress - Variable in class taskspaces.system.SpaceConnection
communicator - Variable in class taskspaces.system.SpaceConnection
contents - Variable in class taskspaces.system.TaskStore
  Holds a Task.
counter - Static variable in class taskspaces.system.SpaceConnection

## D

DELETE_NODE - Static variable in class taskspaces.system.Communicator
  Indicator for Space to delete a registered Node.
date - Variable in class taskspaces.system.Receiver
  Print date if `true`.
defaultPort - Variable in class taskspaces.system.Node
  Default Worker port.
deleteNode(String, int) - Method in class taskspaces.system.Communicator
  Unregisters a Node from a Space.
done - Static variable in class taskspaces.system.ProcessManager
  The value if completed.

## E

execute(String) - Method in class taskspaces.system.ProcessManager
  Executes a native program.

## F

footer - Variable in class taskspaces.system.Receiver
  Include output file footer.

## G

GET_ALL_NODES - Static variable in class taskspaces.system.Communicator
  Indicator for Space to return an array of all registered Node addresses.
GET_IDLE_NODES - Static variable in class taskspaces.system.Communicator
  Indicator for Space to return an array of idle registered Node addresses.
get(Object) - Method in class taskspaces.system.MessageStore
  Returns object matching given key from this store.
get() - Method in class taskspaces.system.TaskStore
  Returns a Task if one is available, otherwise the caller is blocked.
getAcceptedIssuers() - Method in class taskspaces.system.SpaceConnection
getAgentInfo() - Method in class taskspaces.system.Node
  Returns an Object containing information for Agents.
getBusy() - Method in class taskspaces.system.Node
  Indicates if the Worker thread is executing a Task.
getCodeServer() - Method in class taskspaces.system.Communicator
  Returns the codeserver's URL as listed in the properties file.
getDefaultPort() - Method in class taskspaces.system.Node
  Returns the default port number of the local Server.
getHost() - Method in class taskspaces.system.Node
  Returns the local host name.
getIP() - Method in class taskspaces.system.Node
  Returns the IP address of the host system.
getId() - Method in class taskspaces.system.Result
  This method returns the class variable getId
getId() - Method in class taskspaces.system.Task
  Return the ID of this task.
getMaxTasks() - Method in class taskspaces.system.Node
  Returns the port number of the local Server.
getMessageStore() - Method in class taskspaces.system.Node
  Returns a MessageStore reference for Tasks.
getPort() - Method in class taskspaces.system.Node
  Returns the port number of the local Server.
getResource(String, String, boolean, boolean) - Method in class taskspaces.system.ProcessManager
  Downloads the given file name and installs in the given path location.
getResultObject() - Method in class taskspaces.system.Result
  This method returns the class variable getResultObject
getSocket(String) - Static method in class taskspaces.system.Communicator
  Creates new Socket from input address in the form of `IPAddress:PortNumber`
getSpaceAddress() - Method in class taskspaces.system.Node
  Returns the IP address of the registered Space.
getSpaces() - Method in class taskspaces.system.Communicator
  Returns the list of spaces from a system properties file.
getTaskStore() - Method in class taskspaces.system.Node
  Returns a reference to this Node's TaskStore.
getValue(String, int) - Method in class taskspaces.system.Communicator
  Returns an Object from Space.

## H

header - Variable in class taskspaces.system.Receiver
  Include output file header.
host - Variable in class taskspaces.system.Node
  The local host name.

## I

IN - Static variable in class taskspaces.system.Communicator
  Indicator for Space to accept object.
IN_MANY - Static variable in class taskspaces.system.Communicator
  Indicator for Space to accept multiple objects over the current connection.
id - Variable in class taskspaces.system.Node
  Incremental ID for Workers and Servers.
id - Variable in class taskspaces.system.Result
  The id of the task sending this result.
id - Variable in class taskspaces.system.Server
  ID for this Server.
id - Variable in class taskspaces.system.Task
  Identifier.
id - Variable in class taskspaces.system.Worker
  Node incremented ID to identify this Worker
in - Variable in class taskspaces.system.SpaceConnection
includeDate(boolean) - Method in class taskspaces.system.Receiver
  If `true`, includes a date timestamp at the top of the output file.
inst - Variable in class taskspaces.system.LogAgent
  The instance of the initializing class.
ip - Variable in class taskspaces.system.Node
  The local IP address.
ip - Variable in class taskspaces.system.SpaceConnection

## K

keys - Static variable in class taskspaces.system.Space
  Holds the keys to the messages.

## L

LogAgent - class taskspaces.system.LogAgent.
  This class is used by the Logging system to retrieve logs outputted by nodes and spaces.
LogAgent() - Constructor for class taskspaces.system.LogAgent
  Default constructor
load(String) - Method in class taskspaces.system.Communicator
  Returns a java.util.Properties object loaded from a URL.
logWrite - Variable in class taskspaces.system.Communicator
  The PrintWriter that outputs the log file.
logWriteName - Variable in class taskspaces.system.Communicator
  The file name of the log writer.

## M

MessageStore - class taskspaces.system.MessageStore.
  Stores messages arriving at Servers until Tasks undergoing execution by Workers can make message requests.
MessageStore() - Constructor for class taskspaces.system.MessageStore
m - Variable in class taskspaces.system.MessageStore
  Holds messages and keys.
main(String[]) - Static method in class Runner
  Main method of the Runner class This method takes in the arguments and the URLs from the properties files and uses them to execute a class from a remote location accessed through http.
maxTasks - Variable in class taskspaces.system.Node
  Maximum tasks to execute before exiting.
messageStore - Variable in class taskspaces.system.Node
  The child MessageStore.
messageStore - Variable in class taskspaces.system.Server
  Reference to local MessageStore.
messages - Static variable in class taskspaces.system.Space
  Holds messages which would be transferred to nodes.
myStream - Variable in class taskspaces.system.ProcessReader
  Reference to the passed standard output or error stream of an executing process.

## N

NODE_QUERY - Static variable in class taskspaces.system.Communicator
  Indicator for Space to return the number of registered Nodes.
Node - class taskspaces.system.Node.
  Represents a Node which consists of a Worker and Server thread.
Node() - Constructor for class taskspaces.system.Node
next() - Method in class taskspaces.system.Task
  Returns a clone of this Task.
nextData() - Method in class taskspaces.system.Task
  Advances the data for the next Task object, overriden by SPMD subclasses.
node - Variable in class taskspaces.system.Agent
  Reference to hosting Node.
node - Variable in class taskspaces.system.Server
  Reference to the host Node.
node - Variable in class taskspaces.system.Task
  Holds a reference to the host Node.
node - Variable in class taskspaces.system.Worker
  Reference to the hosting Node.
nodes - Static variable in class taskspaces.system.Space
  Holds the list of all the Idle nodes waiting for jobs.
nodesPermanent - Static variable in class taskspaces.system.Space
  Holds the list of all the nodes which are connected, not just idle.

## O

OUT - Static variable in class taskspaces.system.Communicator
  Indicator for Space to send object.
OUT_MANY - Static variable in class taskspaces.system.Communicator
  Indicator for Space to send multiple objects over the current connection.
out - Variable in class taskspaces.system.SpaceConnection
output - Static variable in class taskspaces.system.ProcessManager
  Holds output from process.

## P

ProcessManager - class taskspaces.system.ProcessManager.
  Enables execution and reading of output from an external executable.
ProcessManager() - Constructor for class taskspaces.system.ProcessManager
ProcessReader - class taskspaces.system.ProcessReader.
  Reads text written to standard output and standard error from native process in separate thread.
ProcessReader(InputStream) - Constructor for class taskspaces.system.ProcessReader
parseProperty(String) - Method in class taskspaces.system.Communicator
  Returns a String array from a CSV property.
path - Variable in class taskspaces.system.Receiver
  Desired full output file path.
port - Variable in class taskspaces.system.Node
  Port number of the child Server.
port - Variable in class taskspaces.system.SpaceConnection
print(String) - Method in class taskspaces.system.Communicator
  Convenience method for output.
print(PrintWriter) - Method in class taskspaces.system.Result
  This method is incomplete.
print(String) - Method in class taskspaces.system.SpaceConnection
printFooter(String) - Method in class taskspaces.system.Receiver
  Includes a footer String at the bottom of the output file.
printHeader(String) - Method in class taskspaces.system.Receiver
  Includes a header String at the top of the output file.
put(Object, Object) - Method in class taskspaces.system.MessageStore
  Stores key and object for retrieval by Tasks.
put(Object) - Method in class taskspaces.system.TaskStore
  Stores a Task if this store is empty, otherwise the caller is blocked.

## R

REGISTER_NODE - Static variable in class taskspaces.system.Communicator
  Indicator for Space to register a Node.
RESET - Static variable in class taskspaces.system.Communicator
  Indicator for Space to reset.
Receiver - class taskspaces.system.Receiver.
  Gathers result String objects from a Space and prints them to a new file with the given path, name and header, footer, and date timestamp if specified.
Receiver(String, int, String, String, String, String, boolean) - Constructor for class taskspaces.system.Receiver
  Constructor takes an IP address and port number of the result space, the number of expected result Objects, and an output file name to create and a header to write to the created file.
Result - class taskspaces.system.Result.
  This class stores results generated by tasks which are sent to the Result space and processed by the Reciever quasi-Node
Result(int, Object) - Constructor for class taskspaces.system.Result
  Constructor for the Result class
Runner - class Runner.
  Begins execution of applications or system components with the properties and resource URLs passsed on the command line.
Runner() - Constructor for class Runner
receive(String) - Method in class taskspaces.system.Communicator
  Requests an object from a Space.
receiveRemoteMessage(String, Object, int) - Method in class taskspaces.system.Communicator
  Requests a message with the given key from a given Space IP address and port.
receivedTasks - Variable in class taskspaces.system.Receiver
  Hold 1 for tasks received, 0 for tasks not accounted for.
register() - Method in class taskspaces.system.Node
  Registers this Node with a given Space.
registerNode(String, int) - Method in class taskspaces.system.Communicator
  Registers a Node with a Space.
reset(String) - Method in class taskspaces.system.Communicator
  Resets a Space or Node.
restart() - Method in class taskspaces.system.Node
  Restarts the Worker thread.
resultObject - Variable in class taskspaces.system.Result
  The object which will be sent back as a result.
run() - Method in class taskspaces.system.Agent
  This method is overridden by subclasses and executed by Spaces and Nodes.
run() - Method in class taskspaces.system.LogAgent
  This method is executed by the Node upon being recieved.
run() - Method in class taskspaces.system.Node
  Called by Runner to start a Node on a given host.
run() - Method in class taskspaces.system.ProcessReader
  Monitors output streams in independent thread.
run() - Method in class taskspaces.system.Receiver
  Starts a server on an open port.
run() - Method in class taskspaces.system.Server
  Starts a Server thread on an open port, and sets the port in the parent Node.
run() - Method in class taskspaces.system.Space
  Starts a new Space in a server thread running on an open port.
run() - Method in class taskspaces.system.SpaceConnection
  Handles the client request.
run() - Method in class taskspaces.system.Task
  Overriden by subclasses.
run() - Method in class taskspaces.system.TaskAgent
  Called when Agent is sent to a Space.
run() - Method in class taskspaces.system.Worker
  Looks for Tasks in the local TaskStore, and executes them by calling the run method if available.

## S

SEND_MESSAGE - Static variable in class taskspaces.system.Communicator
  Indicator for Space to send a message.
STORE_MESSAGE - Static variable in class taskspaces.system.Communicator
  Indicator for Space to store a message.
Server - class taskspaces.system.Server.
  Represents the point of interaction between Nodes and other components.
Server(TaskStore, MessageStore, int, Node) - Constructor for class taskspaces.system.Server
  Constructor for the Server class.
Space - class taskspaces.system.Space.
  Represents a server thread and a set of data structures and methods for sending, storing, and retrieving executable objects between applications and Nodes.
Space() - Constructor for class taskspaces.system.Space
SpaceConnection - class taskspaces.system.SpaceConnection.
  Represents a client connection to the Space, started in a separate Thread so the parent Space can continue to handle requests.
SpaceConnection() - Constructor for class taskspaces.system.SpaceConnection
SpaceConnection(ThreadGroup, Socket, Space) - Constructor for class taskspaces.system.SpaceConnection
  Constructor for the SpaceConnection class
s - Variable in class taskspaces.system.Server
  ServerSocket for this Server.
s - Variable in class taskspaces.system.Space
  The ServerSocket which will accept all the incomming connections.
send(String, Object) - Method in class taskspaces.system.Communicator
  Sends an object to a given IP address and port.
sendAgent(String, Object) - Method in class taskspaces.system.Communicator
  Sends an Agent to a given IP address and port.
sendAnObject(String, Object, int) - Method in class taskspaces.system.Communicator
  Sends an Object to a Space and an integer command.
sendCommand(String, int) - Method in class taskspaces.system.Communicator
  Sends a command to a Space.
sendDirectMessage(String, Object, Object) - Method in class taskspaces.system.Communicator
  Sends a key and message to a given Node IP address and port.
sendInt(String, int, int) - Method in class taskspaces.system.Communicator
  Sends a integer to a Space.
sendKeyValue(String, Object, Object, int) - Method in class taskspaces.system.Communicator
  Sends a key/value Object pair to a Space with an integer command.
sendLog(ObjectOutputStream, File) - Method in class taskspaces.system.LogAgent
  This method attempts to read the log and sends the raw bytes of the file over the stream.
sendLog(ObjectOutputStream, File, String, String) - Method in class taskspaces.system.LogAgent
  This method attempts to read the log and sends the raw bytes of the file over the stream.
sendOut(Object) - Method in class taskspaces.system.Space
  Sends an Object to a registered Node.
sendOut(Object) - Method in class taskspaces.system.SpaceConnection
  Sends an executable Task to a node.
sendRemoteMessage(String, Object, int) - Method in class taskspaces.system.Communicator
  Sends a key to a given Space IP address and port.
sendToNode(String, Object) - Method in class taskspaces.system.Communicator
  Sends an Object to a Node.
sendURL(String, URL) - Method in class taskspaces.system.Communicator
  Sends the URL to the Space to be loaded.
sendURL(String, URL[]) - Method in class taskspaces.system.Communicator
  Send the URLs to the Space to be loaded.
serverThread - Variable in class taskspaces.system.Node
  Thread to hold Server.
setAgentInfo(Object) - Method in class taskspaces.system.Node
  Stores the given Object in this Node's agentInfo data member for retrieval.
setBusy(boolean) - Method in class taskspaces.system.Node
  Indicates the child worker is busy.
setDefaultPort(int) - Method in class taskspaces.system.Node
  Sets the default port number of the local Server.
setHost() - Method in class taskspaces.system.Node
  Sets this Node's host member to the local host name.
setIP() - Method in class taskspaces.system.Node
  Sets this Node's ip member to the host system's IP address.
setMaxTasks(long) - Method in class taskspaces.system.Node
  Sets the number of tasks before this Node will exit.
setNode(Node) - Method in class taskspaces.system.Agent
  This method allows Nodes to send references to themselves to the Agent.
setNode(Node) - Method in class taskspaces.system.Task
  Passes a Node reference to this Task.
setPort(int) - Method in class taskspaces.system.Node
  Sets port to the port number of the local Server.
setProperties() - Method in class taskspaces.system.Node
  Sets the address of the associated Space for this Node.
setSpace(Space) - Method in class taskspaces.system.Agent
  This method allows Spaces to send self-references to to the Agent.
setSpace(String) - Method in class taskspaces.system.Node
  Sets the IP address of the registered Space.
setVars(Socket, Object) - Method in class taskspaces.system.LogAgent
  Method to set the variables necessary for communication.
socket - Variable in class taskspaces.system.LogAgent
  The socket of the LogHopper.
space - Variable in class taskspaces.system.Agent
  Reference to hosting Space.
space - Variable in class taskspaces.system.SpaceConnection
spaceAddress - Variable in class taskspaces.system.Node
  Address of the registered Space.
spaceAddress - Variable in class taskspaces.system.Receiver
  IP address and port number of the Space storing results.
startServer() - Method in class taskspaces.system.Node
  Starts a Server.
startWorker() - Method in class taskspaces.system.Node
  Starts a Worker.
statusPath - Variable in class taskspaces.system.Receiver
  Desired full status file path.

## T

Task - class taskspaces.system.Task.
  Superclass of all Tasks, holds memebers for Node references set on arrival at a Node and defines run method to be overriden by application Tasks.
Task() - Constructor for class taskspaces.system.Task
TaskAgent - class taskspaces.system.TaskAgent.
  This is a generic Task distribution Agent for applications.
TaskAgent(Task, int[], String, String) - Constructor for class taskspaces.system.TaskAgent
  Constructor accepts a subclass of Task.
TaskStore - class taskspaces.system.TaskStore.
  Provides a data structure and blocking methods for Tasks to be passed between Servers and Workers.
TaskStore() - Constructor for class taskspaces.system.TaskStore
t - Variable in class taskspaces.system.TaskAgent
  Holds a subclass of Task
taskList - Variable in class taskspaces.system.TaskAgent
  Array of tasks to send
taskStore - Variable in class taskspaces.system.Node
  The child TaskStore.
taskStore - Variable in class taskspaces.system.Server
  Reference to local TaskStore.
taskStore - Variable in class taskspaces.system.Worker
  Holds a reference to the local TaskStore.
tasks - Variable in class taskspaces.system.Receiver
  Number of results to be received.
tasks - Static variable in class taskspaces.system.Space
  Holds the tasks waiting to be sent out to nodes.
tasks - Variable in class taskspaces.system.Task
  Holds the number of tasks for this application.
taskspaces.system - package taskspaces.system
timeout - Variable in class taskspaces.system.Server
  Timeout count

## U

URLLOADER - Static variable in class taskspaces.system.Communicator
  Protocol indicator for Space to accept URL to load.
URLLOADERMANY - Static variable in class taskspaces.system.Communicator
  Protocol indicator for Space to accept URLs to load.
user - Variable in class taskspaces.system.Receiver
  The username of the person who started this job.
user - Variable in class taskspaces.system.TaskAgent
  Username of the one who started the application

## W

Worker - class taskspaces.system.Worker.
  Represents thread which executes Tasks as they become available in the referenced TaskStore.
Worker(TaskStore, int, Node) - Constructor for class taskspaces.system.Worker
  Accepts reference to TaskStore started by host Node, ID number, and reference to host Node.
workerQuery(String) - Method in class taskspaces.system.Communicator
  Returns an Object cotaining addresses of Nodes registered with a Space.
workerThread - Variable in class taskspaces.system.Node
  Thread to hold Worker.

A B C D E F G H I K L M N O P R S T U W

Overview | Package | Class | Use | Tree | Deprecated | Index | Help
| -bottom
PREV NEXT | FRAMES NO FRAMES