Index: talk/session/media/channel.h |
diff --git a/talk/session/media/channel.h b/talk/session/media/channel.h |
deleted file mode 100644 |
index dfc0ce517dc5895df973fec07dbe199d942462aa..0000000000000000000000000000000000000000 |
--- a/talk/session/media/channel.h |
+++ /dev/null |
@@ -1,646 +0,0 @@ |
-/* |
- * libjingle |
- * Copyright 2004 Google Inc. |
- * |
- * Redistribution and use in source and binary forms, with or without |
- * modification, are permitted provided that the following conditions are met: |
- * |
- * 1. Redistributions of source code must retain the above copyright notice, |
- * this list of conditions and the following disclaimer. |
- * 2. Redistributions in binary form must reproduce the above copyright notice, |
- * this list of conditions and the following disclaimer in the documentation |
- * and/or other materials provided with the distribution. |
- * 3. The name of the author may not be used to endorse or promote products |
- * derived from this software without specific prior written permission. |
- * |
- * THIS SOFTWARE IS PROVIDED BY THE AUTHOR ``AS IS'' AND ANY EXPRESS OR IMPLIED |
- * WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES OF |
- * MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO |
- * EVENT SHALL THE AUTHOR BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, |
- * SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, |
- * PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; |
- * OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, |
- * WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR |
- * OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF |
- * ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. |
- */ |
- |
-#ifndef TALK_SESSION_MEDIA_CHANNEL_H_ |
-#define TALK_SESSION_MEDIA_CHANNEL_H_ |
- |
-#include <map> |
-#include <set> |
-#include <string> |
-#include <utility> |
-#include <vector> |
- |
-#include "talk/session/media/audiomonitor.h" |
-#include "talk/session/media/bundlefilter.h" |
-#include "talk/session/media/mediamonitor.h" |
-#include "talk/session/media/mediasession.h" |
-#include "talk/session/media/rtcpmuxfilter.h" |
-#include "talk/session/media/srtpfilter.h" |
-#include "webrtc/audio/audio_sink.h" |
-#include "webrtc/base/asyncudpsocket.h" |
-#include "webrtc/base/criticalsection.h" |
-#include "webrtc/base/network.h" |
-#include "webrtc/base/sigslot.h" |
-#include "webrtc/base/window.h" |
-#include "webrtc/media/base/mediachannel.h" |
-#include "webrtc/media/base/mediaengine.h" |
-#include "webrtc/media/base/streamparams.h" |
-#include "webrtc/media/base/videocapturer.h" |
-#include "webrtc/media/base/videosinkinterface.h" |
-#include "webrtc/p2p/base/transportcontroller.h" |
-#include "webrtc/p2p/client/socketmonitor.h" |
- |
-namespace webrtc { |
-class AudioSinkInterface; |
-} // namespace webrtc |
- |
-namespace cricket { |
- |
-struct CryptoParams; |
-class MediaContentDescription; |
- |
-enum SinkType { |
- SINK_PRE_CRYPTO, // Sink packets before encryption or after decryption. |
- SINK_POST_CRYPTO // Sink packets after encryption or before decryption. |
-}; |
- |
-// BaseChannel contains logic common to voice and video, including |
-// enable, marshaling calls to a worker thread, and |
-// connection and media monitors. |
-// |
-// WARNING! SUBCLASSES MUST CALL Deinit() IN THEIR DESTRUCTORS! |
-// This is required to avoid a data race between the destructor modifying the |
-// vtable, and the media channel's thread using BaseChannel as the |
-// NetworkInterface. |
- |
-class BaseChannel |
- : public rtc::MessageHandler, public sigslot::has_slots<>, |
- public MediaChannel::NetworkInterface, |
- public ConnectionStatsGetter { |
- public: |
- BaseChannel(rtc::Thread* thread, |
- MediaChannel* channel, |
- TransportController* transport_controller, |
- const std::string& content_name, |
- bool rtcp); |
- virtual ~BaseChannel(); |
- bool Init(); |
- // Deinit may be called multiple times and is simply ignored if it's alreay |
- // done. |
- void Deinit(); |
- |
- rtc::Thread* worker_thread() const { return worker_thread_; } |
- const std::string& content_name() const { return content_name_; } |
- const std::string& transport_name() const { return transport_name_; } |
- TransportChannel* transport_channel() const { |
- return transport_channel_; |
- } |
- TransportChannel* rtcp_transport_channel() const { |
- return rtcp_transport_channel_; |
- } |
- bool enabled() const { return enabled_; } |
- |
- // This function returns true if we are using SRTP. |
- bool secure() const { return srtp_filter_.IsActive(); } |
- // The following function returns true if we are using |
- // DTLS-based keying. If you turned off SRTP later, however |
- // you could have secure() == false and dtls_secure() == true. |
- bool secure_dtls() const { return dtls_keyed_; } |
- // This function returns true if we require secure channel for call setup. |
- bool secure_required() const { return secure_required_; } |
- |
- bool writable() const { return writable_; } |
- |
- // Activate RTCP mux, regardless of the state so far. Once |
- // activated, it can not be deactivated, and if the remote |
- // description doesn't support RTCP mux, setting the remote |
- // description will fail. |
- void ActivateRtcpMux(); |
- bool SetTransport(const std::string& transport_name); |
- bool PushdownLocalDescription(const SessionDescription* local_desc, |
- ContentAction action, |
- std::string* error_desc); |
- bool PushdownRemoteDescription(const SessionDescription* remote_desc, |
- ContentAction action, |
- std::string* error_desc); |
- // Channel control |
- bool SetLocalContent(const MediaContentDescription* content, |
- ContentAction action, |
- std::string* error_desc); |
- bool SetRemoteContent(const MediaContentDescription* content, |
- ContentAction action, |
- std::string* error_desc); |
- |
- bool Enable(bool enable); |
- |
- // Multiplexing |
- bool AddRecvStream(const StreamParams& sp); |
- bool RemoveRecvStream(uint32_t ssrc); |
- bool AddSendStream(const StreamParams& sp); |
- bool RemoveSendStream(uint32_t ssrc); |
- |
- // Monitoring |
- void StartConnectionMonitor(int cms); |
- void StopConnectionMonitor(); |
- // For ConnectionStatsGetter, used by ConnectionMonitor |
- bool GetConnectionStats(ConnectionInfos* infos) override; |
- |
- BundleFilter* bundle_filter() { return &bundle_filter_; } |
- |
- const std::vector<StreamParams>& local_streams() const { |
- return local_streams_; |
- } |
- const std::vector<StreamParams>& remote_streams() const { |
- return remote_streams_; |
- } |
- |
- sigslot::signal2<BaseChannel*, bool> SignalDtlsSetupFailure; |
- void SignalDtlsSetupFailure_w(bool rtcp); |
- void SignalDtlsSetupFailure_s(bool rtcp); |
- |
- // Used for latency measurements. |
- sigslot::signal1<BaseChannel*> SignalFirstPacketReceived; |
- |
- // Made public for easier testing. |
- void SetReadyToSend(bool rtcp, bool ready); |
- |
- // Only public for unit tests. Otherwise, consider protected. |
- int SetOption(SocketType type, rtc::Socket::Option o, int val) |
- override; |
- |
- SrtpFilter* srtp_filter() { return &srtp_filter_; } |
- |
- protected: |
- virtual MediaChannel* media_channel() const { return media_channel_; } |
- // Sets the |transport_channel_| (and |rtcp_transport_channel_|, if |rtcp_| is |
- // true). Gets the transport channels from |transport_controller_|. |
- bool SetTransport_w(const std::string& transport_name); |
- |
- void set_transport_channel(TransportChannel* transport); |
- void set_rtcp_transport_channel(TransportChannel* transport, |
- bool update_writablity); |
- |
- bool was_ever_writable() const { return was_ever_writable_; } |
- void set_local_content_direction(MediaContentDirection direction) { |
- local_content_direction_ = direction; |
- } |
- void set_remote_content_direction(MediaContentDirection direction) { |
- remote_content_direction_ = direction; |
- } |
- void set_secure_required(bool secure_required) { |
- secure_required_ = secure_required; |
- } |
- bool IsReadyToReceive() const; |
- bool IsReadyToSend() const; |
- rtc::Thread* signaling_thread() { |
- return transport_controller_->signaling_thread(); |
- } |
- bool rtcp_transport_enabled() const { return rtcp_transport_enabled_; } |
- |
- void ConnectToTransportChannel(TransportChannel* tc); |
- void DisconnectFromTransportChannel(TransportChannel* tc); |
- |
- void FlushRtcpMessages(); |
- |
- // NetworkInterface implementation, called by MediaEngine |
- bool SendPacket(rtc::Buffer* packet, |
- const rtc::PacketOptions& options) override; |
- bool SendRtcp(rtc::Buffer* packet, const rtc::PacketOptions& options) |
- override; |
- |
- // From TransportChannel |
- void OnWritableState(TransportChannel* channel); |
- virtual void OnChannelRead(TransportChannel* channel, |
- const char* data, |
- size_t len, |
- const rtc::PacketTime& packet_time, |
- int flags); |
- void OnReadyToSend(TransportChannel* channel); |
- |
- void OnDtlsState(TransportChannel* channel, DtlsTransportState state); |
- |
- bool PacketIsRtcp(const TransportChannel* channel, const char* data, |
- size_t len); |
- bool SendPacket(bool rtcp, |
- rtc::Buffer* packet, |
- const rtc::PacketOptions& options); |
- virtual bool WantsPacket(bool rtcp, rtc::Buffer* packet); |
- void HandlePacket(bool rtcp, rtc::Buffer* packet, |
- const rtc::PacketTime& packet_time); |
- |
- void EnableMedia_w(); |
- void DisableMedia_w(); |
- void UpdateWritableState_w(); |
- void ChannelWritable_w(); |
- void ChannelNotWritable_w(); |
- bool AddRecvStream_w(const StreamParams& sp); |
- bool RemoveRecvStream_w(uint32_t ssrc); |
- bool AddSendStream_w(const StreamParams& sp); |
- bool RemoveSendStream_w(uint32_t ssrc); |
- virtual bool ShouldSetupDtlsSrtp() const; |
- // Do the DTLS key expansion and impose it on the SRTP/SRTCP filters. |
- // |rtcp_channel| indicates whether to set up the RTP or RTCP filter. |
- bool SetupDtlsSrtp(bool rtcp_channel); |
- void MaybeSetupDtlsSrtp_w(); |
- // Set the DTLS-SRTP cipher policy on this channel as appropriate. |
- bool SetDtlsSrtpCryptoSuites(TransportChannel* tc, bool rtcp); |
- |
- virtual void ChangeState() = 0; |
- |
- // Gets the content info appropriate to the channel (audio or video). |
- virtual const ContentInfo* GetFirstContent( |
- const SessionDescription* sdesc) = 0; |
- bool UpdateLocalStreams_w(const std::vector<StreamParams>& streams, |
- ContentAction action, |
- std::string* error_desc); |
- bool UpdateRemoteStreams_w(const std::vector<StreamParams>& streams, |
- ContentAction action, |
- std::string* error_desc); |
- virtual bool SetLocalContent_w(const MediaContentDescription* content, |
- ContentAction action, |
- std::string* error_desc) = 0; |
- virtual bool SetRemoteContent_w(const MediaContentDescription* content, |
- ContentAction action, |
- std::string* error_desc) = 0; |
- bool SetRtpTransportParameters_w(const MediaContentDescription* content, |
- ContentAction action, |
- ContentSource src, |
- std::string* error_desc); |
- |
- // Helper method to get RTP Absoulute SendTime extension header id if |
- // present in remote supported extensions list. |
- void MaybeCacheRtpAbsSendTimeHeaderExtension( |
- const std::vector<RtpHeaderExtension>& extensions); |
- |
- bool CheckSrtpConfig(const std::vector<CryptoParams>& cryptos, |
- bool* dtls, |
- std::string* error_desc); |
- bool SetSrtp_w(const std::vector<CryptoParams>& params, |
- ContentAction action, |
- ContentSource src, |
- std::string* error_desc); |
- void ActivateRtcpMux_w(); |
- bool SetRtcpMux_w(bool enable, |
- ContentAction action, |
- ContentSource src, |
- std::string* error_desc); |
- |
- // From MessageHandler |
- void OnMessage(rtc::Message* pmsg) override; |
- |
- // Handled in derived classes |
- // Get the SRTP crypto suites to use for RTP media |
- virtual void GetSrtpCryptoSuites(std::vector<int>* crypto_suites) const = 0; |
- virtual void OnConnectionMonitorUpdate(ConnectionMonitor* monitor, |
- const std::vector<ConnectionInfo>& infos) = 0; |
- |
- // Helper function for invoking bool-returning methods on the worker thread. |
- template <class FunctorT> |
- bool InvokeOnWorker(const FunctorT& functor) { |
- return worker_thread_->Invoke<bool>(functor); |
- } |
- |
- private: |
- rtc::Thread* worker_thread_; |
- TransportController* transport_controller_; |
- MediaChannel* media_channel_; |
- std::vector<StreamParams> local_streams_; |
- std::vector<StreamParams> remote_streams_; |
- |
- const std::string content_name_; |
- std::string transport_name_; |
- bool rtcp_transport_enabled_; |
- TransportChannel* transport_channel_; |
- std::vector<std::pair<rtc::Socket::Option, int> > socket_options_; |
- TransportChannel* rtcp_transport_channel_; |
- std::vector<std::pair<rtc::Socket::Option, int> > rtcp_socket_options_; |
- SrtpFilter srtp_filter_; |
- RtcpMuxFilter rtcp_mux_filter_; |
- BundleFilter bundle_filter_; |
- rtc::scoped_ptr<ConnectionMonitor> connection_monitor_; |
- bool enabled_; |
- bool writable_; |
- bool rtp_ready_to_send_; |
- bool rtcp_ready_to_send_; |
- bool was_ever_writable_; |
- MediaContentDirection local_content_direction_; |
- MediaContentDirection remote_content_direction_; |
- bool has_received_packet_; |
- bool dtls_keyed_; |
- bool secure_required_; |
- int rtp_abs_sendtime_extn_id_; |
-}; |
- |
-// VoiceChannel is a specialization that adds support for early media, DTMF, |
-// and input/output level monitoring. |
-class VoiceChannel : public BaseChannel { |
- public: |
- VoiceChannel(rtc::Thread* thread, |
- MediaEngineInterface* media_engine, |
- VoiceMediaChannel* channel, |
- TransportController* transport_controller, |
- const std::string& content_name, |
- bool rtcp); |
- ~VoiceChannel(); |
- bool Init(); |
- |
- // Configure sending media on the stream with SSRC |ssrc| |
- // If there is only one sending stream SSRC 0 can be used. |
- bool SetAudioSend(uint32_t ssrc, |
- bool enable, |
- const AudioOptions* options, |
- AudioRenderer* renderer); |
- |
- // downcasts a MediaChannel |
- virtual VoiceMediaChannel* media_channel() const { |
- return static_cast<VoiceMediaChannel*>(BaseChannel::media_channel()); |
- } |
- |
- void SetEarlyMedia(bool enable); |
- // This signal is emitted when we have gone a period of time without |
- // receiving early media. When received, a UI should start playing its |
- // own ringing sound |
- sigslot::signal1<VoiceChannel*> SignalEarlyMediaTimeout; |
- |
- // Returns if the telephone-event has been negotiated. |
- bool CanInsertDtmf(); |
- // Send and/or play a DTMF |event| according to the |flags|. |
- // The DTMF out-of-band signal will be used on sending. |
- // The |ssrc| should be either 0 or a valid send stream ssrc. |
- // The valid value for the |event| are 0 which corresponding to DTMF |
- // event 0-9, *, #, A-D. |
- bool InsertDtmf(uint32_t ssrc, int event_code, int duration); |
- bool SetOutputVolume(uint32_t ssrc, double volume); |
- void SetRawAudioSink(uint32_t ssrc, |
- rtc::scoped_ptr<webrtc::AudioSinkInterface> sink); |
- |
- // Get statistics about the current media session. |
- bool GetStats(VoiceMediaInfo* stats); |
- |
- // Monitoring functions |
- sigslot::signal2<VoiceChannel*, const std::vector<ConnectionInfo>&> |
- SignalConnectionMonitor; |
- |
- void StartMediaMonitor(int cms); |
- void StopMediaMonitor(); |
- sigslot::signal2<VoiceChannel*, const VoiceMediaInfo&> SignalMediaMonitor; |
- |
- void StartAudioMonitor(int cms); |
- void StopAudioMonitor(); |
- bool IsAudioMonitorRunning() const; |
- sigslot::signal2<VoiceChannel*, const AudioInfo&> SignalAudioMonitor; |
- |
- int GetInputLevel_w(); |
- int GetOutputLevel_w(); |
- void GetActiveStreams_w(AudioInfo::StreamList* actives); |
- |
- private: |
- // overrides from BaseChannel |
- virtual void OnChannelRead(TransportChannel* channel, |
- const char* data, size_t len, |
- const rtc::PacketTime& packet_time, |
- int flags); |
- virtual void ChangeState(); |
- virtual const ContentInfo* GetFirstContent(const SessionDescription* sdesc); |
- virtual bool SetLocalContent_w(const MediaContentDescription* content, |
- ContentAction action, |
- std::string* error_desc); |
- virtual bool SetRemoteContent_w(const MediaContentDescription* content, |
- ContentAction action, |
- std::string* error_desc); |
- void HandleEarlyMediaTimeout(); |
- bool InsertDtmf_w(uint32_t ssrc, int event, int duration); |
- bool SetOutputVolume_w(uint32_t ssrc, double volume); |
- bool GetStats_w(VoiceMediaInfo* stats); |
- |
- virtual void OnMessage(rtc::Message* pmsg); |
- virtual void GetSrtpCryptoSuites(std::vector<int>* crypto_suites) const; |
- virtual void OnConnectionMonitorUpdate( |
- ConnectionMonitor* monitor, const std::vector<ConnectionInfo>& infos); |
- virtual void OnMediaMonitorUpdate( |
- VoiceMediaChannel* media_channel, const VoiceMediaInfo& info); |
- void OnAudioMonitorUpdate(AudioMonitor* monitor, const AudioInfo& info); |
- |
- static const int kEarlyMediaTimeout = 1000; |
- MediaEngineInterface* media_engine_; |
- bool received_media_; |
- rtc::scoped_ptr<VoiceMediaMonitor> media_monitor_; |
- rtc::scoped_ptr<AudioMonitor> audio_monitor_; |
- |
- // Last AudioSendParameters sent down to the media_channel() via |
- // SetSendParameters. |
- AudioSendParameters last_send_params_; |
- // Last AudioRecvParameters sent down to the media_channel() via |
- // SetRecvParameters. |
- AudioRecvParameters last_recv_params_; |
-}; |
- |
-// VideoChannel is a specialization for video. |
-class VideoChannel : public BaseChannel { |
- public: |
- VideoChannel(rtc::Thread* thread, |
- VideoMediaChannel* channel, |
- TransportController* transport_controller, |
- const std::string& content_name, |
- bool rtcp); |
- ~VideoChannel(); |
- bool Init(); |
- |
- // downcasts a MediaChannel |
- virtual VideoMediaChannel* media_channel() const { |
- return static_cast<VideoMediaChannel*>(BaseChannel::media_channel()); |
- } |
- |
- bool SetSink(uint32_t ssrc, rtc::VideoSinkInterface<VideoFrame>* sink); |
- |
- // TODO(pthatcher): Refactor to use a "capture id" instead of an |
- // ssrc here as the "key". |
- // Passes ownership of the capturer to the channel. |
- bool AddScreencast(uint32_t ssrc, VideoCapturer* capturer); |
- bool SetCapturer(uint32_t ssrc, VideoCapturer* capturer); |
- bool RemoveScreencast(uint32_t ssrc); |
- // True if we've added a screencast. Doesn't matter if the capturer |
- // has been started or not. |
- bool IsScreencasting(); |
- // Get statistics about the current media session. |
- bool GetStats(VideoMediaInfo* stats); |
- |
- sigslot::signal2<VideoChannel*, const std::vector<ConnectionInfo>&> |
- SignalConnectionMonitor; |
- |
- void StartMediaMonitor(int cms); |
- void StopMediaMonitor(); |
- sigslot::signal2<VideoChannel*, const VideoMediaInfo&> SignalMediaMonitor; |
- sigslot::signal2<uint32_t, rtc::WindowEvent> SignalScreencastWindowEvent; |
- |
- bool SetVideoSend(uint32_t ssrc, bool enable, const VideoOptions* options); |
- |
- private: |
- typedef std::map<uint32_t, VideoCapturer*> ScreencastMap; |
- |
- // overrides from BaseChannel |
- virtual void ChangeState(); |
- virtual const ContentInfo* GetFirstContent(const SessionDescription* sdesc); |
- virtual bool SetLocalContent_w(const MediaContentDescription* content, |
- ContentAction action, |
- std::string* error_desc); |
- virtual bool SetRemoteContent_w(const MediaContentDescription* content, |
- ContentAction action, |
- std::string* error_desc); |
- |
- bool AddScreencast_w(uint32_t ssrc, VideoCapturer* capturer); |
- bool RemoveScreencast_w(uint32_t ssrc); |
- void OnScreencastWindowEvent_s(uint32_t ssrc, rtc::WindowEvent we); |
- bool IsScreencasting_w() const; |
- bool GetStats_w(VideoMediaInfo* stats); |
- |
- virtual void OnMessage(rtc::Message* pmsg); |
- virtual void GetSrtpCryptoSuites(std::vector<int>* crypto_suites) const; |
- virtual void OnConnectionMonitorUpdate( |
- ConnectionMonitor* monitor, const std::vector<ConnectionInfo>& infos); |
- virtual void OnMediaMonitorUpdate( |
- VideoMediaChannel* media_channel, const VideoMediaInfo& info); |
- virtual void OnScreencastWindowEvent(uint32_t ssrc, rtc::WindowEvent event); |
- virtual void OnStateChange(VideoCapturer* capturer, CaptureState ev); |
- bool GetLocalSsrc(const VideoCapturer* capturer, uint32_t* ssrc); |
- |
- ScreencastMap screencast_capturers_; |
- rtc::scoped_ptr<VideoMediaMonitor> media_monitor_; |
- |
- rtc::WindowEvent previous_we_; |
- |
- // Last VideoSendParameters sent down to the media_channel() via |
- // SetSendParameters. |
- VideoSendParameters last_send_params_; |
- // Last VideoRecvParameters sent down to the media_channel() via |
- // SetRecvParameters. |
- VideoRecvParameters last_recv_params_; |
-}; |
- |
-// DataChannel is a specialization for data. |
-class DataChannel : public BaseChannel { |
- public: |
- DataChannel(rtc::Thread* thread, |
- DataMediaChannel* media_channel, |
- TransportController* transport_controller, |
- const std::string& content_name, |
- bool rtcp); |
- ~DataChannel(); |
- bool Init(); |
- |
- virtual bool SendData(const SendDataParams& params, |
- const rtc::Buffer& payload, |
- SendDataResult* result); |
- |
- void StartMediaMonitor(int cms); |
- void StopMediaMonitor(); |
- |
- // Should be called on the signaling thread only. |
- bool ready_to_send_data() const { |
- return ready_to_send_data_; |
- } |
- |
- sigslot::signal2<DataChannel*, const DataMediaInfo&> SignalMediaMonitor; |
- sigslot::signal2<DataChannel*, const std::vector<ConnectionInfo>&> |
- SignalConnectionMonitor; |
- sigslot::signal3<DataChannel*, const ReceiveDataParams&, const rtc::Buffer&> |
- SignalDataReceived; |
- // Signal for notifying when the channel becomes ready to send data. |
- // That occurs when the channel is enabled, the transport is writable, |
- // both local and remote descriptions are set, and the channel is unblocked. |
- sigslot::signal1<bool> SignalReadyToSendData; |
- // Signal for notifying that the remote side has closed the DataChannel. |
- sigslot::signal1<uint32_t> SignalStreamClosedRemotely; |
- |
- protected: |
- // downcasts a MediaChannel. |
- virtual DataMediaChannel* media_channel() const { |
- return static_cast<DataMediaChannel*>(BaseChannel::media_channel()); |
- } |
- |
- private: |
- struct SendDataMessageData : public rtc::MessageData { |
- SendDataMessageData(const SendDataParams& params, |
- const rtc::Buffer* payload, |
- SendDataResult* result) |
- : params(params), |
- payload(payload), |
- result(result), |
- succeeded(false) { |
- } |
- |
- const SendDataParams& params; |
- const rtc::Buffer* payload; |
- SendDataResult* result; |
- bool succeeded; |
- }; |
- |
- struct DataReceivedMessageData : public rtc::MessageData { |
- // We copy the data because the data will become invalid after we |
- // handle DataMediaChannel::SignalDataReceived but before we fire |
- // SignalDataReceived. |
- DataReceivedMessageData( |
- const ReceiveDataParams& params, const char* data, size_t len) |
- : params(params), |
- payload(data, len) { |
- } |
- const ReceiveDataParams params; |
- const rtc::Buffer payload; |
- }; |
- |
- typedef rtc::TypedMessageData<bool> DataChannelReadyToSendMessageData; |
- |
- // overrides from BaseChannel |
- virtual const ContentInfo* GetFirstContent(const SessionDescription* sdesc); |
- // If data_channel_type_ is DCT_NONE, set it. Otherwise, check that |
- // it's the same as what was set previously. Returns false if it's |
- // set to one type one type and changed to another type later. |
- bool SetDataChannelType(DataChannelType new_data_channel_type, |
- std::string* error_desc); |
- // Same as SetDataChannelType, but extracts the type from the |
- // DataContentDescription. |
- bool SetDataChannelTypeFromContent(const DataContentDescription* content, |
- std::string* error_desc); |
- virtual bool SetLocalContent_w(const MediaContentDescription* content, |
- ContentAction action, |
- std::string* error_desc); |
- virtual bool SetRemoteContent_w(const MediaContentDescription* content, |
- ContentAction action, |
- std::string* error_desc); |
- virtual void ChangeState(); |
- virtual bool WantsPacket(bool rtcp, rtc::Buffer* packet); |
- |
- virtual void OnMessage(rtc::Message* pmsg); |
- virtual void GetSrtpCryptoSuites(std::vector<int>* crypto_suites) const; |
- virtual void OnConnectionMonitorUpdate( |
- ConnectionMonitor* monitor, const std::vector<ConnectionInfo>& infos); |
- virtual void OnMediaMonitorUpdate( |
- DataMediaChannel* media_channel, const DataMediaInfo& info); |
- virtual bool ShouldSetupDtlsSrtp() const; |
- void OnDataReceived( |
- const ReceiveDataParams& params, const char* data, size_t len); |
- void OnDataChannelError(uint32_t ssrc, DataMediaChannel::Error error); |
- void OnDataChannelReadyToSend(bool writable); |
- void OnStreamClosedRemotely(uint32_t sid); |
- |
- rtc::scoped_ptr<DataMediaMonitor> media_monitor_; |
- // TODO(pthatcher): Make a separate SctpDataChannel and |
- // RtpDataChannel instead of using this. |
- DataChannelType data_channel_type_; |
- bool ready_to_send_data_; |
- |
- // Last DataSendParameters sent down to the media_channel() via |
- // SetSendParameters. |
- DataSendParameters last_send_params_; |
- // Last DataRecvParameters sent down to the media_channel() via |
- // SetRecvParameters. |
- DataRecvParameters last_recv_params_; |
-}; |
- |
-} // namespace cricket |
- |
-#endif // TALK_SESSION_MEDIA_CHANNEL_H_ |