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

Added sniffer option to deiplay only messages with age or delay higher than a certain value. 

git-svn-id: http://yate.null.ro/svn/yate/trunk@6466 acf43c95-373e-0410-b603-e72c3f656dc1
This commit is contained in:
paulc 2021-03-15 13:05:28 +00:00
parent 6097706c14
commit d23ac38dbc
2 changed files with 23 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
conf.d/yate.conf.sample
View File

@ -112,6 +112,9 @@
; filtersniff=^\(chan\.\|engine\.halt$\)
;filtersniff=
; agesniff: float: Display only messages whose age or delay is higher than this value
;agesniff=0
[modules]
; This section should hold one line for each module whose loading behaviour

23
modules/msgsniff.cpp
View File

@ -22,6 +22,7 @@
#include <yatengine.h>
#include <stdio.h>
#include <math.h>
using namespace TelEngine;
namespace { // anonymous
@ -38,6 +39,7 @@ static const char* s_debugs[] =
"no",
"filter",
"timer",
"age",
0
};
@ -66,6 +68,7 @@ public:
static bool s_active = true;
static bool s_timer = false;
static u_int64_t s_minAge = 0;
static Regexp s_filter;
static Mutex s_mutex(false,"FilterSniff");
@ -109,11 +112,16 @@ bool SniffHandler::received(Message &msg)
s_filter = line;
s_mutex.unlock();
}
if (line.startSkip("age"))
s_minAge = (u_int64_t)(1000000.0 * fabs(line.toDouble()));
msg.retValue() << "Message sniffer: " << (s_active ? "on" : "off");
if (s_active)
msg.retValue() << ", timer: " << (s_timer ? "on" : "off");
if (s_active && s_filter)
msg.retValue() << ", filter: " << s_filter;
if (s_active && s_minAge)
msg.retValue() << ", age: " << String().printf("%u.%06u",
(unsigned int)(s_minAge / 1000000),(unsigned int)(s_minAge % 1000000));
msg.retValue() << "\r\n";
return true;
}
@ -135,12 +143,18 @@ bool SniffHandler::received(Message &msg)
if (s_filter && !s_filter.matches(msg))
return false;
lock.drop();
u_int64_t mt = msg.msgTime().usec();
u_int64_t dt = Time::now() - mt;
if (s_minAge && (dt < s_minAge))
return false;
String par;
dumpParams(msg,par);
Output("Sniffed '%s' time=%u.%06u%s\r\n thread=%p '%s'\r\n data=%p\r\n retval='%s'%s",
Output("Sniffed '%s' time=%u.%06u age=%u.%06u%s\r\n thread=%p '%s'\r\n data=%p\r\n retval='%s'%s",
msg.c_str(),
(unsigned int)(msg.msgTime().usec() / 1000000),
(unsigned int)(msg.msgTime().usec() % 1000000),
(unsigned int)(mt / 1000000),
(unsigned int)(mt % 1000000),
(unsigned int)(dt / 1000000),
(unsigned int)(dt % 1000000),
(msg.broadcast() ? " (broadcast)" : ""),
Thread::current(),
Thread::currentName(),
@ -160,6 +174,8 @@ void HookHandler::dispatched(const Message& msg, bool handled)
return;
lock.drop();
u_int64_t dt = Time::now() - msg.msgTime().usec();
if (s_minAge && (dt < s_minAge))
return;
String par;
dumpParams(msg,par);
const char* rval = msg.retValue().c_str();
@ -198,6 +214,7 @@ void MsgSniff::initialize()
s_mutex.lock();
s_filter = Engine::config().getValue("general","filtersniff");
s_mutex.unlock();
s_minAge = (u_int64_t)(1000000.0 * fabs(Engine::config().getDoubleValue("general","agesniff")));
Engine::install(new SniffHandler);
Engine::self()->setHook(new HookHandler);
}