Index: webrtc/p2p/base/dtlstransportchannel.h |
diff --git a/webrtc/p2p/base/dtlstransportchannel.h b/webrtc/p2p/base/dtlstransportchannel.h |
deleted file mode 100644 |
index 12b94ce032e0e89440e5b179c5ef38ccf493c0b3..0000000000000000000000000000000000000000 |
--- a/webrtc/p2p/base/dtlstransportchannel.h |
+++ /dev/null |
@@ -1,242 +0,0 @@ |
-/* |
- * Copyright 2011 The WebRTC Project Authors. All rights reserved. |
- * |
- * Use of this source code is governed by a BSD-style license |
- * that can be found in the LICENSE file in the root of the source |
- * tree. An additional intellectual property rights grant can be found |
- * in the file PATENTS. All contributing project authors may |
- * be found in the AUTHORS file in the root of the source tree. |
- */ |
- |
-#ifndef WEBRTC_P2P_BASE_DTLSTRANSPORTCHANNEL_H_ |
-#define WEBRTC_P2P_BASE_DTLSTRANSPORTCHANNEL_H_ |
- |
-#include <memory> |
-#include <string> |
-#include <vector> |
- |
-#include "webrtc/p2p/base/dtlstransportinternal.h" |
-#include "webrtc/p2p/base/icetransportinternal.h" |
-#include "webrtc/rtc_base/buffer.h" |
-#include "webrtc/rtc_base/bufferqueue.h" |
-#include "webrtc/rtc_base/constructormagic.h" |
-#include "webrtc/rtc_base/sslstreamadapter.h" |
-#include "webrtc/rtc_base/stream.h" |
- |
-namespace rtc { |
-class PacketTransportInternal; |
-} |
- |
-namespace cricket { |
- |
-// A bridge between a packet-oriented/transport-type interface on |
-// the bottom and a StreamInterface on the top. |
-class StreamInterfaceChannel : public rtc::StreamInterface { |
- public: |
- explicit StreamInterfaceChannel(IceTransportInternal* ice_transport); |
- |
- // Push in a packet; this gets pulled out from Read(). |
- bool OnPacketReceived(const char* data, size_t size); |
- |
- // Implementations of StreamInterface |
- rtc::StreamState GetState() const override { return state_; } |
- void Close() override; |
- rtc::StreamResult Read(void* buffer, |
- size_t buffer_len, |
- size_t* read, |
- int* error) override; |
- rtc::StreamResult Write(const void* data, |
- size_t data_len, |
- size_t* written, |
- int* error) override; |
- |
- private: |
- IceTransportInternal* ice_transport_; // owned by DtlsTransport |
- rtc::StreamState state_; |
- rtc::BufferQueue packets_; |
- |
- RTC_DISALLOW_COPY_AND_ASSIGN(StreamInterfaceChannel); |
-}; |
- |
- |
-// This class provides a DTLS SSLStreamAdapter inside a TransportChannel-style |
-// packet-based interface, wrapping an existing TransportChannel instance |
-// (e.g a P2PTransportChannel) |
-// Here's the way this works: |
-// |
-// DtlsTransport { |
-// SSLStreamAdapter* dtls_ { |
-// StreamInterfaceChannel downward_ { |
-// IceTransportInternal* ice_transport_; |
-// } |
-// } |
-// } |
-// |
-// - Data which comes into DtlsTransport from the underlying |
-// ice_transport_ via OnReadPacket() is checked for whether it is DTLS |
-// or not, and if it is, is passed to DtlsTransport::HandleDtlsPacket, |
-// which pushes it into to downward_. dtls_ is listening for events on |
-// downward_, so it immediately calls downward_->Read(). |
-// |
-// - Data written to DtlsTransport is passed either to downward_ or directly |
-// to ice_transport_, depending on whether DTLS is negotiated and whether |
-// the flags include PF_SRTP_BYPASS |
-// |
-// - The SSLStreamAdapter writes to downward_->Write() which translates it |
-// into packet writes on ice_transport_. |
-class DtlsTransport : public DtlsTransportInternal { |
- public: |
- // |ice_transport| is the ICE transport this DTLS transport is wrapping. |
- // |
- // |crypto_options| are the options used for the DTLS handshake. This affects |
- // whether GCM crypto suites are negotiated. |
- explicit DtlsTransport(IceTransportInternal* ice_transport, |
- const rtc::CryptoOptions& crypto_options); |
- ~DtlsTransport() override; |
- |
- const rtc::CryptoOptions& crypto_options() const override { |
- return crypto_options_; |
- } |
- |
- DtlsTransportState dtls_state() const override { return dtls_state_; } |
- |
- const std::string& transport_name() const override { return transport_name_; } |
- |
- int component() const override { return component_; } |
- |
- // Returns false if no local certificate was set, or if the peer doesn't |
- // support DTLS. |
- bool IsDtlsActive() const override { return dtls_active_; } |
- |
- bool SetLocalCertificate( |
- const rtc::scoped_refptr<rtc::RTCCertificate>& certificate) override; |
- rtc::scoped_refptr<rtc::RTCCertificate> GetLocalCertificate() const override; |
- |
- bool SetRemoteFingerprint(const std::string& digest_alg, |
- const uint8_t* digest, |
- size_t digest_len) override; |
- |
- |
- // Called to send a packet (via DTLS, if turned on). |
- int SendPacket(const char* data, |
- size_t size, |
- const rtc::PacketOptions& options, |
- int flags) override; |
- |
- bool GetOption(rtc::Socket::Option opt, int* value) override { |
- return ice_transport_->GetOption(opt, value); |
- } |
- |
- virtual bool SetSslMaxProtocolVersion(rtc::SSLProtocolVersion version); |
- |
- // Find out which DTLS-SRTP cipher was negotiated |
- bool GetSrtpCryptoSuite(int* cipher) override; |
- |
- bool GetSslRole(rtc::SSLRole* role) const override; |
- bool SetSslRole(rtc::SSLRole role) override; |
- |
- // Find out which DTLS cipher was negotiated |
- bool GetSslCipherSuite(int* cipher) override; |
- |
- // Once DTLS has been established, this method retrieves the certificate in |
- // use by the remote peer, for use in external identity verification. |
- std::unique_ptr<rtc::SSLCertificate> GetRemoteSSLCertificate() const override; |
- |
- // Once DTLS has established (i.e., this ice_transport is writable), this |
- // method extracts the keys negotiated during the DTLS handshake, for use in |
- // external encryption. DTLS-SRTP uses this to extract the needed SRTP keys. |
- // See the SSLStreamAdapter documentation for info on the specific parameters. |
- bool ExportKeyingMaterial(const std::string& label, |
- const uint8_t* context, |
- size_t context_len, |
- bool use_context, |
- uint8_t* result, |
- size_t result_len) override { |
- return (dtls_.get()) ? dtls_->ExportKeyingMaterial(label, context, |
- context_len, |
- use_context, |
- result, result_len) |
- : false; |
- } |
- |
- IceTransportInternal* ice_transport() override { return ice_transport_; } |
- |
- // For informational purposes. Tells if the DTLS handshake has finished. |
- // This may be true even if writable() is false, if the remote fingerprint |
- // has not yet been verified. |
- bool IsDtlsConnected(); |
- |
- bool receiving() const override { return receiving_; } |
- |
- bool writable() const override { return writable_; } |
- |
- int GetError() override { return ice_transport_->GetError(); } |
- |
- int SetOption(rtc::Socket::Option opt, int value) override { |
- return ice_transport_->SetOption(opt, value); |
- } |
- |
- std::string ToString() const { |
- const char RECEIVING_ABBREV[2] = {'_', 'R'}; |
- const char WRITABLE_ABBREV[2] = {'_', 'W'}; |
- std::stringstream ss; |
- ss << "DtlsTransport[" << transport_name_ << "|" << component_ << "|" |
- << RECEIVING_ABBREV[receiving()] << WRITABLE_ABBREV[writable()] << "]"; |
- return ss.str(); |
- } |
- |
- private: |
- void OnWritableState(rtc::PacketTransportInternal* transport); |
- void OnReadPacket(rtc::PacketTransportInternal* transport, |
- const char* data, |
- size_t size, |
- const rtc::PacketTime& packet_time, |
- int flags); |
- void OnSentPacket(rtc::PacketTransportInternal* transport, |
- const rtc::SentPacket& sent_packet); |
- void OnReadyToSend(rtc::PacketTransportInternal* transport); |
- void OnReceivingState(rtc::PacketTransportInternal* transport); |
- void OnDtlsEvent(rtc::StreamInterface* stream_, int sig, int err); |
- bool SetupDtls(); |
- void MaybeStartDtls(); |
- bool HandleDtlsPacket(const char* data, size_t size); |
- void OnDtlsHandshakeError(rtc::SSLHandshakeError error); |
- void ConfigureHandshakeTimeout(); |
- |
- void set_receiving(bool receiving); |
- void set_writable(bool writable); |
- // Sets the DTLS state, signaling if necessary. |
- void set_dtls_state(DtlsTransportState state); |
- |
- std::string transport_name_; |
- int component_; |
- DtlsTransportState dtls_state_ = DTLS_TRANSPORT_NEW; |
- rtc::Thread* network_thread_; // Everything should occur on this thread. |
- // Underlying ice_transport, not owned by this class. |
- IceTransportInternal* const ice_transport_; |
- std::unique_ptr<rtc::SSLStreamAdapter> dtls_; // The DTLS stream |
- StreamInterfaceChannel* |
- downward_; // Wrapper for ice_transport_, owned by dtls_. |
- std::vector<int> srtp_ciphers_; // SRTP ciphers to use with DTLS. |
- bool dtls_active_ = false; |
- rtc::scoped_refptr<rtc::RTCCertificate> local_certificate_; |
- rtc::SSLRole ssl_role_; |
- rtc::SSLProtocolVersion ssl_max_version_; |
- rtc::CryptoOptions crypto_options_; |
- rtc::Buffer remote_fingerprint_value_; |
- std::string remote_fingerprint_algorithm_; |
- |
- // Cached DTLS ClientHello packet that was received before we started the |
- // DTLS handshake. This could happen if the hello was received before the |
- // ice transport became writable, or before a remote fingerprint was received. |
- rtc::Buffer cached_client_hello_; |
- |
- bool receiving_ = false; |
- bool writable_ = false; |
- |
- RTC_DISALLOW_COPY_AND_ASSIGN(DtlsTransport); |
-}; |
- |
-} // namespace cricket |
- |
-#endif // WEBRTC_P2P_BASE_DTLSTRANSPORTCHANNEL_H_ |