X-Git-Url: https://git.teslayout.com/public/public/public/?a=blobdiff_plain;f=example%2Fdiameter%2Flauncher%2Ftesting%2FTestStep.hpp;h=75cbae35990011cd21e87999eb6ac79c5a8ecfa8;hb=56fdf785afe43dc636ca4334c4ca47cf8241334d;hp=e4574c148c82a0fe8a56a67d8bc8bbba0e6e19f0;hpb=888c763c650fbe314ba47bb0840c47fc508cc837;p=anna.git diff --git a/example/diameter/launcher/testing/TestStep.hpp b/example/diameter/launcher/testing/TestStep.hpp index e4574c1..75cbae3 100644 --- a/example/diameter/launcher/testing/TestStep.hpp +++ b/example/diameter/launcher/testing/TestStep.hpp @@ -17,6 +17,7 @@ // Project #include #include +#include // Process #include @@ -43,13 +44,14 @@ namespace anna { class TestCase; class TestTimer; -class RealmNode; +class OriginHost; class TestStep { int a_number; // step number used for xml (informational) anna::Millisecond a_beginTimestamp; // unix time anna::Millisecond a_endTimestamp; // unix time + bool a_executed; // used for interactive mode in order to not repeat a execution step if before completing, the user add interactive amount void setBeginTimestamp(const anna::Millisecond &t) throw() { a_beginTimestamp = t; } const anna::Millisecond &getBeginTimestamp() const throw() { return a_beginTimestamp; } @@ -62,7 +64,7 @@ class TestStep { struct Type { enum _v { Unconfigured, Timeout, Sendxml2e, Sendxml2c, Delay, Wait, Cmd }; }; static const char* asText(const Type::_v type) throw(); - TestStep(TestCase *testCase) { initialize(testCase); } + TestStep(TestCase *testCase) : a_message(true), a_messageCodec(NULL), a_executed(false) { initialize(testCase); } virtual ~TestStep() {;} // setter & getters @@ -74,14 +76,20 @@ class TestStep { void complete() throw(); void reset() throw(); void next() throw(); - virtual anna::xml::Node* asXML(anna::xml::Node* parent) const throw(); - std::string asXMLString() const throw(); + virtual anna::xml::Node* asXML(anna::xml::Node* parent) throw(); + std::string asXMLString() throw(); protected: TestCase *a_testCase; bool a_completed; Type::_v a_type; + // Message (not for all step types) + anna::DataBlock a_message; + anna::diameter::codec::Message *a_messageCodec; // used as helper and for traffic logs + bool decodeMessage(bool trust = false) throw(); // If trust=true: decoding the previously encoded message (sendxml sentences). + // The only error would be validation ones, and we are going to ignore them here. + virtual bool do_execute() throw() = 0; // returns true if next step must be executed virtual void do_complete() throw() = 0; // end of transaction (delay/timeout expired, wait condition fulfilled, sending done) // In all cases, the next step will be executed except 'timeout' which is asynchronous @@ -106,7 +114,7 @@ class TestStepTimeout : public TestStep { bool do_execute() throw(); void do_complete() throw(); // timeout reached, test case failed void do_reset() throw(); - anna::xml::Node* asXML(anna::xml::Node* parent) const throw(); + anna::xml::Node* asXML(anna::xml::Node* parent) throw(); }; @@ -114,25 +122,24 @@ class TestStepSendxml : public TestStep { protected: // possible end points: - RealmNode *a_realmNode; + OriginHost *a_originHost; // Step number reference ('wait for request' step) int a_waitForRequestStepNumber; - // Message - anna::DataBlock a_message; - anna::diameter::codec::Message *a_messageCodec; // used as helper and for traffic logs - // Expired ? bool a_expired; // a_endTimestamp will be the expiration reception timestamp public: - TestStepSendxml(TestCase *testCase) : TestStep(testCase), a_message(true), a_messageCodec(NULL), a_expired(false), a_realmNode(NULL), a_waitForRequestStepNumber(-1) {;} - ~TestStepSendxml(); + TestStepSendxml(TestCase *testCase) : TestStep(testCase), + a_expired(false), + a_originHost(NULL), + a_waitForRequestStepNumber(-1) {;} + ~TestStepSendxml() {;} // setter & getters - void setRealmNode(RealmNode *realm) throw() { a_realmNode = realm; } - RealmNode *getRealmNode() const throw() { return a_realmNode; } + void setOriginHost(OriginHost *host) throw() { a_originHost = host; } + OriginHost *getOriginHost() const throw() { return a_originHost; } void setWaitForRequestStepNumber(int stepNumber) throw() { a_waitForRequestStepNumber = stepNumber; } int getWaitForRequestStepNumber() const throw() { return a_waitForRequestStepNumber; } void setMsgDataBlock(const anna::DataBlock &db) throw() { a_message = db; } @@ -142,7 +149,7 @@ class TestStepSendxml : public TestStep { bool do_execute() throw(); void do_complete() throw() {;} void do_reset() throw(); - anna::xml::Node* asXML(anna::xml::Node* parent) const throw(); + anna::xml::Node* asXML(anna::xml::Node* parent) throw(); }; class TestStepSendxml2e : public TestStepSendxml { @@ -171,26 +178,29 @@ class TestStepDelay : public TestStep { bool do_execute() throw(); void do_complete() throw(); // delay reached void do_reset() throw(); - anna::xml::Node* asXML(anna::xml::Node* parent) const throw(); + anna::xml::Node* asXML(anna::xml::Node* parent) throw(); }; class TestStepWait : public TestStep { TestCondition a_condition; - anna::DataBlock a_message; // message which complies with condition - anna::diameter::codec::Message *a_messageCodec; // used as helper and for traffic logs anna::diameter::comm::ClientSession *a_clientSession; anna::diameter::comm::ServerSession *a_serverSession; public: - TestStepWait(TestCase *testCase) : TestStep(testCase), a_message(true), a_messageCodec(NULL) { a_type = Type::Wait; a_clientSession = NULL; a_serverSession = NULL; } - ~TestStepWait(); + TestStepWait(TestCase *testCase) : TestStep(testCase) { + a_type = Type::Wait; + a_clientSession = NULL; + a_serverSession = NULL; + } + ~TestStepWait() {;} // setter & getters void setCondition(bool fromEntity, - const std::string &code, const std::string &bitR, const std::string &resultCode, const std::string &sessionId, - const std::string &hopByHop, const std::string &msisdn, const std::string &imsi, const std::string &serviceContextId) throw(); + const std::string &code, const std::string &bitR, const std::string &hopByHop, const std::string &applicationId, + const std::string &sessionId, const std::string &resultCode, + const std::string &msisdn, const std::string &imsi, const std::string &serviceContextId) throw(); void setCondition(bool fromEntity, const std::string ®exp) throw(); void setClientSession(anna::diameter::comm::ClientSession *cs) throw() { a_clientSession = cs; } @@ -208,14 +218,13 @@ class TestStepWait : public TestStep { bool do_execute() throw(); // this will be executed when test case starts (at least we could measure the time until condition is fulfilled) void do_complete() throw(); // condition fulfilled void do_reset() throw(); - anna::xml::Node* asXML(anna::xml::Node* parent) const throw(); + anna::xml::Node* asXML(anna::xml::Node* parent) throw(); }; class TestStepCmd : public TestStep { std::string a_script; - std::string a_parameters; std::thread a_thread; bool a_threadRunning; bool a_threadDeprecated; @@ -223,14 +232,13 @@ class TestStepCmd : public TestStep { std::string a_errorMsg; //std::string a_output; // for POPEN + pid_t a_childPid; + public: - TestStepCmd(TestCase *testCase) : TestStep(testCase), a_threadRunning(false), a_threadDeprecated(false), a_resultCode(-2)/*, a_output("")*/, a_errorMsg("") { a_type = Type::Cmd; } + TestStepCmd(TestCase *testCase) : TestStep(testCase), a_threadRunning(false), a_threadDeprecated(false), a_resultCode(-2)/*, a_output("")*/, a_errorMsg(""), a_childPid(-1) { a_type = Type::Cmd; } // setter & getters void setThreadRunning(bool running) throw() { a_threadRunning = running; } - //bool getThreadRunning() const throw() { return a_threadRunning; } - //void setThreadDeprecated(bool deprecated) throw() { a_threadDeprecated = deprecated; } - //bool getThreadDeprecated() const throw() { return a_threadDeprecated; } void setResultCode(int rc) throw() { a_resultCode = rc; } int getResultCode() const throw() { return a_resultCode; } @@ -238,17 +246,17 @@ class TestStepCmd : public TestStep { const std::string &getErrorMsg() const throw() { return a_errorMsg; } //void appendOutput(const std::string &output) throw() { a_output += output; } //const std::string &getOutput() const throw() { return a_output; } + void setChildPid(pid_t pid) throw() { a_childPid = pid; } + const pid_t &getChildPid() const throw() { return a_childPid; } void setScript(const std::string &script) throw() { a_script = script; } const std::string &getScript() const throw() { return a_script; } - void setParameters(const std::string ¶ms) throw() { a_parameters = params; } - const std::string &getParameters() const throw() { return a_parameters; } // virtuals bool do_execute() throw(); void do_complete() throw(); void do_reset() throw(); - anna::xml::Node* asXML(anna::xml::Node* parent) const throw(); + anna::xml::Node* asXML(anna::xml::Node* parent) throw(); };