Index: net/socket/buffered_write_stream_socket_unittest.cc |
diff --git a/net/socket/buffered_write_stream_socket_unittest.cc b/net/socket/buffered_write_stream_socket_unittest.cc |
index 485295f33f698740189f246cfc3d1570804e4267..e69de29bb2d1d6434b8b29ae775ad8c2e48c5391 100644 |
--- a/net/socket/buffered_write_stream_socket_unittest.cc |
+++ b/net/socket/buffered_write_stream_socket_unittest.cc |
@@ -1,124 +0,0 @@ |
-// Copyright (c) 2012 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. |
- |
-#include "net/socket/buffered_write_stream_socket.h" |
- |
-#include "base/memory/ref_counted.h" |
-#include "base/memory/scoped_ptr.h" |
-#include "base/message_loop/message_loop.h" |
-#include "net/base/net_errors.h" |
-#include "net/base/net_log.h" |
-#include "net/socket/socket_test_util.h" |
-#include "testing/gtest/include/gtest/gtest.h" |
- |
-namespace net { |
- |
-namespace { |
- |
-class BufferedWriteStreamSocketTest : public testing::Test { |
- public: |
- void Finish() { |
- base::MessageLoop::current()->RunUntilIdle(); |
- EXPECT_TRUE(data_->at_read_eof()); |
- EXPECT_TRUE(data_->at_write_eof()); |
- } |
- |
- void Initialize(MockWrite* writes, size_t writes_count) { |
- data_.reset(new DeterministicSocketData(NULL, 0, writes, writes_count)); |
- data_->set_connect_data(MockConnect(SYNCHRONOUS, 0)); |
- if (writes_count) { |
- data_->StopAfter(writes_count); |
- } |
- scoped_ptr<DeterministicMockTCPClientSocket> wrapped_socket( |
- new DeterministicMockTCPClientSocket(net_log_.net_log(), data_.get())); |
- data_->set_delegate(wrapped_socket->AsWeakPtr()); |
- socket_.reset(new BufferedWriteStreamSocket( |
- wrapped_socket.PassAs<StreamSocket>())); |
- socket_->Connect(callback_.callback()); |
- } |
- |
- void TestWrite(const char* text) { |
- scoped_refptr<StringIOBuffer> buf(new StringIOBuffer(text)); |
- EXPECT_EQ(buf->size(), |
- socket_->Write(buf.get(), buf->size(), callback_.callback())); |
- } |
- |
- scoped_ptr<BufferedWriteStreamSocket> socket_; |
- scoped_ptr<DeterministicSocketData> data_; |
- BoundNetLog net_log_; |
- TestCompletionCallback callback_; |
-}; |
- |
-TEST_F(BufferedWriteStreamSocketTest, SingleWrite) { |
- MockWrite writes[] = { |
- MockWrite(SYNCHRONOUS, 0, "abc"), |
- }; |
- Initialize(writes, arraysize(writes)); |
- TestWrite("abc"); |
- Finish(); |
-} |
- |
-TEST_F(BufferedWriteStreamSocketTest, AsyncWrite) { |
- MockWrite writes[] = { |
- MockWrite(ASYNC, 0, "abc"), |
- }; |
- Initialize(writes, arraysize(writes)); |
- TestWrite("abc"); |
- data_->Run(); |
- Finish(); |
-} |
- |
-TEST_F(BufferedWriteStreamSocketTest, TwoWritesIntoOne) { |
- MockWrite writes[] = { |
- MockWrite(SYNCHRONOUS, 0, "abcdef"), |
- }; |
- Initialize(writes, arraysize(writes)); |
- TestWrite("abc"); |
- TestWrite("def"); |
- Finish(); |
-} |
- |
-TEST_F(BufferedWriteStreamSocketTest, WriteWhileBlocked) { |
- MockWrite writes[] = { |
- MockWrite(ASYNC, 0, "abc"), |
- MockWrite(ASYNC, 1, "def"), |
- MockWrite(ASYNC, 2, "ghi"), |
- }; |
- Initialize(writes, arraysize(writes)); |
- TestWrite("abc"); |
- base::MessageLoop::current()->RunUntilIdle(); |
- TestWrite("def"); |
- data_->RunFor(1); |
- TestWrite("ghi"); |
- data_->RunFor(1); |
- Finish(); |
-} |
- |
-TEST_F(BufferedWriteStreamSocketTest, ContinuesPartialWrite) { |
- MockWrite writes[] = { |
- MockWrite(ASYNC, 0, "abc"), |
- MockWrite(ASYNC, 1, "def"), |
- }; |
- Initialize(writes, arraysize(writes)); |
- TestWrite("abcdef"); |
- data_->Run(); |
- Finish(); |
-} |
- |
-TEST_F(BufferedWriteStreamSocketTest, TwoSeparateWrites) { |
- MockWrite writes[] = { |
- MockWrite(ASYNC, 0, "abc"), |
- MockWrite(ASYNC, 1, "def"), |
- }; |
- Initialize(writes, arraysize(writes)); |
- TestWrite("abc"); |
- data_->RunFor(1); |
- TestWrite("def"); |
- data_->RunFor(1); |
- Finish(); |
-} |
- |
-} // anonymous namespace |
- |
-} // namespace net |