retronetworking
/
yate
12
0
Fork 2
Code Issues Pull Requests Projects Releases Wiki Activity

Compute and log how long took to complete a MGCP transaction. 

git-svn-id: http://voip.null.ro/svn/yate@4434 acf43c95-373e-0410-b603-e72c3f656dc1
This commit is contained in:
paulc 2011-06-03 16:57:03 +00:00
parent 680d700568
commit 542e4d9056
1 changed files with 34 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

46
modules/server/mgcpca.cpp
View File

@ -717,11 +717,13 @@ void MGCPWrapper::addParams(MGCPMessage* mm)
// Send a MGCP message, wait for an answer and return it
RefPointer<MGCPMessage> MGCPWrapper::sendSync(MGCPMessage* mm, const SocketAddr& address)
{
u_int64_t t1 = Time::msecNow();
while (m_msg) {
if (Thread::check(false))
return 0;
Thread::idle();
}
u_int64_t t2 = Time::msecNow();
MGCPTransaction* tr = s_engine->sendCommand(mm,address);
tr->userData(static_cast<GenObject*>(this));
m_tr = tr;
@ -729,13 +731,22 @@ RefPointer<MGCPMessage> MGCPWrapper::sendSync(MGCPMessage* mm, const SocketAddr&
Thread::idle();
RefPointer<MGCPMessage> tmp = m_msg;
m_msg = 0;
u_int64_t t3 = Time::msecNow();
if (!tmp)
Debug(&splugin,DebugMild,"MGCPWrapper::sendSync() returning NULL [%p]",this);
#ifdef DEBUG
else
Debug(&splugin,DebugInfo,"MGCPWrapper::sendSync() returning %d '%s' [%p]",
tmp->code(),tmp->comment().c_str(),this);
#endif
Debug(&splugin,DebugMild,"MGCPWrapper::sendSync() returning NULL in %u+%u ms [%p]",
(unsigned int)(t2-t1),(unsigned int)(t3-t2),this);
else {
int level = DebugAll;
if (t3-t1 > 500)
level = DebugMild;
else if (t3-t1 > 350)
level = DebugNote;
else if (t3-t1 > 200)
level = DebugInfo;
Debug(&splugin,level,"MGCPWrapper::sendSync() returning %d '%s' in %u+%u ms [%p]",
tmp->code(),tmp->comment().c_str(),
(unsigned int)(t2-t1),(unsigned int)(t3-t2),this);
}
return tmp;
}
@ -1509,11 +1520,13 @@ RefPointer<MGCPMessage> MGCPCircuit::sendSync(MGCPMessage* mm)
TelEngine::destruct(mm);
return 0;
}
u_int64_t t1 = Time::msecNow();
while (m_msg) {
if (Thread::check(false))
return 0;
Thread::idle();
}
u_int64_t t2 = Time::msecNow();
MGCPTransaction* tr = s_engine->sendCommand(mm,ep->address);
tr->userData(static_cast<GenObject*>(this));
m_tr = tr;
@ -1521,13 +1534,22 @@ RefPointer<MGCPMessage> MGCPCircuit::sendSync(MGCPMessage* mm)
Thread::idle();
RefPointer<MGCPMessage> tmp = m_msg;
m_msg = 0;
u_int64_t t3 = Time::msecNow();
if (!tmp)
Debug(&splugin,DebugMild,"MGCPCircuit::sendSync() returning NULL [%p]",this);
#ifdef DEBUG
else
Debug(&splugin,DebugInfo,"MGCPCircuit::sendSync() returning %d '%s' [%p]",
tmp->code(),tmp->comment().c_str(),this);
#endif
Debug(&splugin,DebugMild,"MGCPCircuit::sendSync() returning NULL in %u+%u ms [%p]",
(unsigned int)(t2-t1),(unsigned int)(t3-t2),this);
else {
int level = DebugAll;
if (t3-t1 > 500)
level = DebugMild;
else if (t3-t1 > 350)
level = DebugNote;
else if (t3-t1 > 200)
level = DebugInfo;
Debug(&splugin,level,"MGCPCircuit::sendSync() returning %d '%s' in %u+%u ms [%p]",
tmp->code(),tmp->comment().c_str(),
(unsigned int)(t2-t1),(unsigned int)(t3-t2),this);
}
return tmp;
}