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

Unified Diff: media/cast/test/utility/udp_proxy.cc

Issue 388663003: Cast: Reshuffle files under media/cast (Closed) Base URL: svn://svn.chromium.org/chrome/trunk/src
Patch Set: missing includes Created 6 years, 5 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 | « media/cast/test/utility/udp_proxy.h ('k') | media/cast/test/utility/udp_proxy_main.cc » ('j') | no next file with comments »
Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
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_);
}
« no previous file with comments | « media/cast/test/utility/udp_proxy.h ('k') | media/cast/test/utility/udp_proxy_main.cc » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698