aleph.comm
Class Client

java.lang.Object
  |
  +--java.lang.Thread
        |
        +--aleph.comm.Client

public class Client

extends java.lang.Thread

A new Client is created at the start of each computation. It creates the PE group, relays outputs from PEs, and goes away when all output streams are closed.

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

Client(java.awt.event.ActionListener listener, int numPEs, java.util.Set selectedHosts, java.lang.String[] args, java.io.OutputStream[] output, boolean logging)
Constructor

Client(int numPEs, java.util.Set selectedHosts, java.lang.String[] args, java.io.OutputStream[] output, boolean logging)
Constructor

Method Summary

void	eof() Input stream from PE shutting down.
void	exit() Shutdown immediately
static Client	getClient() Used by messages to locate client.
void	run() This method does the real work.
void	stderr(PE pe, java.lang.String string) Display a string from a particular PE.
void	stdout(PE pe, java.lang.String string) Display a string from a particular PE.

Methods inherited from class java.lang.Thread

activeCount, checkAccess, countStackFrames, currentThread, destroy, dumpStack, enumerate, getContextClassLoader, getName, getPriority, getThreadGroup, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, resume, setContextClassLoader, setDaemon, setName, setPriority, sleep, sleep, start, stop, stop, suspend, toString, yield

Methods inherited from class java.lang.Object

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

Constructor Detail

Client

public Client(int numPEs,
              java.util.Set selectedHosts,
              java.lang.String[] args,
              java.io.OutputStream[] output,
              boolean logging)

Constructor

Parameters:

numPEs - how many PEs to create

selectedHosts - where to create them

args - User's wish is our command

logging - should we log everything?

Client

public Client(java.awt.event.ActionListener listener,
              int numPEs,
              java.util.Set selectedHosts,
              java.lang.String[] args,
              java.io.OutputStream[] output,
              boolean logging)

Constructor

Parameters:

listener - if non-null, notify when done

numPEs - how many PEs to create

selectedHosts - where to create them

args - User's wish is our command

logging - should we log everything?

Method Detail

getClient

public static Client getClient()

Used by messages to locate client.

run

public void run()

This method does the real work.

Overrides:

run in class java.lang.Thread

stdout

public void stdout(PE pe,
                   java.lang.String string)

Display a string from a particular PE.

Parameters:

pe - source

string - content

stderr

public void stderr(PE pe,
                   java.lang.String string)

Display a string from a particular PE.

Parameters:

pe - source

string - content

exit

public void exit()

Shutdown immediately

eof

public void eof()

Input stream from PE shutting down.