org.symcomp.spsd
Class SPSD

java.lang.Object
  org.symcomp.scscp.CASClient
      org.symcomp.scscp.SCSCPClient
          org.symcomp.spsd.SPSD

All Implemented Interfaces:

java.lang.Runnable, org.symcomp.scscp.SCSCPConstants

public class SPSD
extends org.symcomp.scscp.SCSCPClient

the 'Simple Parallel SCSCP Dispatcher' is responsible to parallely dispatch work to some registered systems. It is derived from SCSCPClient to allow for uniform access.

Field Summary

Fields inherited from class org.symcomp.scscp.SCSCPClient

activeEncoding, defaultEncoding, inn, loglevel, out, scscpPort, scscpUri, scscpVersion, serviceId, serviceName, serviceVersion, socket, state, supportedEncodings

Fields inherited from class org.symcomp.scscp.CASClient

computations, currentComputation, id, resultThread, waitingComputations

Fields inherited from interface org.symcomp.scscp.SCSCPConstants

CLIENT_COMPUTING, CLIENT_DEAD, CLIENT_IDLE, CLIENT_QUIT, CLIENT_UNINITIALIZED, PI_SCSCP_ACK, PI_SCSCP_CANCEL, PI_SCSCP_ENCODINGS_SUPPORTED, PI_SCSCP_ENCODINGS_SUPPORTED_PATT, PI_SCSCP_END, PI_SCSCP_HELLO, PI_SCSCP_HELOPATT, PI_SCSCP_INFO, PI_SCSCP_INFOPATT, PI_SCSCP_KILL, PI_SCSCP_LEFT, PI_SCSCP_QUIT, PI_SCSCP_RIGHT, PI_SCSCP_START, PI_SCSCP_TERM, PI_SCSCP_TERMPATT, PI_SCSCP_VERPATT, PI_SCSCP_VERSION, STATE_COMPUTING, STATE_FINISHED, STATE_INMESSAGE, STATE_MSG_COMPLETED, STATE_NEGOTIATING, STATE_UNITIALIZED, STATE_WAITING

Constructor Summary

SPSD(java.lang.String uri, java.lang.Integer port)

Method Summary

void	addWorker(org.symcomp.scscp.SCSCPClient worker)
void	addWorkers(java.util.Collection<org.symcomp.scscp.SCSCPClient> workers)
void	clearWorkers()
int	getWorkerCount()
java.util.List<org.symcomp.scscp.SCSCPClient>	getWorkers()
boolean	removeWorker(org.symcomp.scscp.SCSCPClient c)
void	run()

Methods inherited from class org.symcomp.scscp.SCSCPClient

compute, computeBlocking, getActiveEncoding, getComputationState, getResult, getSCSCPPort, getSCSCPUri, getSCSCPVersion, getServiceId, getServiceName, getServiceVersion, getState, getSupportedEncodings, log, quit, resultAvailable, setActiveEncoding, setLoglevel, setSupportedEncodings, startComputation

Methods inherited from class org.symcomp.scscp.CASClient

getComputation, getComputations, getNumberOfComputations, isIdle

Methods inherited from class java.lang.Object

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

Constructor Detail

SPSD

public SPSD(java.lang.String uri,
            java.lang.Integer port)

Method Detail

addWorker

public void addWorker(org.symcomp.scscp.SCSCPClient worker)

addWorkers

public void addWorkers(java.util.Collection<org.symcomp.scscp.SCSCPClient> workers)

getWorkers

public java.util.List<org.symcomp.scscp.SCSCPClient> getWorkers()

clearWorkers

public void clearWorkers()

removeWorker

public boolean removeWorker(org.symcomp.scscp.SCSCPClient c)

getWorkerCount

public int getWorkerCount()

run

public void run()

Specified by:

run in interface java.lang.Runnable

Overrides:

run in class org.symcomp.scscp.SCSCPClient