edu.illinois.ncsa.isda.softwareserver.polyglot.weighted

Class PolyglotStewardThreaded

java.lang.Object

edu.illinois.ncsa.isda.softwareserver.polyglot.Polyglot

edu.illinois.ncsa.isda.softwareserver.polyglot.weighted.PolyglotStewardThreaded

All Implemented Interfaces:

Runnable

public class PolyglotStewardThreaded
extends Polyglot
implements Runnable

A class that coordinates the use of several software reuse clients via I/O-graphs to perform file format conversions. This version is threaded so as balance the load on a number of Software Servers.

Author:

Rob Kooper

Constructor Summary

Constructors

Constructor and Description
PolyglotStewardThreaded() Class constructor.
PolyglotStewardThreaded(PolyglotStewardThreaded polyglot) Class copy constructor.

Method Summary

Methods

Modifier and Type	Method and Description
boolean	add(SoftwareServerClient icr) Add a software reuse client.
boolean	add(String server, int port) Add a software reuse client.
void	close() Close all software reuse client connections.
void	conversions()
SoftwareServerAuxiliary.FileData	convert(SoftwareServerAuxiliary.FileData input_file_data, String output_type) Convert a files format.
SoftwareServerAuxiliary.FileData	convert(SoftwareServerAuxiliary.FileData input_file_data, Vector<PolyglotAuxiliary.Conversion<SoftwareServerAuxiliary.Data,SoftwareServerAuxiliary.Application>> conversions) Convert a files format.
String	convert(String input_filename, String output_path, String output_type) Convert a files format.
void	convert(String input_filename, String output_path, Vector<PolyglotAuxiliary.Conversion<SoftwareServerAuxiliary.Data,SoftwareServerAuxiliary.Application>> conversions) Convert a files format.
SoftwareServerClient	get(int index) Retrieve the specified software reuse client.
IOGraph<String,String>	getDistributedInputOutputGraph() Get a string only version of this IOGraph encoded with host machines.
IOGraph<String,String>	getInputOutputGraph() Get the available inputs, outputs, and conversions.
TreeSet<String>	getInputs() Get the inputs available.
TreeSet<String>	getInputs(String output) Get the inputs available for the given output type.
IOGraph<SoftwareServerAuxiliary.Data,SoftwareServerAuxiliary.Application>	getIOGraph() Get the I/O-graph.
TreeSet<String>	getOutputs() Get the outputs available.
TreeSet<String>	getOutputs(String input) Get the outputs available for the given input type.
TreeSet<String>	getOutputs(TreeSet<String> inputs) Get the common outputs available for the given input types.
Vector<String>	getServers() Get a list of connected software reuse servers.
TreeSet<String>	getSoftware() Get the software available.
void	listen(int port) Start listening for SoftwareServers.
static void	main(String[] args) Command line polyglot interface.
void	run() Clean up lost connections.
void	setApplicationFlexibility(int value) Set the flexibility when choosing an application where 0=none (default), 1=allow parallel applications with the same name (different software reuse servers), 2=allow all parallel applications.
int	size() Get the number of software reuse clients being used.

Methods inherited from class edu.illinois.ncsa.isda.softwareserver.polyglot.Polyglot

convertLater, waitOnPending

Methods inherited from class java.lang.Object

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

Constructor Detail

PolyglotStewardThreaded

public PolyglotStewardThreaded()

Class constructor.

PolyglotStewardThreaded

public PolyglotStewardThreaded(PolyglotStewardThreaded polyglot)

Class copy constructor.

Parameters:

polyglot - the polyglot steward to copy

Method Detail

size

public int size()

Get the number of software reuse clients being used.

Returns:

the number of software reuse clients

add

public boolean add(SoftwareServerClient icr)

Add a software reuse client.

Parameters:

icr - a software reuse client

Returns:

true if successfully added

add

public boolean add(String server,
          int port)

Add a software reuse client.

Parameters:

server - the server name

port - the port number

Returns:

true if successfully added

get

public SoftwareServerClient get(int index)

Retrieve the specified software reuse client.

Parameters:

index - the index of the desired client

Returns:

the software reuse client

getIOGraph

public IOGraph<SoftwareServerAuxiliary.Data,SoftwareServerAuxiliary.Application> getIOGraph()

Get the I/O-graph.

Returns:

the I/O-graph

getSoftware

public TreeSet<String> getSoftware()

Get the software available.

Specified by:

getSoftware in class Polyglot

Returns:

the list of software

getOutputs

public TreeSet<String> getOutputs()

Get the outputs available.

Specified by:

getOutputs in class Polyglot

Returns:

the list of outputs

getOutputs

public TreeSet<String> getOutputs(String input)

Get the outputs available for the given input type.

Specified by:

getOutputs in class Polyglot

Parameters:

input - the input type

Returns:

the list of outputs

getOutputs

public TreeSet<String> getOutputs(TreeSet<String> inputs)

Get the common outputs available for the given input types.

Specified by:

getOutputs in class Polyglot

Parameters:

inputs - the input types

Returns:

the list of outputs

getInputs

public TreeSet<String> getInputs()

Get the inputs available.

Specified by:

getInputs in class Polyglot

Returns:

the list of inputs

getInputs

public TreeSet<String> getInputs(String output)

Get the inputs available for the given output type.

Specified by:

getInputs in class Polyglot

Parameters:

output - the output type

Returns:

the list of inputs

getInputOutputGraph

public IOGraph<String,String> getInputOutputGraph()

Get the available inputs, outputs, and conversions.

Specified by:

getInputOutputGraph in class Polyglot

Returns:

an IOGraph containing the information as strings

getServers

public Vector<String> getServers()

Get a list of connected software reuse servers.

Specified by:

getServers in class Polyglot

Returns:

a list of connected software reuse servers

getDistributedInputOutputGraph

public IOGraph<String,String> getDistributedInputOutputGraph()

Get a string only version of this IOGraph encoded with host machines.

Specified by:

getDistributedInputOutputGraph in class Polyglot

Returns:

a string version of this IOGraph

setApplicationFlexibility

public void setApplicationFlexibility(int value)

Set the flexibility when choosing an application where 0=none (default), 1=allow parallel applications with the same name (different software reuse servers), 2=allow all parallel applications. The higher the value the more parallelism can be taken advantage of.

Parameters:

value - the flexibility value

convert

public SoftwareServerAuxiliary.FileData convert(SoftwareServerAuxiliary.FileData input_file_data,
                                       Vector<PolyglotAuxiliary.Conversion<SoftwareServerAuxiliary.Data,SoftwareServerAuxiliary.Application>> conversions)

Convert a files format.

Parameters:

input_file_data - the input file data

conversions - the conversions to perform

Returns:

the output file data

convert

public SoftwareServerAuxiliary.FileData convert(SoftwareServerAuxiliary.FileData input_file_data,
                                       String output_type)

Convert a files format.

Parameters:

input_file_data - the input file data

output_type - the name of the output type

Returns:

the output file data

convert

public void convert(String input_filename,
           String output_path,
           Vector<PolyglotAuxiliary.Conversion<SoftwareServerAuxiliary.Data,SoftwareServerAuxiliary.Application>> conversions)

Convert a files format.

Parameters:

input_filename - the absolute name of the input file

output_path - the output path

conversions - the conversions to perform

convert

public String convert(String input_filename,
             String output_path,
             String output_type)

Convert a files format.

Specified by:

convert in class Polyglot

Parameters:

input_filename - the absolute name of the input file

output_path - the output path

output_type - the name of the output type

Returns:

the output file name (if changed, null otherwise)

close

public void close()

Close all software reuse client connections.

Specified by:

close in class Polyglot

conversions

public void conversions()

listen

public void listen(int port)

Start listening for SoftwareServers.

Parameters:

port - the port to listen to

run

public void run()

Clean up lost connections.

Specified by:

run in interface Runnable

main

public static void main(String[] args)

Command line polyglot interface.

Parameters:

args - command line arguments