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
|
/**
* @file stream.h GNU ZRTP: Stream class
*
* Copyright (C) 2010 - 2017 Creytiv.com
*/
#ifndef __STREAM_H
#define __STREAM_H
#include <libzrtpcpp/ZRtp.h>
enum StreamMediaType {
MT_UNKNOWN = 0,
MT_AUDIO,
MT_VIDEO,
MT_TEXT,
MT_APPLICATION,
MT_MESSAGE
};
class ZRTPConfig {
public:
ZRTPConfig(const struct conf *conf, const char *conf_dir);
private:
friend class Stream;
friend class Session;
ZrtpConfigure zrtp;
char client_id[CLIENT_ID_SIZE + 1];
char zid_filename[256];
bool start_parallel;
};
class Stream;
class SRTPStat {
public:
SRTPStat(const Stream *st, bool srtcp, uint64_t threshold);
void update(int ret_code, bool quiet = false);
void reset();
uint64_t ok() { return m_ok; }
private:
const Stream *m_stream;
const bool m_control;
const uint64_t m_threshold;
uint64_t m_ok, m_decode, m_auth, m_replay;
uint64_t m_decode_burst, m_auth_burst, m_replay_burst;
};
class Session;
class Srtp;
class Stream : public ZrtpCallback {
public:
Stream(int& err, const ZRTPConfig& config, Session *session,
udp_sock *rtpsock, udp_sock *rtcpsock,
uint32_t local_ssrc, StreamMediaType media_type);
virtual ~Stream();
int start(Stream *master);
void stop();
bool started() { return m_started; }
int sdp_encode(struct sdp_media *sdpm);
int sdp_decode(const struct sdp_media *sdpm);
const char *media_name() const;
const char *get_sas() const { return m_sas.c_str(); }
const char *get_ciphers() const { return m_ciphers.c_str(); }
bool sas_verified();
void verify_sas(bool verify);
private:
static void zrtp_timer_cb(void *arg);
static bool udp_helper_send_cb(int *err, struct sa *src,
struct mbuf *mb, void *arg);
static bool udp_helper_recv_cb(struct sa *src, struct mbuf *mb,
void *arg);
bool udp_helper_send(int *err, struct sa *src, struct mbuf *mb);
bool udp_helper_recv(struct sa *src, struct mbuf *mb);
bool recv_zrtp(struct mbuf *mb);
void print_message(GnuZrtpCodes::MessageSeverity severity,
int32_t subcode);
Session *m_session;
ZRtp *m_zrtp;
bool m_started;
struct tmr m_zrtp_timer;
pthread_mutex_t m_zrtp_mutex;
uint16_t m_zrtp_seq;
uint32_t m_local_ssrc, m_peer_ssrc;
struct sa m_raddr;
struct udp_sock *m_rtpsock, *m_rtcpsock;
struct udp_helper *m_uh_rtp;
struct udp_helper *m_uh_rtcp;
StreamMediaType m_media_type;
Srtp *m_send_srtp, *m_recv_srtp;
pthread_mutex_t m_send_mutex;
SRTPStat m_srtp_stat, m_srtcp_stat;
std::string m_sas, m_ciphers;
protected:
virtual int32_t sendDataZRTP(const uint8_t* data, int32_t length);
virtual int32_t activateTimer(int32_t time);
virtual int32_t cancelTimer();
virtual void sendInfo(GnuZrtpCodes::MessageSeverity severity,
int32_t subCode);
virtual bool srtpSecretsReady(SrtpSecret_t* secrets,
EnableSecurity part);
virtual void srtpSecretsOff(EnableSecurity part);
virtual void srtpSecretsOn(std::string c, std::string s,
bool verified);
virtual void handleGoClear();
virtual void zrtpNegotiationFailed(
GnuZrtpCodes::MessageSeverity severity,
int32_t subCode);
virtual void zrtpNotSuppOther();
virtual void synchEnter();
virtual void synchLeave();
virtual void zrtpAskEnrollment(GnuZrtpCodes::InfoEnrollment info);
virtual void zrtpInformEnrollment(GnuZrtpCodes::InfoEnrollment info);
virtual void signSAS(uint8_t* sasHash);
virtual bool checkSASSignature(uint8_t* sasHash);
};
#endif // __STREAM_H
|
