| Index: media/cast/test/utility/udp_proxy.cc
|
| diff --git a/media/cast/test/utility/udp_proxy.cc b/media/cast/test/utility/udp_proxy.cc
|
| index 7e9c553381a68646ba0bb6527b9a36d3ec0ba6cf..4714b7ed675d8ced80bd1445dc86e4f6e3d593ab 100644
|
| --- a/media/cast/test/utility/udp_proxy.cc
|
| +++ b/media/cast/test/utility/udp_proxy.cc
|
| @@ -56,10 +56,10 @@ class Buffer : public PacketPipe {
|
| CHECK_GT(max_megabits_per_second, 0);
|
| }
|
|
|
| - virtual void Send(scoped_ptr<transport::Packet> packet) OVERRIDE {
|
| + virtual void Send(scoped_ptr<Packet> packet) OVERRIDE {
|
| if (packet->size() + buffer_size_ <= max_buffer_size_) {
|
| buffer_size_ += packet->size();
|
| - buffer_.push_back(linked_ptr<transport::Packet>(packet.release()));
|
| + buffer_.push_back(linked_ptr<Packet>(packet.release()));
|
| if (buffer_.size() == 1) {
|
| Schedule();
|
| }
|
| @@ -79,7 +79,7 @@ class Buffer : public PacketPipe {
|
|
|
| void ProcessBuffer() {
|
| CHECK(!buffer_.empty());
|
| - scoped_ptr<transport::Packet> packet(buffer_.front().release());
|
| + scoped_ptr<Packet> packet(buffer_.front().release());
|
| buffer_size_ -= packet->size();
|
| buffer_.pop_front();
|
| pipe_->Send(packet.Pass());
|
| @@ -88,7 +88,7 @@ class Buffer : public PacketPipe {
|
| }
|
| }
|
|
|
| - std::deque<linked_ptr<transport::Packet> > buffer_;
|
| + std::deque<linked_ptr<Packet> > buffer_;
|
| size_t buffer_size_;
|
| size_t max_buffer_size_;
|
| double max_megabits_per_second_; // megabits per second
|
| @@ -104,7 +104,7 @@ class RandomDrop : public PacketPipe {
|
| RandomDrop(double drop_fraction)
|
| : drop_fraction_(static_cast<int>(drop_fraction * RAND_MAX)) {}
|
|
|
| - virtual void Send(scoped_ptr<transport::Packet> packet) OVERRIDE {
|
| + virtual void Send(scoped_ptr<Packet> packet) OVERRIDE {
|
| if (rand() > drop_fraction_) {
|
| pipe_->Send(packet.Pass());
|
| }
|
| @@ -123,7 +123,7 @@ class SimpleDelayBase : public PacketPipe {
|
| SimpleDelayBase() : weak_factory_(this) {}
|
| virtual ~SimpleDelayBase() {}
|
|
|
| - virtual void Send(scoped_ptr<transport::Packet> packet) OVERRIDE {
|
| + virtual void Send(scoped_ptr<Packet> packet) OVERRIDE {
|
| double seconds = GetDelay();
|
| task_runner_->PostDelayedTask(
|
| FROM_HERE,
|
| @@ -136,7 +136,7 @@ class SimpleDelayBase : public PacketPipe {
|
| virtual double GetDelay() = 0;
|
|
|
| private:
|
| - virtual void SendInternal(scoped_ptr<transport::Packet> packet) {
|
| + virtual void SendInternal(scoped_ptr<Packet> packet) {
|
| pipe_->Send(packet.Pass());
|
| }
|
|
|
| @@ -185,8 +185,8 @@ class RandomSortedDelay : public PacketPipe {
|
| seconds_between_extra_delay_(seconds_between_extra_delay),
|
| weak_factory_(this) {}
|
|
|
| - virtual void Send(scoped_ptr<transport::Packet> packet) OVERRIDE {
|
| - buffer_.push_back(linked_ptr<transport::Packet>(packet.release()));
|
| + virtual void Send(scoped_ptr<Packet> packet) OVERRIDE {
|
| + buffer_.push_back(linked_ptr<Packet>(packet.release()));
|
| if (buffer_.size() == 1) {
|
| Schedule();
|
| }
|
| @@ -239,7 +239,7 @@ class RandomSortedDelay : public PacketPipe {
|
|
|
| void ProcessBuffer() {
|
| CHECK(!buffer_.empty());
|
| - scoped_ptr<transport::Packet> packet(buffer_.front().release());
|
| + scoped_ptr<Packet> packet(buffer_.front().release());
|
| pipe_->Send(packet.Pass());
|
| buffer_.pop_front();
|
| if (!buffer_.empty()) {
|
| @@ -248,7 +248,7 @@ class RandomSortedDelay : public PacketPipe {
|
| }
|
|
|
| base::TimeTicks block_until_;
|
| - std::deque<linked_ptr<transport::Packet> > buffer_;
|
| + std::deque<linked_ptr<Packet> > buffer_;
|
| double random_delay_;
|
| double extra_delay_;
|
| double seconds_between_extra_delay_;
|
| @@ -280,7 +280,7 @@ class NetworkGlitchPipe : public PacketPipe {
|
| Flip();
|
| }
|
|
|
| - virtual void Send(scoped_ptr<transport::Packet> packet) OVERRIDE {
|
| + virtual void Send(scoped_ptr<Packet> packet) OVERRIDE {
|
| if (works_) {
|
| pipe_->Send(packet.Pass());
|
| }
|
| @@ -324,12 +324,12 @@ class InterruptedPoissonProcess::InternalBuffer : public PacketPipe {
|
| weak_factory_(this) {
|
| }
|
|
|
| - virtual void Send(scoped_ptr<transport::Packet> packet) OVERRIDE {
|
| + virtual void Send(scoped_ptr<Packet> packet) OVERRIDE {
|
| // Drop if buffer is full.
|
| if (stored_size_ >= stored_limit_)
|
| return;
|
| stored_size_ += packet->size();
|
| - buffer_.push_back(linked_ptr<transport::Packet>(packet.release()));
|
| + buffer_.push_back(linked_ptr<Packet>(packet.release()));
|
| buffer_time_.push_back(clock_->NowTicks());
|
| DCHECK(buffer_.size() == buffer_time_.size());
|
| }
|
| @@ -344,7 +344,7 @@ class InterruptedPoissonProcess::InternalBuffer : public PacketPipe {
|
| }
|
|
|
| void SendOnePacket() {
|
| - scoped_ptr<transport::Packet> packet(buffer_.front().release());
|
| + scoped_ptr<Packet> packet(buffer_.front().release());
|
| stored_size_ -= packet->size();
|
| buffer_.pop_front();
|
| buffer_time_.pop_front();
|
| @@ -370,7 +370,7 @@ class InterruptedPoissonProcess::InternalBuffer : public PacketPipe {
|
| const base::WeakPtr<InterruptedPoissonProcess> ipp_;
|
| size_t stored_size_;
|
| const size_t stored_limit_;
|
| - std::deque<linked_ptr<transport::Packet> > buffer_;
|
| + std::deque<linked_ptr<Packet> > buffer_;
|
| std::deque<base::TimeTicks> buffer_time_;
|
| base::TickClock* clock_;
|
| base::WeakPtrFactory<InternalBuffer> weak_factory_;
|
| @@ -516,7 +516,7 @@ class PacketSender : public PacketPipe {
|
| public:
|
| PacketSender(UDPProxyImpl* udp_proxy, const net::IPEndPoint* destination)
|
| : udp_proxy_(udp_proxy), destination_(destination) {}
|
| - virtual void Send(scoped_ptr<transport::Packet> packet) OVERRIDE;
|
| + virtual void Send(scoped_ptr<Packet> packet) OVERRIDE;
|
| virtual void AppendToPipe(scoped_ptr<PacketPipe> pipe) OVERRIDE {
|
| NOTREACHED();
|
| }
|
| @@ -626,7 +626,7 @@ class UDPProxyImpl : public UDPProxy {
|
| proxy_thread_.Stop();
|
| }
|
|
|
| - void Send(scoped_ptr<transport::Packet> packet,
|
| + void Send(scoped_ptr<Packet> packet,
|
| const net::IPEndPoint& destination) {
|
| if (blocked_) {
|
| LOG(ERROR) << "Cannot write packet right now: blocked";
|
| @@ -722,7 +722,7 @@ class UDPProxyImpl : public UDPProxy {
|
|
|
| void PollRead() {
|
| while (true) {
|
| - packet_.reset(new transport::Packet(kMaxPacketSize));
|
| + packet_.reset(new Packet(kMaxPacketSize));
|
| scoped_refptr<net::IOBuffer> recv_buf =
|
| new net::WrappedIOBuffer(reinterpret_cast<char*>(&packet_->front()));
|
| int len = socket_->RecvFrom(
|
| @@ -739,7 +739,7 @@ class UDPProxyImpl : public UDPProxy {
|
| }
|
|
|
| void AllowWrite(scoped_refptr<net::IOBuffer> buf,
|
| - scoped_ptr<transport::Packet> packet,
|
| + scoped_ptr<Packet> packet,
|
| int unused_len) {
|
| DCHECK(blocked_);
|
| blocked_ = false;
|
| @@ -762,7 +762,7 @@ class UDPProxyImpl : public UDPProxy {
|
|
|
| // For receiving.
|
| net::IPEndPoint recv_address_;
|
| - scoped_ptr<transport::Packet> packet_;
|
| + scoped_ptr<Packet> packet_;
|
|
|
| // For sending.
|
| bool blocked_;
|
| @@ -770,7 +770,7 @@ class UDPProxyImpl : public UDPProxy {
|
| base::WeakPtrFactory<UDPProxyImpl> weak_factory_;
|
| };
|
|
|
| -void PacketSender::Send(scoped_ptr<transport::Packet> packet) {
|
| +void PacketSender::Send(scoped_ptr<Packet> packet) {
|
| udp_proxy_->Send(packet.Pass(), *destination_);
|
| }
|
|
|
|
|