| Index: webrtc/pc/srtpfilter.h
|
| diff --git a/webrtc/pc/srtpfilter.h b/webrtc/pc/srtpfilter.h
|
| index 15fdae9582a4019e8fb52534d576516385eeba28..619aaa37d56a7465509600ba978e0451d99f279e 100644
|
| --- a/webrtc/pc/srtpfilter.h
|
| +++ b/webrtc/pc/srtpfilter.h
|
| @@ -20,8 +20,10 @@
|
| #include "webrtc/media/base/cryptoparams.h"
|
| #include "webrtc/p2p/base/sessiondescription.h"
|
| #include "webrtc/rtc_base/basictypes.h"
|
| +#include "webrtc/rtc_base/buffer.h"
|
| #include "webrtc/rtc_base/constructormagic.h"
|
| #include "webrtc/rtc_base/criticalsection.h"
|
| +#include "webrtc/rtc_base/optional.h"
|
| #include "webrtc/rtc_base/sslstreamadapter.h"
|
| #include "webrtc/rtc_base/thread_checker.h"
|
|
|
| @@ -31,15 +33,10 @@ struct srtp_ctx_t_;
|
|
|
| namespace cricket {
|
|
|
| -class SrtpSession;
|
| -
|
| void ShutdownSrtp();
|
|
|
| -// Class to transform SRTP to/from RTP.
|
| -// Initialize by calling SetSend with the local security params, then call
|
| -// SetRecv once the remote security params are received. At that point
|
| -// Protect/UnprotectRt(c)p can be called to encrypt/decrypt data.
|
| -// TODO: Figure out concurrency policy for SrtpFilter.
|
| +// A helper class used to negotiate SDES crypto params.
|
| +// TODO(zhihuang): Find a better name for this class, like "SdesNegotiator".
|
| class SrtpFilter {
|
| public:
|
| enum Mode {
|
| @@ -76,85 +73,38 @@ class SrtpFilter {
|
| bool SetAnswer(const std::vector<CryptoParams>& answer_params,
|
| ContentSource source);
|
|
|
| - // Set the header extension ids that should be encrypted for the given source.
|
| - void SetEncryptedHeaderExtensionIds(ContentSource source,
|
| - const std::vector<int>& extension_ids);
|
| -
|
| - // Just set up both sets of keys directly.
|
| - // Used with DTLS-SRTP.
|
| - bool SetRtpParams(int send_cs,
|
| - const uint8_t* send_key,
|
| - int send_key_len,
|
| - int recv_cs,
|
| - const uint8_t* recv_key,
|
| - int recv_key_len);
|
| - bool UpdateRtpParams(int send_cs,
|
| - const uint8_t* send_key,
|
| - int send_key_len,
|
| - int recv_cs,
|
| - const uint8_t* recv_key,
|
| - int recv_key_len);
|
| - bool SetRtcpParams(int send_cs,
|
| - const uint8_t* send_key,
|
| - int send_key_len,
|
| - int recv_cs,
|
| - const uint8_t* recv_key,
|
| - int recv_key_len);
|
| -
|
| - // Encrypts/signs an individual RTP/RTCP packet, in-place.
|
| - // If an HMAC is used, this will increase the packet size.
|
| - bool ProtectRtp(void* data, int in_len, int max_len, int* out_len);
|
| - // Overloaded version, outputs packet index.
|
| - bool ProtectRtp(void* data,
|
| - int in_len,
|
| - int max_len,
|
| - int* out_len,
|
| - int64_t* index);
|
| - bool ProtectRtcp(void* data, int in_len, int max_len, int* out_len);
|
| - // Decrypts/verifies an invidiual RTP/RTCP packet.
|
| - // If an HMAC is used, this will decrease the packet size.
|
| - bool UnprotectRtp(void* data, int in_len, int* out_len);
|
| - bool UnprotectRtcp(void* data, int in_len, int* out_len);
|
| -
|
| - // Returns rtp auth params from srtp context.
|
| - bool GetRtpAuthParams(uint8_t** key, int* key_len, int* tag_len);
|
| -
|
| - // Returns srtp overhead for rtp packets.
|
| - bool GetSrtpOverhead(int* srtp_overhead) const;
|
| -
|
| - // If external auth is enabled, SRTP will write a dummy auth tag that then
|
| - // later must get replaced before the packet is sent out. Only supported for
|
| - // non-GCM cipher suites and can be checked through "IsExternalAuthActive"
|
| - // if it is actually used. This method is only valid before the RTP params
|
| - // have been set.
|
| - void EnableExternalAuth();
|
| - bool IsExternalAuthEnabled() const;
|
| -
|
| - // A SRTP filter supports external creation of the auth tag if a non-GCM
|
| - // cipher is used. This method is only valid after the RTP params have
|
| - // been set.
|
| - bool IsExternalAuthActive() const;
|
| -
|
| bool ResetParams();
|
|
|
| + rtc::Optional<int> send_cipher_suite() { return send_cipher_suite_; }
|
| + rtc::Optional<int> recv_cipher_suite() { return recv_cipher_suite_; }
|
| +
|
| + const rtc::Buffer& send_key() { return send_key_; }
|
| + const rtc::Buffer& recv_key() { return recv_key_; }
|
| +
|
| protected:
|
| bool ExpectOffer(ContentSource source);
|
| +
|
| bool StoreParams(const std::vector<CryptoParams>& params,
|
| ContentSource source);
|
| +
|
| bool ExpectAnswer(ContentSource source);
|
| +
|
| bool DoSetAnswer(const std::vector<CryptoParams>& answer_params,
|
| - ContentSource source,
|
| - bool final);
|
| - void CreateSrtpSessions();
|
| + ContentSource source,
|
| + bool final);
|
| +
|
| bool NegotiateParams(const std::vector<CryptoParams>& answer_params,
|
| CryptoParams* selected_params);
|
| - bool ApplyParams(const CryptoParams& send_params,
|
| - const CryptoParams& recv_params);
|
| +
|
| + private:
|
| + bool ApplySendParams(const CryptoParams& send_params);
|
| +
|
| + bool ApplyRecvParams(const CryptoParams& recv_params);
|
| +
|
| static bool ParseKeyParams(const std::string& params,
|
| uint8_t* key,
|
| size_t len);
|
|
|
| - private:
|
| enum State {
|
| ST_INIT, // SRTP filter unused.
|
| ST_SENTOFFER, // Offer with SRTP parameters sent.
|
| @@ -179,16 +129,13 @@ class SrtpFilter {
|
| ST_RECEIVEDPRANSWER
|
| };
|
| State state_ = ST_INIT;
|
| - bool external_auth_enabled_ = false;
|
| std::vector<CryptoParams> offer_params_;
|
| - std::unique_ptr<SrtpSession> send_session_;
|
| - std::unique_ptr<SrtpSession> recv_session_;
|
| - std::unique_ptr<SrtpSession> send_rtcp_session_;
|
| - std::unique_ptr<SrtpSession> recv_rtcp_session_;
|
| CryptoParams applied_send_params_;
|
| CryptoParams applied_recv_params_;
|
| - std::vector<int> send_encrypted_header_extension_ids_;
|
| - std::vector<int> recv_encrypted_header_extension_ids_;
|
| + rtc::Optional<int> send_cipher_suite_;
|
| + rtc::Optional<int> recv_cipher_suite_;
|
| + rtc::Buffer send_key_;
|
| + rtc::Buffer recv_key_;
|
| };
|
|
|
| } // namespace cricket
|
|
|