ds.granules.bridge

Class JavaPoolComputation

java.lang.Object

ds.granules.bridge.JavaGenericComputation

ds.granules.bridge.JavaPoolComputation

public class JavaPoolComputation
extends JavaGenericComputation

Constructor Summary

Constructors

Constructor and Description
JavaPoolComputation(java.lang.String progName) Constructor, simply grabs the runtime, needs a program name

Method Summary

Modifier and Type	Method and Description
void	closeConnection() Function to close all open connections
void	sendMessage(JavaByteMessage jm) Function which allows the resource to send messages to an attached computation
void	startExecution(java.lang.String executeCommand, int commType, JavaMessageHandler jmh) Starts execution of a bridged program, needs actual execution command, type of communication, and a link to the appropriate message handler As a note, error stream is used even with TCP communications
JavaPoolComputation	switchCommunication(JavaByteMessage switchMessage, int newCommType) Allows the user to switch communication types from Java.

Methods inherited from class java.lang.Object

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

Constructor Detail

JavaPoolComputation

public JavaPoolComputation(java.lang.String progName)

Constructor, simply grabs the runtime, needs a program name

Parameters:

progName - Identifying name for the program - does not directly effect execution.

Method Detail

startExecution

public void startExecution(java.lang.String executeCommand,
                           int commType,
                           JavaMessageHandler jmh)
                    throws java.io.IOException

Starts execution of a bridged program, needs actual execution command, type of communication, and a link to the appropriate message handler As a note, error stream is used even with TCP communications

Overrides:

startExecution in class JavaGenericComputation

Parameters:

executeCommand - command to be executed to start the program

commType - as specified in ControlMessage - UPIPES and TCP currently supported, default is UPIPES

jmh - the message handler for this program

Throws:

java.io.IOException

switchCommunication

public JavaPoolComputation switchCommunication(JavaByteMessage switchMessage,
                                               int newCommType)
                                        throws java.io.IOException

Allows the user to switch communication types from Java. The connected computation needs to support communication switching for full functionality.

Overrides:

switchCommunication in class JavaGenericComputation

Parameters:

switchMessage - Actual message for switching communications - should be formatted in an appropriate manner for the connected computation

newCommType - From ControlMessage - UPIPES and TCP currently supported

Returns:

Renews connections.

Throws:

java.io.IOException

sendMessage

public void sendMessage(JavaByteMessage jm)

Function which allows the resource to send messages to an attached computation

Overrides:

sendMessage in class JavaGenericComputation

Parameters:

jm - Message to send

closeConnection

public void closeConnection()
                     throws java.io.IOException

Function to close all open connections

Overrides:

closeConnection in class JavaGenericComputation

Throws:

java.io.IOException