projects
/
anna.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
Decrease timex Engine minimum resolution from 100 to 10 milliseconds. Add warning...
[anna.git]
/
example
/
diameter
/
launcher
/
Launcher.cpp
diff --git
a/example/diameter/launcher/Launcher.cpp
b/example/diameter/launcher/Launcher.cpp
index
05422f4
..
59f5202
100644
(file)
--- a/
example/diameter/launcher/Launcher.cpp
+++ b/
example/diameter/launcher/Launcher.cpp
@@
-278,7
+278,8
@@
throw(anna::RuntimeException) {
// if (cl.exists ("clone"))
// workMode = anna::comm::Communicator::WorkMode::Clone;
a_communicator = new MyCommunicator(workMode);
// if (cl.exists ("clone"))
// workMode = anna::comm::Communicator::WorkMode::Clone;
a_communicator = new MyCommunicator(workMode);
- a_timeEngine = new anna::timex::Engine((anna::Millisecond)600000, (anna::Millisecond)150);
+ //a_timeEngine = new anna::timex::Engine((anna::Millisecond)600000, anna::timex::Engine::minResolution);
+ a_timeEngine = new anna::timex::Engine((anna::Millisecond)600000, (anna::Millisecond)100); // puedo bajar hasta 10
// Counters record procedure:
anna::Millisecond cntRecordPeriod = (anna::Millisecond)300000; // ms
// Counters record procedure:
anna::Millisecond cntRecordPeriod = (anna::Millisecond)300000; // ms
@@
-1096,6
+1097,7
@@
std::string Launcher::help() const throw() {
result += "\n has been logged)";
result += "\n [recvfe-ans-unknown] Reception from entity of an unknown answer (probably former [req2e-expired]";
result += "\n has been logged)";
result += "\n has been logged)";
result += "\n [recvfe-ans-unknown] Reception from entity of an unknown answer (probably former [req2e-expired]";
result += "\n has been logged)";
+ result += "\n [retry] Request retransmission";
result += "\n";
result += "\n-------------------------------------------------------------------------------------------- Load tests";
result += "\n";
result += "\n";
result += "\n-------------------------------------------------------------------------------------------- Load tests";
result += "\n";
@@
-1314,9
+1316,8
@@
void Launcher::eventOperation(const std::string &operation, std::string &respons
if(!entity) throw anna::RuntimeException("No entity configured to send the message", ANNA_FILE_LOCATION);
anna::diameter::comm::Message *msg = createCommMessage();
if(!entity) throw anna::RuntimeException("No entity configured to send the message", ANNA_FILE_LOCATION);
anna::diameter::comm::Message *msg = createCommMessage();
-//xxxxxxxxxxxxx
- msg->setRetries(4);
- msg->setOnExpiry(anna::diameter::comm::Message::OnExpiry::Retransmit);
+ //msg->setRetries(4);
+ //msg->setOnExpiry(anna::diameter::comm::Message::OnExpiry::Retransmit);
if((opType == "sendxml") || (opType == "sendxml2e")) {
codecMsg.loadXML(param1);
if((opType == "sendxml") || (opType == "sendxml2e")) {
codecMsg.loadXML(param1);