// reports
std::string a_reportsDirectory;
bool a_dumpReports;
+ bool a_dumpHexMessages;
// Pool of test cases
test_pool_t a_testPool;
test_pool_it a_currentTestIt;
- bool a_poolRepeat; // repeat pool when finish
+ int a_poolRepeats; // repeat pool N times
+ int a_poolCycle; // current cycle, from 1 to N
unsigned int a_inProgressCount;
unsigned int a_inProgressLimit; // limit load to have this value
void setReportsDirectory(const std::string &rd) throw() { a_reportsDirectory = rd; }
const std::string &getReportsDirectory() const throw() { return a_reportsDirectory; }
+ void setDumpHex(bool dh) throw() { a_dumpHexMessages = dh; }
+ bool getDumpHex() const throw() { return a_dumpHexMessages; }
void setDumpReports(bool dr) throw() { a_dumpReports = dr; }
bool getDumpReports() const throw() { return a_dumpReports; }
bool clearPool() throw();
bool resetPool(bool hard /* hard reset includes in-progress test cases */) throw();
- void setPoolRepeat(bool repeat) throw() { a_poolRepeat = repeat; }
- bool getPoolRepeat() const throw() { return a_poolRepeat; }
+ void setPoolRepeats(int repeats) throw() { a_poolRepeats = repeats; }
+ int getPoolRepeats() const throw() { return a_poolRepeats; }
+ int getPoolCycle() const throw() { return a_poolCycle; }
+
unsigned int getInProgressCount() const throw() { return a_inProgressCount; }
void setInProgressCountDelta(unsigned int delta) throw() { a_inProgressCount += delta; }
unsigned int getInProgressLimit() const throw() { return a_inProgressLimit; }
TestCase *getTestCase(unsigned int id) throw(); // creates/reuses a test case
// Main logic
- TestCase *getTestCaseFromSessionId(const anna::DataBlock &message, std::string &sessionId) throw(anna::RuntimeException);
+ TestCase *getTestCaseFromSessionId(const anna::DataBlock &message, std::string &sessionId) throw();
void receiveMessage(const anna::DataBlock &message, const anna::diameter::comm::ClientSession *clientSession) throw(anna::RuntimeException);
void receiveMessage(const anna::DataBlock &message, const anna::diameter::comm::ServerSession *serverSession) throw(anna::RuntimeException);