ds.granules.bridge

Class JavaGenericComputation

java.lang.Object

ds.granules.bridge.JavaGenericComputation

Direct Known Subclasses:

JavaPoolComputation

public class JavaGenericComputation
extends java.lang.Object

Constructor Summary

Constructors

Constructor and Description
JavaGenericComputation(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
JavaGenericComputation	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

JavaGenericComputation

public JavaGenericComputation(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

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 JavaGenericComputation 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.

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

Parameters:

jm - Message to send

closeConnection

public void closeConnection()
                     throws java.io.IOException

Function to close all open connections

Throws:

java.io.IOException