| Index: blimp/net/stream_packet_reader_unittest.cc
|
| diff --git a/blimp/net/stream_packet_reader_unittest.cc b/blimp/net/stream_packet_reader_unittest.cc
|
| index 3341a673f982bc2b5991c047c4aecf6f8cdaa57f..a076a41c5eac2ca09f5d04ef00152b6cbcf9e9f2 100644
|
| --- a/blimp/net/stream_packet_reader_unittest.cc
|
| +++ b/blimp/net/stream_packet_reader_unittest.cc
|
| @@ -7,7 +7,6 @@
|
|
|
| #include "base/message_loop/message_loop.h"
|
| #include "base/sys_byteorder.h"
|
| -#include "blimp/net/blimp_connection_statistics.h"
|
| #include "blimp/net/common.h"
|
| #include "blimp/net/stream_packet_reader.h"
|
| #include "blimp/net/test_common.h"
|
| @@ -35,7 +34,7 @@
|
| StreamPacketReaderTest()
|
| : buffer_(new net::GrowableIOBuffer),
|
| test_msg_("U WOT M8"),
|
| - data_reader_(&socket_, &statistics_) {}
|
| + data_reader_(&socket_) {}
|
|
|
| ~StreamPacketReaderTest() override {}
|
|
|
| @@ -48,7 +47,6 @@
|
| net::TestCompletionCallback callback_;
|
| testing::StrictMock<MockStreamSocket> socket_;
|
| testing::InSequence sequence_;
|
| - BlimpConnectionStatistics statistics_;
|
| StreamPacketReader data_reader_;
|
| };
|
|
|
| @@ -158,13 +156,9 @@
|
|
|
| ReadPacket();
|
| ASSERT_EQ(static_cast<int>(test_msg_.size()), callback_.WaitForResult());
|
| - EXPECT_EQ(static_cast<int>(test_msg_.size()),
|
| - statistics_.Get(BlimpConnectionStatistics::BYTES_RECEIVED));
|
|
|
| ReadPacket();
|
| ASSERT_EQ(static_cast<int>(test_msg2.size()), callback_.WaitForResult());
|
| - EXPECT_EQ(static_cast<int>(test_msg_.size() + test_msg2.size()),
|
| - statistics_.Get(BlimpConnectionStatistics::BYTES_RECEIVED));
|
|
|
| EXPECT_TRUE(BufferStartsWith(buffer_.get(), test_msg2.size(), test_msg2));
|
| EXPECT_FALSE(callback_.have_result());
|
| @@ -319,8 +313,7 @@
|
| TEST_F(StreamPacketReaderTest, ReaderDeletedDuringAsyncHeaderRead) {
|
| net::CompletionCallback cb;
|
| net::TestCompletionCallback test_cb;
|
| - std::unique_ptr<StreamPacketReader> reader(
|
| - new StreamPacketReader(&socket_, &statistics_));
|
| + std::unique_ptr<StreamPacketReader> reader(new StreamPacketReader(&socket_));
|
|
|
| EXPECT_CALL(socket_, Read(NotNull(), kPacketHeaderSizeBytes, _))
|
| .WillOnce(DoAll(FillBufferFromString<0>(EncodeHeader(test_msg_.size())),
|
| @@ -335,8 +328,7 @@
|
| // StreamPacketReader object was destroyed.
|
| TEST_F(StreamPacketReaderTest, ReaderDeletedDuringAsyncPayloadRead) {
|
| net::CompletionCallback cb;
|
| - std::unique_ptr<StreamPacketReader> reader(
|
| - new StreamPacketReader(&socket_, &statistics_));
|
| + std::unique_ptr<StreamPacketReader> reader(new StreamPacketReader(&socket_));
|
|
|
| EXPECT_CALL(socket_, Read(NotNull(), kPacketHeaderSizeBytes, _))
|
| .WillOnce(DoAll(FillBufferFromString<0>(EncodeHeader(test_msg_.size())),
|
|
|