SmartFrog 3.10.000

org.smartfrog.examples.dynamicwebserver.stresstest
Class StressTesterImpl

java.lang.Object
  extended by org.smartfrog.sfcore.reference.RemoteReferenceResolverHelperImpl
      extended by org.smartfrog.sfcore.prim.PrimImpl
          extended by 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

SmartFrog CORE 3.10.000

(C) Copyright 1998-2006 Hewlett-Packard Development Company, LP