#include <anna/diameter/helpers/base/functions.hpp>
// Process
-#include <RealmNode.hpp>
+#include <OriginHost.hpp>
#include <MyDiameterEntity.hpp>
#include <MyLocalServer.hpp>
#include <TestStep.hpp>
a_number = testCase->steps() + 1; // testCase is not NULL
}
-bool TestStep::decodeMessage() throw() {
+bool TestStep::decodeMessage(bool trust) throw() {
if (a_messageCodec) return true;
a_messageCodec = new anna::diameter::codec::Message;
if (::decodeMessage(a_message, *a_messageCodec)) return true;
+ if (trust) {
+ LOGDEBUG(anna::Logger::debug("Error DECODING, but trusting it ...", ANNA_FILE_LOCATION));
+ return true;
+ }
delete a_messageCodec;
a_messageCodec = NULL;
xmlmsg += a_messageCodec->asXMLString();
xmlmsg += "\n";
}
+ else {
+ xmlmsg = "<unable to decode, check traces>";
+ }
if (msg != "") result->createAttribute("Message", msg);
if (xmlmsg != "") result->createAttribute("XMLMessage", xmlmsg);
bool TestStepSendxml::do_execute() throw() {
bool success = false;
- std::string failReason, s_warn;
- MyDiameterEntity *entity = a_realmNode->getEntity(); // by default
- MyLocalServer *localServer = a_realmNode->getDiameterServer(); // by default
+ std::string failReason;
+ MyDiameterEntity *entity = a_originHost->getEntity(); // by default
+ MyLocalServer *localServer = a_originHost->getDiameterServer(); // by default
const TestStepWait *tsw = NULL;
-
- // Create comm message:
- anna::diameter::comm::Message *msg = a_realmNode->createCommMessage();
- //msg->clearBody();
- msg->setBody(a_message);
+ anna::diameter::comm::Message *msg = a_originHost->createCommMessage();
try {
- // Update sequence for answers:
- if (a_waitForRequestStepNumber != -1) { // is an answer: try to copy sequence information; alert about Session-Id discrepance
- // Request which was received:
- tsw = static_cast<const TestStepWait*>(a_testCase->getStep(a_waitForRequestStepNumber));
- const anna::DataBlock &request = tsw->getMsgDataBlock();
- anna::diameter::HopByHop hbh = anna::diameter::codec::functions::getHopByHop(request);
- anna::diameter::EndToEnd ete = anna::diameter::codec::functions::getEndToEnd(request);
+ if (a_waitForRequestStepNumber != -1) {
- // Update sequence:
- anna::diameter::codec::functions::setHopByHop(a_message, hbh);
- anna::diameter::codec::functions::setEndToEnd(a_message, ete);
+ // Referenced request in the 'wait for request step':
+ tsw = static_cast<const TestStepWait*>(a_testCase->getStep(a_waitForRequestStepNumber));
+ const anna::DataBlock &referenceRequest = tsw->getMsgDataBlock();
+ std::string sessionIdReferenceRequest = anna::diameter::helpers::base::functions::getSessionId(referenceRequest);
+ bool thisIsAnswer = anna::diameter::codec::functions::isRequest(getMsgDataBlock());
- // Check Session-Id for warning ...
- std::string sessionIdAnswer = anna::diameter::helpers::base::functions::getSessionId(a_message);
- std::string sessionIdRequest = anna::diameter::helpers::base::functions::getSessionId(request);
+ if (thisIsAnswer) { // is an answer: try to copy sequence information; alert about Session-Id discrepance
+ anna::diameter::HopByHop hbh = anna::diameter::codec::functions::getHopByHop(referenceRequest);
+ anna::diameter::EndToEnd ete = anna::diameter::codec::functions::getEndToEnd(referenceRequest);
- if (sessionIdRequest != sessionIdAnswer) {
- s_warn = anna::functions::asString("Sending an answer which Session-Id (%s) is different than supposed corresponding request (%s)", sessionIdAnswer.c_str(), sessionIdRequest.c_str());
- LOGWARNING(anna::Logger::warning(s_warn, ANNA_FILE_LOCATION));
- a_testCase->addDebugSummaryHint(s_warn);
+ // Update sequence:
+ anna::diameter::codec::functions::setHopByHop(a_message, hbh);
+ anna::diameter::codec::functions::setEndToEnd(a_message, ete);
+ }
+
+ // Session-Id substitution:
+ std::string thisSessionId = anna::diameter::helpers::base::functions::getSessionId(getMsgDataBlock());
+ if (thisSessionId != sessionIdReferenceRequest) {
+ static anna::diameter::codec::Message codecMsg;
+ codecMsg.decode(getMsgDataBlock());
+ codecMsg.getAvp("Session-Id")->getUTF8String()->setValue(sessionIdReferenceRequest);
+ a_message = codecMsg.code();
+ std::string trace = anna::functions::asString("Replacing %s Session-Id (%s) to set the corresponding request one (%s)", (thisIsAnswer ? "answer":"request"), thisSessionId.c_str(), sessionIdReferenceRequest.c_str());
+ LOGDEBUG(anna::Logger::debug(trace, ANNA_FILE_LOCATION));
+ a_testCase->addDebugSummaryHint(trace);
}
}
+ // Create comm message:
+ //msg->clearBody();
+ msg->setBody(a_message);
+
+
if (getType() == Type::Sendxml2e) {
anna::diameter::comm::ClientSession *usedClientSession = NULL;
} // else (normal sending)
// Detailed log:
- if(a_realmNode->logEnabled()) {
- if (decodeMessage()) {
+ if(a_originHost->logEnabled()) {
+ if (decodeMessage(true /* trust */)) {
std::string detail = usedClientSession ? usedClientSession->asString() : "<null client session>"; // shouldn't happen
- a_realmNode->writeLogFile(*a_messageCodec, (success ? "sent2e" : "send2eError"), detail);
+ a_originHost->writeLogFile(*a_messageCodec, (success ? "sent2e" : "send2eError"), detail);
}
}
}
} // else (normal sending)
// Detailed log:
- if(a_realmNode->logEnabled()) {
- if (decodeMessage()) {
+ if(a_originHost->logEnabled()) {
+ if (decodeMessage(true /* trust */)) {
std::string detail = usedServerSession ? usedServerSession->asString() : "<null server session>"; // shouldn't happen
- a_realmNode->writeLogFile(*a_messageCodec, (success ? "sent2c" : "send2cError"), detail);
+ a_originHost->writeLogFile(*a_messageCodec, (success ? "sent2c" : "send2cError"), detail);
}
}
}
}
// release msg
- a_realmNode->releaseCommMessage(msg);
+ a_originHost->releaseCommMessage(msg);
if (!success) {
a_testCase->addDebugSummaryHint(failReason); // before report (when set Failed state);
anna::xml::Node* result = TestStep::asXML(parent);
//parent->createChild("TestStepDelay");
- result->createAttribute("Delay", a_delay.asString());
+ result->createAttribute("Delay", ((a_delay == 0) ? "dummy step, no delay" : a_delay.asString()));
return result;
}
bool TestStepDelay::do_execute() throw() {
+ if (a_delay == 0) { complete(); return true; } // special case
try {
a_timer = TestManager::instantiate().createTimer((TestCaseStep*)this, a_delay, TestTimer::Type::Delay);
}
}
void TestStepDelay::do_complete() throw() {
+ if (a_delay == 0) return; // special case
a_timer = NULL;
next(); // next() invoked here because execute() is always false for delay and never advance the iterator
// TODO, avoid this recursion
}
void TestStepDelay::do_reset() throw() {
+ if (a_delay == 0) return; // special case
try {
TestManager::instantiate().cancelTimer(a_timer);
}
xmlmsg += a_messageCodec->asXMLString();
xmlmsg += "\n";
}
+ else {
+ xmlmsg = "<unable to decode, check traces>";
+ }
if (msg != "") result->createAttribute("MatchedMessage", msg);
if (xmlmsg != "") result->createAttribute("MatchedXMLMessage", xmlmsg);
projects / anna.git / blobdiff