| Index: media/cast/audio_receiver/audio_receiver.h
|
| diff --git a/media/cast/audio_receiver/audio_receiver.h b/media/cast/audio_receiver/audio_receiver.h
|
| deleted file mode 100644
|
| index 87c5147b50b83b5e382ee89a84b687d3a6e1f882..0000000000000000000000000000000000000000
|
| --- a/media/cast/audio_receiver/audio_receiver.h
|
| +++ /dev/null
|
| @@ -1,210 +0,0 @@
|
| -// Copyright 2013 The Chromium Authors. All rights reserved.
|
| -// Use of this source code is governed by a BSD-style license that can be
|
| -// found in the LICENSE file.
|
| -
|
| -#ifndef MEDIA_CAST_AUDIO_RECEIVER_AUDIO_RECEIVER_H_
|
| -#define MEDIA_CAST_AUDIO_RECEIVER_AUDIO_RECEIVER_H_
|
| -
|
| -#include "base/basictypes.h"
|
| -#include "base/callback.h"
|
| -#include "base/macros.h"
|
| -#include "base/memory/ref_counted.h"
|
| -#include "base/memory/scoped_ptr.h"
|
| -#include "base/memory/weak_ptr.h"
|
| -#include "base/threading/non_thread_safe.h"
|
| -#include "base/time/tick_clock.h"
|
| -#include "base/time/time.h"
|
| -#include "media/cast/base/clock_drift_smoother.h"
|
| -#include "media/cast/cast_config.h"
|
| -#include "media/cast/cast_environment.h"
|
| -#include "media/cast/cast_receiver.h"
|
| -#include "media/cast/framer/framer.h"
|
| -#include "media/cast/rtcp/receiver_rtcp_event_subscriber.h"
|
| -#include "media/cast/rtcp/rtcp.h"
|
| -#include "media/cast/rtp_receiver/rtp_receiver.h"
|
| -#include "media/cast/rtp_receiver/rtp_receiver_defines.h"
|
| -#include "media/cast/transport/utility/transport_encryption_handler.h"
|
| -
|
| -namespace media {
|
| -namespace cast {
|
| -
|
| -class AudioDecoder;
|
| -
|
| -// AudioReceiver receives packets out-of-order while clients make requests for
|
| -// complete frames in-order. (A frame consists of one or more packets.)
|
| -//
|
| -// AudioReceiver also includes logic for computing the playout time for each
|
| -// frame, accounting for a constant targeted playout delay. The purpose of the
|
| -// playout delay is to provide a fixed window of time between the capture event
|
| -// on the sender and the playout on the receiver. This is important because
|
| -// each step of the pipeline (i.e., encode frame, then transmit/retransmit from
|
| -// the sender, then receive and re-order packets on the receiver, then decode
|
| -// frame) can vary in duration and is typically very hard to predict.
|
| -//
|
| -// Two types of frames can be requested: 1) A frame of decoded audio data; or 2)
|
| -// a frame of still-encoded audio data, to be passed into an external audio
|
| -// decoder. Each request for a frame includes a callback which AudioReceiver
|
| -// guarantees will be called at some point in the future unless the
|
| -// AudioReceiver is destroyed. Clients should generally limit the number of
|
| -// outstanding requests (perhaps to just one or two).
|
| -//
|
| -// This class is not thread safe. Should only be called from the Main cast
|
| -// thread.
|
| -class AudioReceiver : public RtpReceiver,
|
| - public RtpPayloadFeedback,
|
| - public base::NonThreadSafe,
|
| - public base::SupportsWeakPtr<AudioReceiver> {
|
| - public:
|
| - AudioReceiver(scoped_refptr<CastEnvironment> cast_environment,
|
| - const FrameReceiverConfig& audio_config,
|
| - transport::PacedPacketSender* const packet_sender);
|
| -
|
| - virtual ~AudioReceiver();
|
| -
|
| - // Request a decoded audio frame. The audio signal data returned in the
|
| - // callback will have the sampling rate and number of channels as requested in
|
| - // the configuration that was passed to the ctor.
|
| - //
|
| - // The given |callback| is guaranteed to be run at some point in the future,
|
| - // even if to respond with NULL at shutdown time.
|
| - void GetRawAudioFrame(const AudioFrameDecodedCallback& callback);
|
| -
|
| - // Request an encoded audio frame.
|
| - //
|
| - // The given |callback| is guaranteed to be run at some point in the future,
|
| - // even if to respond with NULL at shutdown time.
|
| - void GetEncodedAudioFrame(const FrameEncodedCallback& callback);
|
| -
|
| - // Deliver another packet, possibly a duplicate, and possibly out-of-order.
|
| - void IncomingPacket(scoped_ptr<Packet> packet);
|
| -
|
| - protected:
|
| - friend class AudioReceiverTest; // Invokes OnReceivedPayloadData().
|
| -
|
| - virtual void OnReceivedPayloadData(const uint8* payload_data,
|
| - size_t payload_size,
|
| - const RtpCastHeader& rtp_header) OVERRIDE;
|
| -
|
| - // RtpPayloadFeedback implementation.
|
| - virtual void CastFeedback(const RtcpCastMessage& cast_message) OVERRIDE;
|
| -
|
| - private:
|
| - // Processes ready-to-consume packets from |framer_|, decrypting each packet's
|
| - // payload data, and then running the enqueued callbacks in order (one for
|
| - // each packet). This method may post a delayed task to re-invoke itself in
|
| - // the future to wait for missing/incomplete frames.
|
| - void EmitAvailableEncodedFrames();
|
| -
|
| - // Clears the |is_waiting_for_consecutive_frame_| flag and invokes
|
| - // EmitAvailableEncodedFrames().
|
| - void EmitAvailableEncodedFramesAfterWaiting();
|
| -
|
| - // Feeds an EncodedFrame into |audio_decoder_|. GetRawAudioFrame() uses this
|
| - // as a callback for GetEncodedAudioFrame().
|
| - void DecodeEncodedAudioFrame(
|
| - const AudioFrameDecodedCallback& callback,
|
| - scoped_ptr<transport::EncodedFrame> encoded_frame);
|
| -
|
| - // Computes the playout time for a frame with the given |rtp_timestamp|.
|
| - // Because lip-sync info is refreshed regularly, calling this method with the
|
| - // same argument may return different results.
|
| - base::TimeTicks GetPlayoutTime(uint32 rtp_timestamp) const;
|
| -
|
| - // Schedule the next RTCP report.
|
| - void ScheduleNextRtcpReport();
|
| -
|
| - // Actually send the next RTCP report.
|
| - void SendNextRtcpReport();
|
| -
|
| - // Schedule timing for the next cast message.
|
| - void ScheduleNextCastMessage();
|
| -
|
| - // Actually send the next cast message.
|
| - void SendNextCastMessage();
|
| -
|
| - // Receives an AudioBus from |audio_decoder_|, logs the event, and passes the
|
| - // data on by running the given |callback|. This method is static to ensure
|
| - // it can be called after an AudioReceiver instance is destroyed.
|
| - // DecodeEncodedAudioFrame() uses this as a callback for
|
| - // AudioDecoder::DecodeFrame().
|
| - static void EmitRawAudioFrame(
|
| - const scoped_refptr<CastEnvironment>& cast_environment,
|
| - const AudioFrameDecodedCallback& callback,
|
| - uint32 frame_id,
|
| - uint32 rtp_timestamp,
|
| - const base::TimeTicks& playout_time,
|
| - scoped_ptr<AudioBus> audio_bus,
|
| - bool is_continuous);
|
| -
|
| - const scoped_refptr<CastEnvironment> cast_environment_;
|
| -
|
| - // Subscribes to raw events.
|
| - // Processes raw audio events to be sent over to the cast sender via RTCP.
|
| - ReceiverRtcpEventSubscriber event_subscriber_;
|
| -
|
| - // Configured audio codec.
|
| - const transport::AudioCodec codec_;
|
| -
|
| - // RTP timebase: The number of RTP units advanced per one second. For audio,
|
| - // this is the sampling rate.
|
| - const int frequency_;
|
| -
|
| - // The total amount of time between a frame's capture/recording on the sender
|
| - // and its playback on the receiver (i.e., shown to a user). This is fixed as
|
| - // a value large enough to give the system sufficient time to encode,
|
| - // transmit/retransmit, receive, decode, and render; given its run-time
|
| - // environment (sender/receiver hardware performance, network conditions,
|
| - // etc.).
|
| - const base::TimeDelta target_playout_delay_;
|
| -
|
| - // Hack: This is used in logic that determines whether to skip frames.
|
| - const base::TimeDelta expected_frame_duration_;
|
| -
|
| - // Set to false initially, then set to true after scheduling the periodic
|
| - // sending of reports back to the sender. Reports are first scheduled just
|
| - // after receiving a first packet (since the first packet identifies the
|
| - // sender for the remainder of the session).
|
| - bool reports_are_scheduled_;
|
| -
|
| - // Assembles packets into frames, providing this receiver with complete,
|
| - // decodable EncodedFrames.
|
| - Framer framer_;
|
| -
|
| - // Decodes frames into raw audio for playback.
|
| - scoped_ptr<AudioDecoder> audio_decoder_;
|
| -
|
| - // Manages sending/receiving of RTCP packets, including sender/receiver
|
| - // reports.
|
| - Rtcp rtcp_;
|
| -
|
| - // Decrypts encrypted frames.
|
| - transport::TransportEncryptionHandler decryptor_;
|
| -
|
| - // Outstanding callbacks to run to deliver on client requests for frames.
|
| - std::list<FrameEncodedCallback> frame_request_queue_;
|
| -
|
| - // True while there's an outstanding task to re-invoke
|
| - // EmitAvailableEncodedFrames().
|
| - bool is_waiting_for_consecutive_frame_;
|
| -
|
| - // This mapping allows us to log AUDIO_ACK_SENT as a frame event. In addition
|
| - // it allows the event to be transmitted via RTCP.
|
| - RtpTimestamp frame_id_to_rtp_timestamp_[256];
|
| -
|
| - // Lip-sync values used to compute the playout time of each frame from its RTP
|
| - // timestamp. These are updated each time the first packet of a frame is
|
| - // received.
|
| - RtpTimestamp lip_sync_rtp_timestamp_;
|
| - base::TimeTicks lip_sync_reference_time_;
|
| - ClockDriftSmoother lip_sync_drift_;
|
| -
|
| - // NOTE: Weak pointers must be invalidated before all other member variables.
|
| - base::WeakPtrFactory<AudioReceiver> weak_factory_;
|
| -
|
| - DISALLOW_COPY_AND_ASSIGN(AudioReceiver);
|
| -};
|
| -
|
| -} // namespace cast
|
| -} // namespace media
|
| -
|
| -#endif // MEDIA_CAST_AUDIO_RECEIVER_AUDIO_RECEIVER_H_
|
|
|