pegasus/test/StressTestController/StressTestController.cpp - diff

Return to StressTestController.cpp CVS log

Up to [Pegasus] / pegasus / test / StressTestController

Diff for /pegasus/test/StressTestController/StressTestController.cpp between version 1.3.24.2 and 1.4

version 1.3.24.2, 2007/09/28 15:31:43

version 1.4, 2007/02/13 18:55:28

Line 29

//==============================================================================

// Author: John Alex

// Modified By:

//%/////////////////////////////////////////////////////////////////////////////

#include <iostream>

Line 373

Line 369

// Set up tables for client properties.

_clientTable = new Table[Total_Clients];

_clientTable.reset(new Table[Total_Clients]);

// Allocate one table to collect all the common properties Thy use AutoPtr

_propertyTable = new Table;

// Client Information

_clientCommands = 0;

_clientDurations = 0;

_clientDelays = 0;

// Get environment variables:

Line 590

Line 574

}

_hostName = getOpts [i].Value ();

_hostNameSpecified = true;

if (!_propertyTable->insert("hostname", _hostName))

if (!_propertyTable.insert("hostname", _hostName))

{

// shouldn't get here

if(verboseEnabled)

Line 627

Line 611

throw e;

}

_portNumberSpecified = true;

if (!_propertyTable->insert("port", _portNumberStr))

if (!_propertyTable.insert("port", _portNumberStr))

{

if(verboseEnabled)

{

Line 648

Line 632

{

_portNumber = 5989;

_portNumberStr = "5989";

if (!_propertyTable->insert("port", _portNumberStr))

if (!_propertyTable.insert("port", _portNumberStr))

{

if(verboseEnabled)

{

Line 658

Line 642

}

if (!_propertyTable->insert("ssl", ""))

if (!_propertyTable.insert("ssl", ""))

{

if(verboseEnabled)

{

Line 682

Line 666

}

_userName = getOpts[i].Value();

_userNameSpecified = true;

if (!_propertyTable->insert("username", _userName))

if (!_propertyTable.insert("username", _userName))

{

if(verboseEnabled)

{

Line 706

Line 690

}

_password = getOpts[i].Value();

_passwordSpecified = true;

if (!_propertyTable->insert("password", _password))

if (!_propertyTable.insert("password", _password))

{

if(verboseEnabled)

{

Line 782

Line 766

// Array's to store client specific information

_clientCommands = new String[_clientCount];

_clientCommands.reset(new String[_clientCount]);

_clientDurations = new Uint64[_clientCount];

_clientDurations.reset(new Uint64[_clientCount]);

_clientDelays = new Uint64[_clientCount];

_clientDelays.reset(new Uint64[_clientCount]);

// Retrieve all the client options from the client table

Line 799

Line 783

// Stress Client Name must exist for each client/client table

if (!_clientTable[j].lookup(NAME, clientName))

if (!_clientTable.get()[j].lookup(NAME, clientName))

{

log_file<<StressTestControllerCommand::COMMAND_NAME<<

"::Required property NAME not found."<<endl;

Line 813

Line 797

// Generate the commands for each client from each client table.

for (Table::Iterator i = _clientTable[j].start(); i; i++)

for (Table::Iterator i = _clientTable.get()[j].start(); i; i++)

{

if (String::equalNoCase(i.key(),HOSTNAME))

{

Line 927

Line 911

// from config file and include it as part of the client command

// as required.

for (Table::Iterator k = _propertyTable->start(); k; k++)

for (Table::Iterator k = _propertyTable.start(); k; k++)

{

String propertyValue = String::EMPTY;

// Only include the common properties that are not already

// listed for the clients.

if (!_clientTable[j].lookup(k.key(), propertyValue))

if (!_clientTable.get()[j].lookup(k.key(), propertyValue))

{

// Include options other than ToleranceLevel

Line 969

Line 953

{

duration = _duration;

}

} /* for (Table::Iterator k = _propertyTable->start(); k; k++) */

} /* for (Table::Iterator k = _propertyTable.start(); k; k++) */

// Looking up table while ignoring cases for Client Duration/Wait.

for (Table::Iterator k = _clientTable[j].start(); k; k++)

for (Table::Iterator k = _clientTable.get()[j].start(); k; k++)

{

// Overwrite duration if client duration set

Line 993

Line 977

// Save the generated command to corresponding element in the

// clientCommand array.

_clientCommands[j] = client_command;

_clientCommands.get()[j] = client_command;

// Converting minutes to milliseconds

_clientDurations[j] = (Uint64)convertmin2millisecs(duration);

_clientDurations.get()[j] = (Uint64)convertmin2millisecs(duration);

_clientDelays[j] = (Uint64)convertmin2millisecs(delay);

_clientDelays.get()[j] = (Uint64)convertmin2millisecs(delay);

// Saving logs

log_file<<StressTestControllerCommand::COMMAND_NAME<<

"::Client Command[";

"::Client Command[" << j << "]" << endl;

log_file<<j<<"]"<<endl;

log_file << " " << _clientCommands.get()[j] << endl;

log_file<<" "<<_clientCommands[j]<<endl;

log_file<<" Client Duration: "<<

convertUint64toString(_clientDurations[j])<<endl;

convertUint64toString(_clientDurations.get()[j]) << endl;

log_file<<

log_file << " Client Delay: " <<

" Client Delay: "<<convertUint64toString(_clientDelays[j])<<endl;

convertUint64toString(_clientDelays.get()[j]) << endl;

// Verbose

if (verboseEnabled)

{

cout<<

cout << StressTestControllerCommand::COMMAND_NAME <<

StressTestControllerCommand::COMMAND_NAME<<"::Client Command[";

"::Client Command[" << j << "]" << endl;

cout<<j<<"]"<<endl;

cout << " " << _clientCommands.get()[j] << endl;

cout<<" "<<_clientCommands[j]<<endl;

cout<<" Client Duration: "<<

convertUint64toString(_clientDurations[j])<<endl;

convertUint64toString(_clientDurations.get()[j]) << endl;

cout<<" Client Delay: "<<convertUint64toString(_clientDelays[j])<<

cout << " Client Delay: " <<

endl;

convertUint64toString(_clientDelays.get()[j]) << endl;

}

} /* for(Uint32 j=0; j< _clientCount; j++) */

return true;

Line 1058

Line 1040

ostream& outPrintWriter,

ostream& errPrintWriter)

{

int actual_client = 0;

Uint64 startMilliseconds = 0;

Uint64 nowMilliseconds = 0;

Uint64 stopMilliseconds = 0;

Uint64 timeoutMilliseconds = 0;

Uint64 *clientStartMilliseconds = 0;

AutoArrayPtr<Uint64> clientStartMilliseconds;

Uint64 *clientStopMilliseconds = 0;

AutoArrayPtr<Uint64> clientStopMilliseconds;

Uint64 *clientDelayMilliseconds = 0;

AutoArrayPtr<Uint64> clientDelayMilliseconds;

Boolean *clientStopped = 0;

AutoArrayPtr<Boolean> clientStopped;

Boolean *clientDelayed = 0;

AutoArrayPtr<Boolean> clientDelayed;

String act_command = String::EMPTY;

String act_command;

Boolean TestFailed = false;

char str[15];

char strTime[256];

struct tm tmTime;

// log file

Line 1147

Line 1126

if(_clientCount > 0)

{

clientInstance = new int[_clientCount];

clientStartMilliseconds = new Uint64[_clientCount];

clientStartMilliseconds.reset(new Uint64[_clientCount]);

clientStopMilliseconds = new Uint64[_clientCount];

clientStopMilliseconds.reset(new Uint64[_clientCount]);

clientDelayMilliseconds = new Uint64[_clientCount];

clientDelayMilliseconds.reset(new Uint64[_clientCount]);

clientStopped = new Boolean[_clientCount];

clientStopped.reset(new Boolean[_clientCount]);

clientDelayed = new Boolean[_clientCount];

clientDelayed.reset(new Boolean[_clientCount]);

}

else

{

Line 1169

Line 1148

for (Uint32 i=0;i<_clientCount;i++)

{

clientStopped[i] = false;

clientStopped.get()[i] = false;

clientDelayed[i] = false;

clientDelayed.get()[i] = false;

}

// Set up duration of the tests

Line 1253

Line 1232

// Acquire the client Instance for each clients

if (!_clientTable[j].lookup(INSTANCE, clientInst))

if (!_clientTable.get()[j].lookup(INSTANCE, clientInst))

{

String ErrReport = String("Invalid Property Value: ");

ErrReport.append(INSTANCE);

Line 1266

Line 1245

// Acquire and set client specific duration

clientStartMilliseconds[j] =

clientStartMilliseconds.get()[j] =

TimeValue::getCurrentTime().toMilliseconds();

clientStopMilliseconds[j] =

clientStopMilliseconds.get()[j] =

clientStartMilliseconds[j] + _clientDurations[j];

clientStartMilliseconds.get()[j] +

_clientDurations.get()[j];

// for verbose only

Line 1279

Line 1259

outPrintWriter<<"Client:"<<"["<<j<<"]"<<endl;

log_file<<"Client:"<<"["<<j<<"]"<<endl;

outPrintWriter<<"ClientStart:"<<

convertUint64toString(clientStartMilliseconds[j])<<

convertUint64toString(

clientStartMilliseconds.get()[j]) <<

endl;

outPrintWriter<<"ClientStop:"<<

convertUint64toString(clientStopMilliseconds[j])<<

convertUint64toString(

clientStopMilliseconds.get()[j]) <<

endl;

outPrintWriter<<"ClientDuration:"<<

convertUint64toString(_clientDurations[j])<<endl;

convertUint64toString(_clientDurations.get()[j]) <<

endl;

log_file<<"ClientStart:"<<

convertUint64toString(clientStartMilliseconds[j])<<

convertUint64toString(

clientStartMilliseconds.get()[j]) <<

endl;

log_file<<"ClientStop:"<<

convertUint64toString(clientStopMilliseconds[j])<<

convertUint64toString(

clientStopMilliseconds.get()[j]) <<

endl;

log_file << "ClientDuration:" <<

convertUint64toString(_clientDurations.get()[j]) <<

endl;

log_file<<

"ClientDuration:"<<

convertUint64toString(_clientDurations[j])<<endl;

}

log_file<<

"Number of instances of this client: "<<

Line 1325

Line 1310

// Adding all the required parameters for the command.

act_command.append(_clientCommands[j].getCString());

act_command.append(_clientCommands.get()[j]);

act_command.append(" -clientid ");

sprintf(str,"%d",actual_client);

act_command.append(str);

Line 1531

Line 1516

// Stop only running clients as required.

if (!clientStopped[clientID])

if (!clientStopped.get()[clientID])

{

// If Client's duration is up

if (clientStopMilliseconds[clientID]<= nowMilliseconds)

if (clientStopMilliseconds.get()[clientID] <=

nowMilliseconds)

{

// Stop all the instances of this client

Line 1602

Line 1588

// indicate that the client was stopped.

clientStopped[clientID] = true;

clientStopped.get()[clientID] = true;

// If the Client has a Wait time

if (_clientDelays[clientID] !=0)

if (_clientDelays.get()[clientID] !=0)

{

clientDelayMilliseconds[clientID] =

clientDelayMilliseconds.get()[clientID] =

nowMilliseconds + _clientDelays[clientID];

nowMilliseconds +

clientDelayed[clientID] = true;

_clientDelays.get()[clientID];

clientDelayed.get()[clientID] = true;

}

} /* if (clientStopMilliseconds[clientID]<= nowMilli..*/

} /* if (!clientStopped[clientID]) */

} /* if (!clientStopped.get()[clientID]) */

else

{

// Only restart clients that are waiting.

if (clientDelayed[clientID])

if (clientDelayed.get()[clientID])

{

// When waiting period is consumed.

if (clientDelayMilliseconds[clientID]<=

if (clientDelayMilliseconds.get()[clientID] <=

nowMilliseconds)

{

Line 1639

Line 1626

act_command.append("start ");

#endif

act_command.append(

_clientCommands[clientID].getCString());

_clientCommands.get()[clientID]);

act_command.append(" -clientid ");

sprintf(str,"%d",clientID+instanceID);

act_command.append(str);

act_command.append(" -pidfile ");

act_command.append(" \"");

act_command.append(_stressTestClientPIDFile);

act_command.append(

_stressTestClientPIDFile);

act_command.append("\"");

act_command.append(" -clientlog");

act_command.append(" \"");

act_command.append(_stressTestClientLogFile);

act_command.append(

_stressTestClientLogFile);

act_command.append("\"");

act_command.append("&");

log_file<<"Restarting client:("<<

Line 1685

Line 1674

}

clientActive[clientID+instanceID] = true;

} /* for (int instanceID =0;instanceID .. */

clientStopMilliseconds[clientID] =

clientStopMilliseconds.get()[clientID] =

nowMilliseconds +

_clientDurations[clientID];

_clientDurations.get()[clientID];

clientStopped[clientID] = false;

clientStopped.get()[clientID] = false;

clientDelayed[clientID] = false;

clientDelayed.get()[clientID] = false;

}/* if(clientDelayMilliseconds[clientID]<=nowMi.. */

} /* if(clientDelayed[clientID]) */

} /* if(clientDelayed.get()[clientID]) */

} /* else ..*/

} /* for(Uint32 clientID=0;clientID < _clientCount;clientID++)*/

} /* else for if(!actual_client) */

Line 1935

Line 1924

{

cout<<" "<<name<<"\t= "<<value<<endl;

}

if (!_propertyTable->insert(name, value))

if (!_propertyTable.insert(name, value))

{

// Duplicate property, ignore the new property value.

Line 1984

Line 1973

cout<<StressTestControllerCommand::COMMAND_NAME<<

"::Common Properties:"<<endl;

}

for (Table::Iterator i = _propertyTable->start(); i; i++)

for (Table::Iterator i = _propertyTable.start(); i; i++)

{

log_file<<" "<<i.key()<<"\t= "<<i.value()<<endl;

if (verboseEnabled)

Line 2006

Line 1995

{

cout<<"Client("<<j<<")"<<endl;

}

for (Table::Iterator i = _clientTable[j].start(); i; i++)

for (Table::Iterator i = _clientTable.get()[j].start(); i; i++)

{

log_file<<" "<<i.key()<<" = "<<i.value()<<endl;

if (verboseEnabled)

Line 2301

Line 2290

- "]" indicates end of client options.

- Client properties and values are seperated by commas.

Example:

[clientName=cimcli,Options=niall]

[clientName=CLI,Options=niall]

- This method will throw appropriate exceptions.

@param p The pointer to the char in the concerned line

Line 2329

Line 2318

}

if (!(isalpha(*p) || *p == '_'))

{

throw StressTestControllerException

throw StressTestControllerException(

(StressTestControllerException::INVALID_OPTION);

StressTestControllerException::INVALID_OPTION);

}

name.append(*p++);

Line 2354

Line 2343

if (*p != '=')

{

throw StressTestControllerException

throw StressTestControllerException(

(StressTestControllerException::INVALID_OPERATOR);

StressTestControllerException::INVALID_OPERATOR);

}

p++;

Line 2387

Line 2376

if(*p !=']' && *p != ',')

{

throw StressTestControllerException

throw StressTestControllerException(

(StressTestControllerException::MISSING_BRACE);

StressTestControllerException::MISSING_BRACE);

}

if(value == String::EMPTY)

{

throw StressTestControllerException

throw StressTestControllerException(

(StressTestControllerException::MISSING_VALUE);

StressTestControllerException::MISSING_VALUE);

}

#ifdef STRESSTEST_DEBUG

Line 2415

Line 2404

// Save client property in client table if valid.

if (!_clientTable[_currClientCount].insert(name,value))

if (!_clientTable.get()[_currClientCount].insert(name,value))

{

// Duplicate property, ignore the new property value.

Line 2747

Line 2736

- "[" indicates start of client options.

- Client properties and values are seperated by commas.

Example:

[clientName=cimcli,Options=niall]

[clientName=CLI,Options=niall]

@param line The line that will be parsed.

@parm lineNumber The line number of the line.

Line 2980

Line 2969

Table* tempClientTable = new Table[Total_Clients];

for (Uint32 i =0;i<_clientCount;i++)

{

tempClientTable[i] = _clientTable[i];

tempClientTable[i] = _clientTable.get()[i];

}

delete [] _clientTable;

_clientTable.reset(tempClientTable);

_clientTable = tempClientTable;

}

// Store the client Name in the table

if (!_clientTable[_clientCount].insert(NAME, name))

if (!_clientTable.get()[_clientCount].insert(NAME, name))

{

// Duplicate property, ignore the new property value.

Line 3004

Line 2992

// Store the number of instances for the client in the table

if (!_clientTable[_clientCount].insert(INSTANCE, value))

if (!_clientTable.get()[_clientCount].insert(INSTANCE, value))

{

Line 3178

Line 3166

// Adding the default instance value to each client table

if (!_clientTable[i].insert(INSTANCE, DEFAULT_INSTANCE))

if (!_clientTable.get()[i].insert(INSTANCE, DEFAULT_INSTANCE))

{

log_file << "Duplicate name already saved: "<<INSTANCE<<endl;

if (verboseEnabled)

Line 3190

Line 3178

{

case 0:

{

if (!_clientTable[i].insert(NAME, MODELWALK_CLIENT))

if (!_clientTable.get()[i].insert(NAME, MODELWALK_CLIENT))

{

log_file << "Duplicate name already saved: "<<NAME<<endl;

if (verboseEnabled)

Line 3198

Line 3186

cout<< "Duplicate name already saved: "<<NAME<<endl;

}

log_file << "Stress Test Client Name:"<<MODELWALK_CLIENT<< endl;

log_file << "Stress Test Client Name:" << MODELWALK_CLIENT <<

endl;

if (verboseEnabled)

{

cout<< "Stress Test Client Name:"<<MODELWALK_CLIENT<< endl;

Line 3208

Line 3197

}

case 1:

{

if (!_clientTable[i].insert(NAME, WRAPPER_CLIENT))

if (!_clientTable.get()[i].insert(NAME, WRAPPER_CLIENT))

{

log_file << "Duplicate name already saved: "<<NAME<<endl;

if (verboseEnabled)

Line 3221

Line 3210

{

cout << "Stress Test Client Name:" <<WRAPPER_CLIENT<< endl;

}

if (!_clientTable[i].insert(CLIENTNAME, "cimcli"))

if (!_clientTable.get()[i].insert(CLIENTNAME, "CLI"))

{

log_file<< "Duplicate name already saved: "<<

CLIENTNAME<<endl;

Line 3231

Line 3220

CLIENTNAME<<endl;

}

if (!_clientTable[i].insert(OPTIONS, "niall"))

if (!_clientTable.get()[i].insert(OPTIONS, "niall"))

{

log_file<< "Duplicate name already saved: "<<OPTIONS<<endl;

if (verboseEnabled)

Line 3239

Line 3228

cout<< "Duplicate name already saved: "<<OPTIONS<<endl;

}

log_file<< " Client Command & options: cimcli niall"<<

log_file<< " Client Command & options: CLI niall"<<

endl;

if (verboseEnabled)

{

cout<< " Client Command & options: cimcli niall"<<

cout<< " Client Command & options: CLI niall"<<

endl;

}

break;

Legend:

Removed from v.1.3.24.2
changed lines
	Added in v.1.4

No CVS admin address has been configured