Index: net/base/elements_upload_data_stream_unittest.cc |
diff --git a/net/base/elements_upload_data_stream_unittest.cc b/net/base/elements_upload_data_stream_unittest.cc |
index 0fab7acdedfe7d80633f5048f2515f52475136c9..fadf45d4d911a4e00b05a9dc0238a1ef6ab17339 100644 |
--- a/net/base/elements_upload_data_stream_unittest.cc |
+++ b/net/base/elements_upload_data_stream_unittest.cc |
@@ -27,10 +27,14 @@ |
#include "net/base/upload_bytes_element_reader.h" |
#include "net/base/upload_data_stream.h" |
#include "net/base/upload_file_element_reader.h" |
+#include "net/test/gtest_util.h" |
#include "testing/gmock/include/gmock/gmock.h" |
#include "testing/gtest/include/gtest/gtest.h" |
#include "testing/platform_test.h" |
+using net::test::IsError; |
+using net::test::IsOk; |
+ |
using ::testing::DoAll; |
using ::testing::Invoke; |
using ::testing::Return; |
@@ -150,7 +154,7 @@ class ElementsUploadDataStreamTest : public PlatformTest { |
TEST_F(ElementsUploadDataStreamTest, EmptyUploadData) { |
std::unique_ptr<UploadDataStream> stream( |
new ElementsUploadDataStream(std::move(element_readers_), 0)); |
- ASSERT_EQ(OK, stream->Init(CompletionCallback())); |
+ ASSERT_THAT(stream->Init(CompletionCallback()), IsOk()); |
EXPECT_TRUE(stream->IsInMemory()); |
EXPECT_EQ(0U, stream->size()); |
EXPECT_EQ(0U, stream->position()); |
@@ -162,7 +166,7 @@ TEST_F(ElementsUploadDataStreamTest, ConsumeAllBytes) { |
base::WrapUnique(new UploadBytesElementReader(kTestData, kTestDataSize))); |
std::unique_ptr<UploadDataStream> stream( |
new ElementsUploadDataStream(std::move(element_readers_), 0)); |
- ASSERT_EQ(OK, stream->Init(CompletionCallback())); |
+ ASSERT_THAT(stream->Init(CompletionCallback()), IsOk()); |
EXPECT_TRUE(stream->IsInMemory()); |
EXPECT_EQ(kTestDataSize, stream->size()); |
EXPECT_EQ(0U, stream->position()); |
@@ -191,8 +195,8 @@ TEST_F(ElementsUploadDataStreamTest, File) { |
TestCompletionCallback init_callback; |
std::unique_ptr<UploadDataStream> stream( |
new ElementsUploadDataStream(std::move(element_readers_), 0)); |
- ASSERT_EQ(ERR_IO_PENDING, stream->Init(init_callback.callback())); |
- ASSERT_EQ(OK, init_callback.WaitForResult()); |
+ ASSERT_THAT(stream->Init(init_callback.callback()), IsError(ERR_IO_PENDING)); |
+ ASSERT_THAT(init_callback.WaitForResult(), IsOk()); |
EXPECT_FALSE(stream->IsInMemory()); |
EXPECT_EQ(kTestDataSize, stream->size()); |
EXPECT_EQ(0U, stream->position()); |
@@ -227,8 +231,8 @@ TEST_F(ElementsUploadDataStreamTest, FileSmallerThanLength) { |
TestCompletionCallback init_callback; |
std::unique_ptr<UploadDataStream> stream( |
new ElementsUploadDataStream(std::move(element_readers_), 0)); |
- ASSERT_EQ(ERR_IO_PENDING, stream->Init(init_callback.callback())); |
- ASSERT_EQ(OK, init_callback.WaitForResult()); |
+ ASSERT_THAT(stream->Init(init_callback.callback()), IsError(ERR_IO_PENDING)); |
+ ASSERT_THAT(init_callback.WaitForResult(), IsOk()); |
EXPECT_FALSE(stream->IsInMemory()); |
EXPECT_EQ(kFakeSize, stream->size()); |
EXPECT_EQ(0U, stream->position()); |
@@ -268,7 +272,7 @@ TEST_F(ElementsUploadDataStreamTest, ReadErrorSync) { |
new ElementsUploadDataStream(std::move(element_readers_), 0)); |
// Run Init(). |
- ASSERT_EQ(OK, stream->Init(CompletionCallback())); |
+ ASSERT_THAT(stream->Init(CompletionCallback()), IsOk()); |
EXPECT_EQ(kTestDataSize*2, stream->size()); |
EXPECT_EQ(0U, stream->position()); |
EXPECT_FALSE(stream->IsEOF()); |
@@ -304,8 +308,8 @@ TEST_F(ElementsUploadDataStreamTest, ReadErrorAsync) { |
// Run Init(). |
TestCompletionCallback init_callback; |
- ASSERT_EQ(ERR_IO_PENDING, stream->Init(init_callback.callback())); |
- EXPECT_EQ(OK, init_callback.WaitForResult()); |
+ ASSERT_THAT(stream->Init(init_callback.callback()), IsError(ERR_IO_PENDING)); |
+ EXPECT_THAT(init_callback.WaitForResult(), IsOk()); |
EXPECT_EQ(kTestDataSize*2, stream->size()); |
EXPECT_EQ(0U, stream->position()); |
EXPECT_FALSE(stream->IsEOF()); |
@@ -318,7 +322,7 @@ TEST_F(ElementsUploadDataStreamTest, ReadErrorAsync) { |
TestCompletionCallback read_callback; |
ASSERT_EQ(ERR_IO_PENDING, |
stream->Read(buf.get(), kTestBufferSize, read_callback.callback())); |
- EXPECT_EQ(ERR_FAILED, read_callback.WaitForResult()); |
+ EXPECT_THAT(read_callback.WaitForResult(), IsError(ERR_FAILED)); |
EXPECT_EQ(0U, stream->position()); |
EXPECT_FALSE(stream->IsEOF()); |
@@ -346,8 +350,8 @@ TEST_F(ElementsUploadDataStreamTest, FileAndBytes) { |
TestCompletionCallback init_callback; |
std::unique_ptr<UploadDataStream> stream( |
new ElementsUploadDataStream(std::move(element_readers_), 0)); |
- ASSERT_EQ(ERR_IO_PENDING, stream->Init(init_callback.callback())); |
- ASSERT_EQ(OK, init_callback.WaitForResult()); |
+ ASSERT_THAT(stream->Init(init_callback.callback()), IsError(ERR_IO_PENDING)); |
+ ASSERT_THAT(init_callback.WaitForResult(), IsOk()); |
EXPECT_FALSE(stream->IsInMemory()); |
EXPECT_EQ(kStreamSize, stream->size()); |
EXPECT_EQ(0U, stream->position()); |
@@ -398,8 +402,8 @@ TEST_F(ElementsUploadDataStreamTest, InitAsync) { |
// Run Init(). |
TestCompletionCallback callback; |
- ASSERT_EQ(ERR_IO_PENDING, stream->Init(callback.callback())); |
- EXPECT_EQ(OK, callback.WaitForResult()); |
+ ASSERT_THAT(stream->Init(callback.callback()), IsError(ERR_IO_PENDING)); |
+ EXPECT_THAT(callback.WaitForResult(), IsOk()); |
} |
// Init() of a reader fails asynchronously. |
@@ -415,8 +419,8 @@ TEST_F(ElementsUploadDataStreamTest, InitAsyncFailureAsync) { |
// Run Init(). |
TestCompletionCallback callback; |
- ASSERT_EQ(ERR_IO_PENDING, stream->Init(callback.callback())); |
- EXPECT_EQ(ERR_FAILED, callback.WaitForResult()); |
+ ASSERT_THAT(stream->Init(callback.callback()), IsError(ERR_IO_PENDING)); |
+ EXPECT_THAT(callback.WaitForResult(), IsError(ERR_FAILED)); |
} |
// Init() of a reader fails synchronously. |
@@ -437,8 +441,8 @@ TEST_F(ElementsUploadDataStreamTest, InitAsyncFailureSync) { |
// Run Init(). |
TestCompletionCallback callback; |
- ASSERT_EQ(ERR_IO_PENDING, stream->Init(callback.callback())); |
- EXPECT_EQ(ERR_FAILED, callback.WaitForResult()); |
+ ASSERT_THAT(stream->Init(callback.callback()), IsError(ERR_IO_PENDING)); |
+ EXPECT_THAT(callback.WaitForResult(), IsError(ERR_FAILED)); |
} |
// Read with a buffer whose size is same as the data. |
@@ -448,7 +452,7 @@ TEST_F(ElementsUploadDataStreamTest, ReadAsyncWithExactSizeBuffer) { |
std::unique_ptr<UploadDataStream> stream( |
new ElementsUploadDataStream(std::move(element_readers_), 0)); |
- ASSERT_EQ(OK, stream->Init(CompletionCallback())); |
+ ASSERT_THAT(stream->Init(CompletionCallback()), IsOk()); |
EXPECT_TRUE(stream->IsInMemory()); |
EXPECT_EQ(kTestDataSize, stream->size()); |
EXPECT_EQ(0U, stream->position()); |
@@ -492,8 +496,8 @@ TEST_F(ElementsUploadDataStreamTest, ReadAsync) { |
// Run Init(). |
TestCompletionCallback init_callback; |
- EXPECT_EQ(ERR_IO_PENDING, stream->Init(init_callback.callback())); |
- EXPECT_EQ(OK, init_callback.WaitForResult()); |
+ EXPECT_THAT(stream->Init(init_callback.callback()), IsError(ERR_IO_PENDING)); |
+ EXPECT_THAT(init_callback.WaitForResult(), IsOk()); |
scoped_refptr<IOBuffer> buf = new IOBuffer(kTestBufferSize); |
@@ -532,12 +536,12 @@ void ElementsUploadDataStreamTest::FileChangedHelper( |
TestCompletionCallback init_callback; |
std::unique_ptr<UploadDataStream> stream( |
new ElementsUploadDataStream(std::move(element_readers), 0)); |
- ASSERT_EQ(ERR_IO_PENDING, stream->Init(init_callback.callback())); |
+ ASSERT_THAT(stream->Init(init_callback.callback()), IsError(ERR_IO_PENDING)); |
int error_code = init_callback.WaitForResult(); |
if (error_expected) |
- ASSERT_EQ(ERR_UPLOAD_FILE_CHANGED, error_code); |
+ ASSERT_THAT(error_code, IsError(ERR_UPLOAD_FILE_CHANGED)); |
else |
- ASSERT_EQ(OK, error_code); |
+ ASSERT_THAT(error_code, IsOk()); |
} |
TEST_F(ElementsUploadDataStreamTest, FileChanged) { |
@@ -580,8 +584,8 @@ TEST_F(ElementsUploadDataStreamTest, MultipleInit) { |
// Call Init(). |
TestCompletionCallback init_callback1; |
- ASSERT_EQ(ERR_IO_PENDING, stream->Init(init_callback1.callback())); |
- ASSERT_EQ(OK, init_callback1.WaitForResult()); |
+ ASSERT_THAT(stream->Init(init_callback1.callback()), IsError(ERR_IO_PENDING)); |
+ ASSERT_THAT(init_callback1.WaitForResult(), IsOk()); |
EXPECT_FALSE(stream->IsEOF()); |
EXPECT_EQ(kTestDataSize*2, stream->size()); |
@@ -591,8 +595,8 @@ TEST_F(ElementsUploadDataStreamTest, MultipleInit) { |
// Call Init() again to reset. |
TestCompletionCallback init_callback2; |
- ASSERT_EQ(ERR_IO_PENDING, stream->Init(init_callback2.callback())); |
- ASSERT_EQ(OK, init_callback2.WaitForResult()); |
+ ASSERT_THAT(stream->Init(init_callback2.callback()), IsError(ERR_IO_PENDING)); |
+ ASSERT_THAT(init_callback2.WaitForResult(), IsOk()); |
EXPECT_FALSE(stream->IsEOF()); |
EXPECT_EQ(kTestDataSize*2, stream->size()); |
@@ -622,8 +626,8 @@ TEST_F(ElementsUploadDataStreamTest, MultipleInitAsync) { |
expected_data += expected_data; |
// Call Init(). |
- ASSERT_EQ(ERR_IO_PENDING, stream->Init(test_callback.callback())); |
- EXPECT_EQ(OK, test_callback.WaitForResult()); |
+ ASSERT_THAT(stream->Init(test_callback.callback()), IsError(ERR_IO_PENDING)); |
+ EXPECT_THAT(test_callback.WaitForResult(), IsOk()); |
EXPECT_FALSE(stream->IsEOF()); |
EXPECT_EQ(kTestDataSize*2, stream->size()); |
@@ -632,8 +636,8 @@ TEST_F(ElementsUploadDataStreamTest, MultipleInitAsync) { |
EXPECT_TRUE(stream->IsEOF()); |
// Call Init() again to reset. |
- ASSERT_EQ(ERR_IO_PENDING, stream->Init(test_callback.callback())); |
- EXPECT_EQ(OK, test_callback.WaitForResult()); |
+ ASSERT_THAT(stream->Init(test_callback.callback()), IsError(ERR_IO_PENDING)); |
+ EXPECT_THAT(test_callback.WaitForResult(), IsOk()); |
EXPECT_FALSE(stream->IsEOF()); |
EXPECT_EQ(kTestDataSize*2, stream->size()); |
@@ -664,8 +668,8 @@ TEST_F(ElementsUploadDataStreamTest, InitToReset) { |
// Call Init(). |
TestCompletionCallback init_callback1; |
- ASSERT_EQ(ERR_IO_PENDING, stream->Init(init_callback1.callback())); |
- EXPECT_EQ(OK, init_callback1.WaitForResult()); |
+ ASSERT_THAT(stream->Init(init_callback1.callback()), IsError(ERR_IO_PENDING)); |
+ EXPECT_THAT(init_callback1.WaitForResult(), IsOk()); |
EXPECT_FALSE(stream->IsEOF()); |
EXPECT_EQ(kTestDataSize*2, stream->size()); |
@@ -682,8 +686,8 @@ TEST_F(ElementsUploadDataStreamTest, InitToReset) { |
// Call Init to reset the state. |
TestCompletionCallback init_callback2; |
- ASSERT_EQ(ERR_IO_PENDING, stream->Init(init_callback2.callback())); |
- EXPECT_EQ(OK, init_callback2.WaitForResult()); |
+ ASSERT_THAT(stream->Init(init_callback2.callback()), IsError(ERR_IO_PENDING)); |
+ EXPECT_THAT(init_callback2.WaitForResult(), IsOk()); |
EXPECT_FALSE(stream->IsEOF()); |
EXPECT_EQ(kTestDataSize*2, stream->size()); |
@@ -720,12 +724,12 @@ TEST_F(ElementsUploadDataStreamTest, InitDuringAsyncInit) { |
// Start Init. |
TestCompletionCallback init_callback1; |
- EXPECT_EQ(ERR_IO_PENDING, stream->Init(init_callback1.callback())); |
+ EXPECT_THAT(stream->Init(init_callback1.callback()), IsError(ERR_IO_PENDING)); |
// Call Init again to cancel the previous init. |
TestCompletionCallback init_callback2; |
- EXPECT_EQ(ERR_IO_PENDING, stream->Init(init_callback2.callback())); |
- EXPECT_EQ(OK, init_callback2.WaitForResult()); |
+ EXPECT_THAT(stream->Init(init_callback2.callback()), IsError(ERR_IO_PENDING)); |
+ EXPECT_THAT(init_callback2.WaitForResult(), IsOk()); |
EXPECT_FALSE(stream->IsEOF()); |
EXPECT_EQ(kTestDataSize*2, stream->size()); |
@@ -766,8 +770,8 @@ TEST_F(ElementsUploadDataStreamTest, InitDuringAsyncRead) { |
// Call Init(). |
TestCompletionCallback init_callback1; |
- ASSERT_EQ(ERR_IO_PENDING, stream->Init(init_callback1.callback())); |
- EXPECT_EQ(OK, init_callback1.WaitForResult()); |
+ ASSERT_THAT(stream->Init(init_callback1.callback()), IsError(ERR_IO_PENDING)); |
+ EXPECT_THAT(init_callback1.WaitForResult(), IsOk()); |
EXPECT_FALSE(stream->IsEOF()); |
EXPECT_EQ(kTestDataSize*2, stream->size()); |
@@ -782,8 +786,8 @@ TEST_F(ElementsUploadDataStreamTest, InitDuringAsyncRead) { |
// Call Init to cancel the previous read. |
TestCompletionCallback init_callback2; |
- EXPECT_EQ(ERR_IO_PENDING, stream->Init(init_callback2.callback())); |
- EXPECT_EQ(OK, init_callback2.WaitForResult()); |
+ EXPECT_THAT(stream->Init(init_callback2.callback()), IsError(ERR_IO_PENDING)); |
+ EXPECT_THAT(init_callback2.WaitForResult(), IsOk()); |
EXPECT_FALSE(stream->IsEOF()); |
EXPECT_EQ(kTestDataSize*2, stream->size()); |