1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
|
/*
* 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 <log4cxx/logger.h>
#include "RtpSession.h"
#include "Rtp.h"
#include <map>
#include "ace/Singleton.h"
#include "PacketHeaderDefs.h"
using namespace log4cxx;
class SipInviteInfo
{
public:
SipInviteInfo();
void ToString(CStdString& string);
struct in_addr m_senderIp;
struct in_addr m_receiverIp;
struct in_addr m_fromRtpIp;
char m_senderMac[6];
char m_receiverMac[6];
CStdString m_fromRtpPort;
CStdString m_from;
CStdString m_to;
CStdString m_callId;
bool m_validated; // true when an RTP stream has been seen for the INVITE
std::map<CStdString, CStdString> m_extractedFields;
};
typedef boost::shared_ptr<SipInviteInfo> SipInviteInfoRef;
class SipByeInfo
{
public:
CStdString m_callId;
};
//=============================================================
class EndpointInfo
{
public:
CStdString m_extension;
};
typedef boost::shared_ptr<EndpointInfo> EndpointInfoRef;
// ============================================================
class RtpSession
{
public:
#define PROT_RAW_RTP "RawRtp"
#define PROT_SIP "Sip"
#define PROT_SKINNY "Skinny"
#define PROT_UNKN "Unkn"
typedef enum{ProtRawRtp, ProtSip, ProtSkinny, ProtUnkn} ProtocolEnum;
static int ProtocolToEnum(CStdString& protocol);
static CStdString ProtocolToString(int protocolEnum);
RtpSession(CStdString& trackingId);
void Stop();
void Start();
bool AddRtpPacket(RtpPacketInfoRef& rtpPacket);
void ReportSipInvite(SipInviteInfoRef& invite);
CStdString m_trackingId;
CStdString m_ipAndPort; // IP address and TCP port of one side of the session, serves as a key for session storage and retrieval. Not necessarily the same as the capturePort (capturePort is usually the client (phone) IP+port)
CStdString m_callId;
SipInviteInfoRef m_invite;
time_t m_lastUpdated;
ProtocolEnum m_protocol;
CStdString m_localParty;
CStdString m_remoteParty;
CaptureEvent::DirectionEnum m_direction;
int m_numRtpPackets;
struct in_addr m_endPointIp; // only used for Skinny
bool m_onHold;
private:
void ProcessMetadataSip(RtpPacketInfoRef&);
void ProcessMetadataSipIncoming();
void ProcessMetadataSipOutgoing();
void UpdateMetadataSip(RtpPacketInfoRef& rtpPacket, bool);
void ProcessMetadataRawRtp(RtpPacketInfoRef&);
void ProcessMetadataSkinny(RtpPacketInfoRef& rtpPacket);
void ReportMetadata();
void GenerateOrkUid();
RtpPacketInfoRef m_lastRtpPacket;
RtpPacketInfoRef m_lastRtpPacketSide1;
RtpPacketInfoRef m_lastRtpPacketSide2;
//RtpRingBuffer m_rtpRingBuffer;
struct in_addr m_invitorIp;
int m_invitorTcpPort;
struct in_addr m_inviteeIp;
int m_inviteeTcpPort;
char m_invitorMac[6];
char m_inviteeMac[6];
struct in_addr m_localIp;
struct in_addr m_remoteIp;
char m_localMac[6];
char m_remoteMac[6];
//struct in_addr m_localMac;
//struct in_addr m_remoteMac;
LoggerPtr m_log;
CStdString m_capturePort;
bool m_started;
bool m_stopped;
time_t m_beginDate;
CStdString m_orkUid;
bool m_hasDuplicateRtp;
unsigned int m_highestRtpSeqNumDelta;
double m_minRtpSeqDelta;
double m_minRtpTimestampDelta;
TcpAddressList m_rtpAddressList;
std::list<SipInviteInfoRef> m_invites;
std::map<CStdString, CStdString> m_tags;
};
typedef boost::shared_ptr<RtpSession> RtpSessionRef;
//===================================================================
class RtpSessions
{
public:
RtpSessions();
void Stop(RtpSessionRef& session);
void StopAll();
void ReportSipInvite(SipInviteInfoRef& invite);
void ReportSipBye(SipByeInfo bye);
void ReportSkinnyCallInfo(SkCallInfoStruct*, IpHeaderStruct* ipHeader);
void ReportSkinnyStartMediaTransmission(SkStartMediaTransmissionStruct*, IpHeaderStruct* ipHeader);
void ReportSkinnyStopMediaTransmission(SkStopMediaTransmissionStruct*, IpHeaderStruct* ipHeader);
void ReportSkinnyOpenReceiveChannelAck(SkOpenReceiveChannelAckStruct*);
void ReportSkinnyLineStat(SkLineStatStruct*, IpHeaderStruct* ipHeader);
void ReportSkinnySoftKeyHold(SkSoftKeyEventMessageStruct* skEvent, IpHeaderStruct* ipHeader);
void ReportSkinnySoftKeyResume(SkSoftKeyEventMessageStruct* skEvent, IpHeaderStruct* ipHeader);
void ReportRtpPacket(RtpPacketInfoRef& rtpPacket);
void Hoover(time_t now);
EndpointInfoRef GetEndpointInfo(struct in_addr endpointIp);
private:
RtpSessionRef findByEndpointIp(struct in_addr);
RtpSessionRef findByEndpointIpUsingIpAndPort(struct in_addr endpointIpAddr);
bool ChangeCallId(RtpSessionRef& session, unsigned int newId);
void SetMediaAddress(RtpSessionRef& session, struct in_addr mediaIp, unsigned short mediaPort);
CStdString GenerateSkinnyCallId(struct in_addr endpointIp, unsigned int callId);
std::map<CStdString, RtpSessionRef> m_byIpAndPort;
std::map<CStdString, RtpSessionRef> m_byCallId;
std::map<unsigned int, EndpointInfoRef> m_endpoints;
LoggerPtr m_log;
AlphaCounter m_alphaCounter;
};
typedef ACE_Singleton<RtpSessions, ACE_Thread_Mutex> RtpSessionsSingleton;
#endif
|
