org.smartfrog.examples.dynamicwebserver.stresstest
Class StressTesterImpl

java.lang.Object
  org.smartfrog.sfcore.reference.RemoteReferenceResolverHelperImpl
      org.smartfrog.sfcore.prim.PrimImpl
          org.smartfrog.examples.dynamicwebserver.stresstest.StressTesterImpl

All Implemented Interfaces:

java.lang.Runnable, java.rmi.Remote, DataSource, StressTester, MessageKeys, Diagnostics, Liveness, Prim, RemoteReferenceResolver, RemoteReferenceResolverHelper

public class StressTesterImpl
extends PrimImpl
implements Prim, java.lang.Runnable, StressTester, DataSource

Description of the Class

Field Summary

Fields inherited from class org.smartfrog.sfcore.prim.PrimImpl

refLivenessDelay, refLivenessFactor, sfCompleteName, sfContext, sfDeployHooks, sfDeployWithHooks, sfExportRef, sfIsDeployed, sfIsStarted, sfIsTerminated, sfIsTerminating, sfLivenessCount, sfLivenessDelay, sfLivenessFactor, sfLivenessSender, sfParent, sfStartHooks, sfTerminateWithHooks, termLock

Fields inherited from interface org.smartfrog.examples.dynamicwebserver.stresstest.StressTester

CONTROLGUI, FACTOR, FREQUENCY, HOST, HOSTS, LOGTO, NUMHITS, PAGE, PORT

Fields inherited from interface org.smartfrog.sfcore.common.MessageKeys

CANNOT_LINK_TO_PREDICATE, COMPONENT_TERMINATED, COPY_FAILED, COPY_SERIALIZE_FAILED, ERROR_NO_SECURITY_BUT_REQUIRED, ILLEGAL_BOOLEAN_PARAMETER, ILLEGAL_NUMERIC_PARAMETER, ILLEGAL_STRING_PARAMETER, ILLEGAL_VECTOR_PARAMETER, LIVENESS_SEND_FAILURE, LIVENESS_SEND_FAILURE_IN, MISSING_PARAMETER, MSG_CLASS_NOT_FOUND, MSG_CONNECT_ERR, MSG_CONT_OTHER_DEPLOY, MSG_DEPLOY_COMP_TERMINATED, MSG_DEPLOY_SUCCESS, MSG_DEPLOYWITH_PHASE_FAILED, MSG_DETACH_SUCCESS, MSG_DETACH_TERMINATE_SUCCESS, MSG_ERR_DEPLOY_FROM_URL, MSG_ERR_PARSE, MSG_ERR_RESOLVE_PHASE, MSG_ERR_SF_RUNNING, MSG_ERR_TERM, MSG_FAILED_INET_ADDRESS_LOOKUP, MSG_FAILED_TO_CONTACT_PARENT, MSG_FILE_NOT_FOUND, MSG_HOOK_ACTION_FAILED, MSG_ILLEGAL_ACCESS, MSG_ILLEGAL_CLASS_TYPE, MSG_ILLEGAL_CLASS_TYPE_EXPECTING_GOT, MSG_ILLEGAL_REFERENCE, MSG_INPUTSTREAM_NULL, MSG_INSTANTIATION_ERROR, MSG_INVALID_OBJECT_TYPE, MSG_INVOCATION_TARGET, MSG_LANG_NOT_FOUND, MSG_LIVENESS_START_FAILED, MSG_LOADING_URL, MSG_METHOD_NOT_FOUND, MSG_NON_REP_ATTRIB, MSG_NOT_COMPONENT_REFERENCE, MSG_NOT_FOUND_ATTRIBUTE, MSG_NOT_FOUND_REFERENCE, MSG_NOT_VALUE_REFERENCE, MSG_NULL_DEF_METHOD, MSG_NULL_URL, MSG_OBJECT_REGISTRATION_FAILED, MSG_PARENT_LOCATION_FAILED, MSG_PING_SUCCESS, MSG_RANDM_ERR, MSG_REMOTE_CONNECT_ERR, MSG_REPEATED_ATTRIBUTE, MSG_SF_DEAD, MSG_SF_READY, MSG_SF_TERMINATED, MSG_STACKTRACE_FOLLOWS, MSG_START_COMP_TERMINATED, MSG_TERMINATE_SUCCESS, MSG_UNHANDLED_EXCEPTION, MSG_UNKNOWN_HOST, MSG_UNRESOLVED_REFERENCE, MSG_UNRESOLVED_REFERENCE_IN, MSG_UPDATE_SUCCESS, MSG_URL_NOT_FOUND, MSG_URL_TO_PARSE_NOT_FOUND, MSG_WARNING_LIVENESS_ENABLED, MSG_WARNING_STACKTRACE_DISABLED, MSG_WARNING_STACKTRACE_ENABLED, ROOT_MUST_BE_COMPONENT, WARN_NO_SECURITY

Constructor Summary

StressTesterImpl()
Constructor for the StressTesterImpl object

Method Summary

java.net.Socket	connect(java.lang.String host, int port) Establishes the connection, then passes the socket to handleConnection.
int	getData() Gets the data attribute of the StressTesterImpl object
java.lang.String	getHost() The hostname of the server we're contacting.
protected java.util.Vector	getHosts() get the hosts that should be tested
int	getPort() The port connection will be made on.
static java.io.BufferedReader	getReader(java.net.Socket s) Make a BufferedReader to get incoming data.
static java.io.PrintWriter	getWriter(java.net.Socket s) Make a PrintWriter to send outgoing data.
void	run() Main processing method for the StressTesterImpl object
void	setFrequency(int newFrequency) Sets the frequency attribute of the StressTesterImpl object
void	setHits(int s) Sets the hits attribute of the StressTesterImpl object
void	setPage(java.lang.String newPage) Sets the page attribute of the StressTesterImpl object
void	sfDeploy() Standard sfDeploy()
void	sfStart() Standard sfStart()
void	sfTerminateWith(TerminationRecord tr) Standard sfTerminateWith()
void	stop() Description of the Method
java.lang.String	toString() Description of the Method

Methods inherited from class org.smartfrog.sfcore.prim.PrimImpl

equals, hashCode, registerWithProcessCompound, sfAddAttribute, sfAttributeKeyFor, sfAttributes, sfCompleteName, sfCompleteNameSafe, sfContainsAttribute, sfContainsValue, sfContext, sfDeployedHost, sfDeployedProcessName, sfDeployWith, sfDetach, sfDetachAndTerminate, sfDiagnosticsReport, sfDumpState, sfExport, sfExportRef, sfExportRef, sfGetApplicationLog, sfGetCoreLog, sfGetLog, sfIsDeployed, sfIsRemote, sfIsStarted, sfIsTerminated, sfIsTerminating, sfLivenessFailure, sfLog, sfParent, sfParentageChanged, sfPing, sfRemoveAttribute, sfReplaceAttribute, sfResolve, sfResolve, sfResolveHere, sfResolveHere, sfResolveParent, sfSetLog, sfStartLivenessSender, sfStopLivenessSender, sfTerminate, sfTerminatedWith, sfTerminateQuietlyWith, sfValues, terminateComponent, terminateNotifying

Methods inherited from class org.smartfrog.sfcore.reference.RemoteReferenceResolverHelperImpl

sfResolve, sfResolve, sfResolve, sfResolve, sfResolve, sfResolve, sfResolve, sfResolve, sfResolve, sfResolve, sfResolve, sfResolve, sfResolve, sfResolve, sfResolve, sfResolve, sfResolve, sfResolve, sfResolve, sfResolve, sfResolve, sfResolve, sfResolve, sfResolve, sfResolve, sfResolve, sfResolve, sfResolve, sfResolve, sfResolve, sfResolve, sfResolve, sfResolve, sfResolve, sfResolve, sfResolve, sfResolve, sfResolve, sfResolve, sfResolve, sfResolve, sfResolve, sfResolve, sfResolveWithParser

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.smartfrog.sfcore.prim.Prim

sfAddAttribute, sfAttributeKeyFor, sfAttributes, sfCompleteName, sfContainsAttribute, sfContainsValue, sfContext, sfDeployedHost, sfDeployedProcessName, sfDeployWith, sfDetach, sfDetachAndTerminate, sfDumpState, sfIsDeployed, sfIsStarted, sfIsTerminated, sfIsTerminating, sfParent, sfParentageChanged, sfRemoveAttribute, sfReplaceAttribute, sfTerminate, sfTerminatedWith, sfTerminateQuietlyWith, sfValues

Methods inherited from interface org.smartfrog.sfcore.prim.Liveness

sfPing

Methods inherited from interface org.smartfrog.sfcore.reference.RemoteReferenceResolver

sfResolve, sfResolve, sfResolveHere, sfResolveHere, sfResolveParent

Methods inherited from interface org.smartfrog.sfcore.reference.RemoteReferenceResolverHelper

sfResolve, sfResolve, sfResolve, sfResolve, sfResolve, sfResolve, sfResolve, sfResolve, sfResolve, sfResolve, sfResolve, sfResolve, sfResolve, sfResolve, sfResolve, sfResolve, sfResolve, sfResolve, sfResolve, sfResolve, sfResolve, sfResolve, sfResolve, sfResolve, sfResolve, sfResolve, sfResolve, sfResolve, sfResolve, sfResolve, sfResolve, sfResolve, sfResolve, sfResolve, sfResolve, sfResolve, sfResolve, sfResolve, sfResolve, sfResolve, sfResolve, sfResolve, sfResolve, sfResolveWithParser

Methods inherited from interface org.smartfrog.sfcore.prim.Diagnostics

sfDiagnosticsReport

Constructor Detail

StressTesterImpl

public StressTesterImpl()
                 throws java.rmi.RemoteException

Constructor for the StressTesterImpl object

Throws:

java.rmi.RemoteException - Description of the Exception

Method Detail

toString

public java.lang.String toString()

Description of the Method

Overrides:

toString in class PrimImpl

Returns:

Description of the Return Value

stop

public void stop()

Description of the Method

Specified by:

stop in interface StressTester

setHits

public void setHits(int s)

Sets the hits attribute of the StressTesterImpl object

Parameters:

s - The new hits value

sfDeploy

public void sfDeploy()
              throws SmartFrogException,
                     java.rmi.RemoteException

Standard sfDeploy()

Specified by:

sfDeploy in interface Prim

Overrides:

sfDeploy in class PrimImpl

Throws:

SmartFrogException - Description of the Exception

java.rmi.RemoteException - DOCUMENT ME!

sfStart

public void sfStart()
             throws SmartFrogException,
                    java.rmi.RemoteException

Standard sfStart()

Specified by:

sfStart in interface Prim

Overrides:

sfStart in class PrimImpl

Throws:

SmartFrogException - Description of the Exception

java.rmi.RemoteException - DOCUMENT ME!

sfTerminateWith

public void sfTerminateWith(TerminationRecord tr)

Standard sfTerminateWith()

Overrides:

sfTerminateWith in class PrimImpl

Parameters:

tr - Description of the Parameter

getHosts

protected java.util.Vector getHosts()

get the hosts that should be tested

Returns:

DOCUMENT ME!

run

public void run()

Main processing method for the StressTesterImpl object

Specified by:

run in interface java.lang.Runnable

connect

public java.net.Socket connect(java.lang.String host,
                               int port)

Establishes the connection, then passes the socket to handleConnection.

Parameters:

host - Description of the Parameter

port - Description of the Parameter

Returns:

Description of the Return Value

getHost

public java.lang.String getHost()

The hostname of the server we're contacting.

Returns:

The host value

getPort

public int getPort()

The port connection will be made on.

Returns:

The port value

getReader

public static java.io.BufferedReader getReader(java.net.Socket s)
                                        throws java.io.IOException

Make a BufferedReader to get incoming data.

Parameters:

s - Description of the Parameter

Returns:

The reader value

Throws:

java.io.IOException - Description of the Exception

getWriter

public static java.io.PrintWriter getWriter(java.net.Socket s)
                                     throws java.io.IOException

Make a PrintWriter to send outgoing data. This PrintWriter will automatically flush stream when println is called.

Parameters:

s - Description of the Parameter

Returns:

The writer value

Throws:

java.io.IOException - Description of the Exception

setPage

public void setPage(java.lang.String newPage)
             throws java.rmi.RemoteException

Sets the page attribute of the StressTesterImpl object

Specified by:

setPage in interface StressTester

Parameters:

newPage - The new page value

Throws:

java.rmi.RemoteException - Description of the Exception

setFrequency

public void setFrequency(int newFrequency)
                  throws java.rmi.RemoteException

Sets the frequency attribute of the StressTesterImpl object

Specified by:

setFrequency in interface StressTester

Parameters:

newFrequency - The new frequency value

Throws:

java.rmi.RemoteException - Description of the Exception

getData

public int getData()

Gets the data attribute of the StressTesterImpl object

Specified by:

getData in interface DataSource

Returns:

The data value