Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(615)

Unified Diff: talk/session/media/channel.h

Issue 1691463002: Move talk/session/media -> webrtc/pc (Closed) Base URL: https://chromium.googlesource.com/external/webrtc.git@master
Patch Set: Last rebase Created 4 years, 10 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View side-by-side diff with in-line comments
Download patch
« no previous file with comments | « talk/session/media/bundlefilter_unittest.cc ('k') | talk/session/media/channel.cc » ('j') | no next file with comments »
Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
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_
« no previous file with comments | « talk/session/media/bundlefilter_unittest.cc ('k') | talk/session/media/channel.cc » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698