1 files changed, 101 insertions, 0 deletions
diff --git a/orkaudio/audiocaptureplugins/voip/RtpSession.h b/orkaudio/audiocaptureplugins/voip/RtpSession.h
new file mode 100644
index 0000000..f804721
--- /dev/null
+++ b/orkaudio/audiocaptureplugins/voip/RtpSession.h
@@ -0,0 +1,101 @@
+/*
+ * Oreka -- A media capture and retrieval platform
+ * 
+ * Copyright (C) 2005, orecx LLC
+ *
+ * http://www.orecx.com
+ *
+ * This program is free software, distributed under the terms of
+ * the GNU General Public License.
+ * Please refer to http://www.gnu.org/copyleft/gpl.html
+ *
+ */
+
+#ifndef __RTPSESSION_H__
+#define __RTPSESSION_H__
+
+#include "RtpSession.h"
+#include "Rtp.h"
+#include <map>
+#include "ace/Singleton.h"
+
+class SipInviteInfo
+{
+public:
+	struct in_addr m_fromIp;
+	CStdString m_fromRtpPort;
+	CStdString m_from;
+	CStdString m_to;
+	CStdString m_callId;
+};
+typedef boost::shared_ptr<SipInviteInfo> SipInviteInfoRef;
+
+class SipByeInfo
+{
+public:
+	CStdString m_callId;
+};
+
+
+class RtpSession
+{
+public:
+#define PROT_RAW_RTP "RawRtp"
+#define PROT_SIP "Sip"
+#define PROT_UNKN "Unkn"
+	typedef enum{ProtRawRtp, ProtSip, ProtUnkn} ProtocolEnum;
+	static int ProtocolToEnum(CStdString& protocol);
+	static CStdString ProtocolToString(int protocolEnum);
+
+	RtpSession();
+	void Stop();
+	void Start();
+	void AddRtpPacket(RtpPacketInfoRef& rtpPacket);
+	void ReportSipInvite(SipInviteInfoRef& invite);
+
+	CStdString m_ipAndPort;
+	SipInviteInfoRef m_invite;
+	time_t m_lastUpdated;
+	ProtocolEnum m_protocol;
+private:
+	void ProcessMetadataSip(RtpPacketInfoRef&);
+	void ProcessMetadataSipIncoming();
+	void ProcessMetadataSipOutgoing();
+	void ProcessMetadataRawRtp(RtpPacketInfoRef&);
+	void ReportMetadata();
+
+	RtpPacketInfoRef m_lastRtpPacket;
+	int m_numRtpPackets;
+	RtpRingBuffer m_rtpRingBuffer;
+	struct in_addr m_invitorIp;
+	int m_invitorTcpPort;
+	struct in_addr m_inviteeIp;
+	int m_inviteeTcpPort;
+	LoggerPtr m_log;
+	CStdString m_capturePort;
+	CStdString m_localParty;
+	CStdString m_remoteParty;
+	CaptureEvent::DirectionEnum m_direction;
+	bool m_started;
+};
+typedef boost::shared_ptr<RtpSession> RtpSessionRef;
+
+class RtpSessions
+{
+public:
+	RtpSessions();
+	void Create(CStdString& ipAndPort);
+	void Stop(RtpSessionRef& session);
+	void ReportSipInvite(SipInviteInfoRef& invite);
+	void ReportSipBye(SipByeInfo bye);
+	void ReportRtpPacket(RtpPacketInfoRef& rtpPacket);
+	void Hoover(time_t now);
+private:
+	std::map<CStdString, RtpSessionRef> m_byIpAndPort;
+	std::map<CStdString, RtpSessionRef> m_byCallId;
+	LoggerPtr m_log;
+};
+typedef ACE_Singleton<RtpSessions, ACE_Thread_Mutex> RtpSessionsSingleton;
+
+#endif
+