|
|
|
@ -127,9 +127,11 @@ bool TagAnalogData::processFrame(const uint8_t* data, uint32_t len, uint32_t pee
|
|
|
|
else if (!fromUpstream)
|
|
|
|
else if (!fromUpstream)
|
|
|
|
LogInfoEx(LOG_MASTER, CALL_END_LOG);
|
|
|
|
LogInfoEx(LOG_MASTER, CALL_END_LOG);
|
|
|
|
|
|
|
|
|
|
|
|
m_network->m_totalActiveCalls--;
|
|
|
|
if (!tg.config().parrot()) {
|
|
|
|
if (m_network->m_totalActiveCalls < 0)
|
|
|
|
m_network->m_totalActiveCalls--;
|
|
|
|
m_network->m_totalActiveCalls = 0;
|
|
|
|
if (m_network->m_totalActiveCalls < 0)
|
|
|
|
|
|
|
|
m_network->m_totalActiveCalls = 0;
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
// report call event to InfluxDB
|
|
|
|
// report call event to InfluxDB
|
|
|
|
if (m_network->m_enableInfluxDB) {
|
|
|
|
if (m_network->m_enableInfluxDB) {
|
|
|
|
@ -269,8 +271,10 @@ bool TagAnalogData::processFrame(const uint8_t* data, uint32_t len, uint32_t pee
|
|
|
|
m_status[dstId].activeCall = true;
|
|
|
|
m_status[dstId].activeCall = true;
|
|
|
|
m_status.unlock();
|
|
|
|
m_status.unlock();
|
|
|
|
|
|
|
|
|
|
|
|
m_network->m_totalCallsProcessed++;
|
|
|
|
if (!tg.config().parrot()) {
|
|
|
|
m_network->m_totalActiveCalls++;
|
|
|
|
m_network->m_totalCallsProcessed++;
|
|
|
|
|
|
|
|
m_network->m_totalActiveCalls++;
|
|
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
#define CALL_START_LOG "Analog, Call Start, peer = %u, ssrc = %u, srcId = %u, dstId = %u, streamId = %u, fromUpstream = %u", peerId, ssrc, srcId, dstId, streamId, fromUpstream
|
|
|
|
#define CALL_START_LOG "Analog, Call Start, peer = %u, ssrc = %u, srcId = %u, dstId = %u, streamId = %u, fromUpstream = %u", peerId, ssrc, srcId, dstId, streamId, fromUpstream
|
|
|
|
if (m_network->m_logUpstreamCallStartEnd && fromUpstream)
|
|
|
|
if (m_network->m_logUpstreamCallStartEnd && fromUpstream)
|
|
|
|
|