Added support for resetting the Engine's maxqueue and maxmsgrate after returning them in status.

git-svn-id: http://voip.null.ro/svn/yate@6500 acf43c95-373e-0410-b603-e72c3f656dc1
This commit is contained in:
paulc 2021-06-04 13:00:07 +00:00
parent d7acccc9bb
commit 71014c9de7
2 changed files with 8 additions and 0 deletions

View File

@ -562,6 +562,8 @@ bool EngineStatusHandler::received(Message &msg)
msg.retValue() << ",waiting=" << locks;
msg.retValue() << ",acceptcalls=" << lookup(Engine::accept(),Engine::getCallAcceptStates());
msg.retValue() << ",congestion=" << Engine::getCongestion();
if (msg.getBoolValue("reset",false))
Engine::self()->resetMax();
if (details) {
NamedIterator iter(Engine::runParams());
char sep = ';';

View File

@ -1599,6 +1599,12 @@ public:
inline void getStats(u_int64_t& enqueued, u_int64_t& dequeued, u_int64_t& dispatched, u_int64_t& queueMax)
{ m_dispatcher.getStats(enqueued,dequeued,dispatched,queueMax); }
/**
* Reset the high water mark of the stat counters
*/
inline void resetMax()
{ m_maxMsgRate = m_messageRate; m_dispatcher.m_queuedMax = m_dispatcher.messageCount(); }
/**
* Check if a plugin is currently loaded
* @param name Name of the plugin to check