summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorHenri Herscher <henri@oreka.org>2008-06-13 16:24:18 +0000
committerHenri Herscher <henri@oreka.org>2008-06-13 16:24:18 +0000
commit70e68d786574bc217c30e44e02fd6b11898e2acf (patch)
treeeed01083a01bc2d881180df0360b77874c59a211
parent2617fbea5ba138b69a68f832ff6146274e580f2c (diff)
RTP stream start and expiry logging now includes host timestamps.
git-svn-id: https://oreka.svn.sourceforge.net/svnroot/oreka/trunk@547 09dcff7a-b715-0410-9601-b79a96267cd0
-rw-r--r--orkaudio/audiocaptureplugins/voip/Rtp.cpp4
-rw-r--r--orkaudio/audiocaptureplugins/voip/RtpSession.cpp7
2 files changed, 8 insertions, 3 deletions
diff --git a/orkaudio/audiocaptureplugins/voip/Rtp.cpp b/orkaudio/audiocaptureplugins/voip/Rtp.cpp
index a35e519..61b93f1 100644
--- a/orkaudio/audiocaptureplugins/voip/Rtp.cpp
+++ b/orkaudio/audiocaptureplugins/voip/Rtp.cpp
@@ -38,7 +38,9 @@ void RtpPacketInfo::ToString(CStdString& string)
ACE_OS::inet_ntop(AF_INET, (void*)&m_sourceIp, sourceIp, sizeof(sourceIp));
char destIp[16];
ACE_OS::inet_ntop(AF_INET, (void*)&m_destIp, destIp, sizeof(destIp));
- string.Format("%s,%d %s,%d seq:%u ts:%u len:%d type:%d", sourceIp, m_sourcePort, destIp, m_destPort, m_seqNum, m_timestamp, m_payloadSize, m_payloadType);
+ string.Format("%s,%d %s,%d seq:%u ts:%u len:%d type:%d ats:%u",
+ sourceIp, m_sourcePort, destIp, m_destPort, m_seqNum,
+ m_timestamp, m_payloadSize, m_payloadType, m_arrivalTimestamp);
}
void RtpEventInfo::ToString(CStdString& string)
diff --git a/orkaudio/audiocaptureplugins/voip/RtpSession.cpp b/orkaudio/audiocaptureplugins/voip/RtpSession.cpp
index e1309dd..208e161 100644
--- a/orkaudio/audiocaptureplugins/voip/RtpSession.cpp
+++ b/orkaudio/audiocaptureplugins/voip/RtpSession.cpp
@@ -2014,7 +2014,9 @@ void RtpSessions::Hoover(time_t now)
for (std::list<RtpSessionRef>::iterator it = toDismiss.begin(); it != toDismiss.end() ; it++)
{
RtpSessionRef session = *it;
- LOG4CXX_INFO(m_log, "[" + session->m_trackingId + "] " + session->m_ipAndPort + " Expired");
+ CStdString logMsg;
+ logMsg.Format("[%s] %s Expired (RTP) ts:%u", session->m_trackingId, session->m_ipAndPort, session->m_lastUpdated);
+ LOG4CXX_INFO(m_log, logMsg);
Stop(session);
}
@@ -2054,7 +2056,8 @@ void RtpSessions::Hoover(time_t now)
for (std::list<RtpSessionRef>::iterator it2 = toDismiss.begin(); it2 != toDismiss.end() ; it2++)
{
RtpSessionRef session = *it2;
- LOG4CXX_INFO(m_log, "[" + session->m_trackingId + "] " + session->m_ipAndPort + " Expired");
+ CStdString logMsg;
+ logMsg.Format("[%s] %s Expired (CallID) ts:%u", session->m_trackingId, session->m_ipAndPort, session->m_lastUpdated);
Stop(session);
}
}