Index: net/tools/quic/test_tools/packet_dropping_test_writer.cc |
diff --git a/net/tools/quic/test_tools/packet_dropping_test_writer.cc b/net/tools/quic/test_tools/packet_dropping_test_writer.cc |
index 11aafb694954b25ccdae8690cb23d1287e003bbf..fc80ed7fb64c1d9cd316bd931a876a250941f519 100644 |
--- a/net/tools/quic/test_tools/packet_dropping_test_writer.cc |
+++ b/net/tools/quic/test_tools/packet_dropping_test_writer.cc |
@@ -10,8 +10,6 @@ |
#include "net/tools/quic/quic_epoll_connection_helper.h" |
#include "net/tools/quic/quic_socket_utils.h" |
-using net::test::QuicTestWriter; |
- |
namespace net { |
namespace tools { |
namespace test { |
@@ -64,7 +62,7 @@ PacketDroppingTestWriter::PacketDroppingTestWriter() |
simple_random_.set_seed(seed); |
} |
-PacketDroppingTestWriter::~PacketDroppingTestWriter() { } |
+PacketDroppingTestWriter::~PacketDroppingTestWriter() {} |
void PacketDroppingTestWriter::SetConnectionHelper( |
QuicEpollConnectionHelper* helper) { |
@@ -76,7 +74,8 @@ void PacketDroppingTestWriter::SetConnectionHelper( |
} |
WriteResult PacketDroppingTestWriter::WritePacket( |
- const char* buffer, size_t buf_len, |
+ const char* buffer, |
+ size_t buf_len, |
const net::IPAddressNumber& self_address, |
const net::IPEndPoint& peer_address, |
QuicBlockedWriterInterface* blocked_writer) { |
@@ -133,12 +132,8 @@ WriteResult PacketDroppingTestWriter::WritePacket( |
return WriteResult(WRITE_STATUS_OK, buf_len); |
} |
- return writer()->WritePacket(buffer, buf_len, self_address, peer_address, |
- blocked_writer); |
-} |
- |
-bool PacketDroppingTestWriter::IsWriteBlockedDataBuffered() const { |
- return false; |
+ return QuicPacketWriterWrapper::WritePacket( |
+ buffer, buf_len, self_address, peer_address, blocked_writer); |
} |
QuicTime PacketDroppingTestWriter::ReleaseNextPacket() { |
@@ -160,8 +155,9 @@ QuicTime PacketDroppingTestWriter::ReleaseNextPacket() { |
DLOG(INFO) << "Releasing packet. " << (delayed_packets_.size() - 1) |
<< " remaining."; |
// Grab the next one off the queue and send it. |
- writer()->WritePacket(iter->buffer.data(), iter->buffer.length(), |
- iter->self_address, iter->peer_address, NULL); |
+ QuicPacketWriterWrapper::WritePacket( |
+ iter->buffer.data(), iter->buffer.length(), |
+ iter->self_address, iter->peer_address, NULL); |
DCHECK_GE(cur_buffer_size_, iter->buffer.length()); |
cur_buffer_size_ -= iter->buffer.length(); |
delayed_packets_.erase(iter); |