// TODO: mutex the step while setting data here !!
}
+/*
void cmdRunOnThreadWithFork (TestStepCmd *step, const std::string &cmd) {
// Thread running:
step->complete();
}
}
+*/
bool decodeMessage(const anna::DataBlock &message, anna::diameter::codec::Message &messageCodec) throw() {
bool TestStepSendxml::do_execute() throw() {
bool success = false;
- std::string failReason;
+ std::string failReason = "Error sending diameter message";
anna::diameter::comm::Entity *entity = a_originHost->getEntity(); // by default
anna::diameter::comm::LocalServer *localServer = a_originHost->getDiameterServer(); // by default
const TestStepWait *tsw = NULL;
a_condition.setServiceContextId(serviceContextId);
}
-void TestStepWait::setCondition(bool fromEntity, const std::string ®exp) throw() {
+void TestStepWait::setConditionRegexpHex(bool fromEntity, const std::string ®exp) throw() {
+ a_condition.setReceivedFromEntity(fromEntity);
+ a_condition.setRegexpHex(regexp);
+}
+void TestStepWait::setConditionRegexpXml(bool fromEntity, const std::string ®exp) throw() {
a_condition.setReceivedFromEntity(fromEntity);
- a_condition.setRegexp(regexp);
+ a_condition.setRegexpXml(regexp);
}
anna::xml::Node* TestStepWait::asXML(anna::xml::Node* parent)
}
}
- if (decodeMessage()) {
- xmlmsg = "\n";
- xmlmsg += a_messageCodec->asXMLString();
- xmlmsg += "\n";
+ if (a_message.isEmpty()) {
+ xmlmsg = "<empty>";
}
else {
- xmlmsg = "<unable to decode, check traces>";
+ if (decodeMessage()) {
+ xmlmsg = "\n";
+ xmlmsg += a_messageCodec->asXMLString();
+ xmlmsg += "\n";
+ }
+ else {
+ xmlmsg = "<unable to decode, check traces>";
+ }
}
if (msg != "") result->createAttribute("MatchedMessage", msg);