| OLD | NEW |
| 1 // Copyright 2015 The Chromium Authors. All rights reserved. | 1 // Copyright 2015 The Chromium Authors. All rights reserved. |
| 2 // Use of this source code is governed by a BSD-style license that can be | 2 // Use of this source code is governed by a BSD-style license that can be |
| 3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
| 4 | 4 |
| 5 #include "modules/fetch/DataConsumerHandleUtil.h" | 5 #include "modules/fetch/DataConsumerHandleUtil.h" |
| 6 | 6 |
| 7 #include "modules/fetch/DataConsumerHandleTestUtil.h" | 7 #include "modules/fetch/DataConsumerHandleTestUtil.h" |
| 8 #include <memory> |
| 8 | 9 |
| 9 namespace blink { | 10 namespace blink { |
| 10 | 11 |
| 11 namespace { | 12 namespace { |
| 12 | 13 |
| 13 const WebDataConsumerHandle::Result kShouldWait = WebDataConsumerHandle::ShouldW
ait; | 14 const WebDataConsumerHandle::Result kShouldWait = WebDataConsumerHandle::ShouldW
ait; |
| 14 const WebDataConsumerHandle::Result kDone = WebDataConsumerHandle::Done; | 15 const WebDataConsumerHandle::Result kDone = WebDataConsumerHandle::Done; |
| 15 const WebDataConsumerHandle::Result kUnexpectedError = WebDataConsumerHandle::Un
expectedError; | 16 const WebDataConsumerHandle::Result kUnexpectedError = WebDataConsumerHandle::Un
expectedError; |
| 16 const WebDataConsumerHandle::Flags kNone = WebDataConsumerHandle::FlagNone; | 17 const WebDataConsumerHandle::Flags kNone = WebDataConsumerHandle::FlagNone; |
| 17 | 18 |
| 18 TEST(DataConsumerHandleUtilTest, CreateWaitingHandle) | 19 TEST(DataConsumerHandleUtilTest, CreateWaitingHandle) |
| 19 { | 20 { |
| 20 char buffer[20]; | 21 char buffer[20]; |
| 21 const void* p = nullptr; | 22 const void* p = nullptr; |
| 22 size_t size = 0; | 23 size_t size = 0; |
| 23 OwnPtr<WebDataConsumerHandle> handle = createWaitingDataConsumerHandle(); | 24 std::unique_ptr<WebDataConsumerHandle> handle = createWaitingDataConsumerHan
dle(); |
| 24 OwnPtr<WebDataConsumerHandle::Reader> reader = handle->obtainReader(nullptr)
; | 25 std::unique_ptr<WebDataConsumerHandle::Reader> reader = handle->obtainReader
(nullptr); |
| 25 | 26 |
| 26 EXPECT_EQ(kShouldWait, reader->read(buffer, sizeof(buffer), kNone, &size)); | 27 EXPECT_EQ(kShouldWait, reader->read(buffer, sizeof(buffer), kNone, &size)); |
| 27 EXPECT_EQ(kShouldWait, reader->beginRead(&p, kNone, &size)); | 28 EXPECT_EQ(kShouldWait, reader->beginRead(&p, kNone, &size)); |
| 28 EXPECT_EQ(kUnexpectedError, reader->endRead(99)); | 29 EXPECT_EQ(kUnexpectedError, reader->endRead(99)); |
| 29 } | 30 } |
| 30 | 31 |
| 31 TEST(DataConsumerHandleUtilTest, WaitingHandleNoNotification) | 32 TEST(DataConsumerHandleUtilTest, WaitingHandleNoNotification) |
| 32 { | 33 { |
| 33 RefPtr<DataConsumerHandleTestUtil::ThreadingHandleNoNotificationTest> test =
DataConsumerHandleTestUtil::ThreadingHandleNoNotificationTest::create(); | 34 RefPtr<DataConsumerHandleTestUtil::ThreadingHandleNoNotificationTest> test =
DataConsumerHandleTestUtil::ThreadingHandleNoNotificationTest::create(); |
| 34 // Test this function doesn't crash. | 35 // Test this function doesn't crash. |
| 35 test->run(createWaitingDataConsumerHandle()); | 36 test->run(createWaitingDataConsumerHandle()); |
| 36 } | 37 } |
| 37 | 38 |
| 38 TEST(DataConsumerHandleUtilTest, CreateDoneHandle) | 39 TEST(DataConsumerHandleUtilTest, CreateDoneHandle) |
| 39 { | 40 { |
| 40 char buffer[20]; | 41 char buffer[20]; |
| 41 const void* p = nullptr; | 42 const void* p = nullptr; |
| 42 size_t size = 0; | 43 size_t size = 0; |
| 43 OwnPtr<WebDataConsumerHandle> handle = createDoneDataConsumerHandle(); | 44 std::unique_ptr<WebDataConsumerHandle> handle = createDoneDataConsumerHandle
(); |
| 44 OwnPtr<WebDataConsumerHandle::Reader> reader = handle->obtainReader(nullptr)
; | 45 std::unique_ptr<WebDataConsumerHandle::Reader> reader = handle->obtainReader
(nullptr); |
| 45 | 46 |
| 46 EXPECT_EQ(kDone, reader->read(buffer, sizeof(buffer), kNone, &size)); | 47 EXPECT_EQ(kDone, reader->read(buffer, sizeof(buffer), kNone, &size)); |
| 47 EXPECT_EQ(kDone, reader->beginRead(&p, kNone, &size)); | 48 EXPECT_EQ(kDone, reader->beginRead(&p, kNone, &size)); |
| 48 EXPECT_EQ(kUnexpectedError, reader->endRead(99)); | 49 EXPECT_EQ(kUnexpectedError, reader->endRead(99)); |
| 49 } | 50 } |
| 50 | 51 |
| 51 TEST(DataConsumerHandleUtilTest, DoneHandleNotification) | 52 TEST(DataConsumerHandleUtilTest, DoneHandleNotification) |
| 52 { | 53 { |
| 53 RefPtr<DataConsumerHandleTestUtil::ThreadingHandleNotificationTest> test = D
ataConsumerHandleTestUtil::ThreadingHandleNotificationTest::create(); | 54 RefPtr<DataConsumerHandleTestUtil::ThreadingHandleNotificationTest> test = D
ataConsumerHandleTestUtil::ThreadingHandleNotificationTest::create(); |
| 54 // Test this function returns. | 55 // Test this function returns. |
| 55 test->run(createDoneDataConsumerHandle()); | 56 test->run(createDoneDataConsumerHandle()); |
| 56 } | 57 } |
| 57 | 58 |
| 58 TEST(DataConsumerHandleUtilTest, DoneHandleNoNotification) | 59 TEST(DataConsumerHandleUtilTest, DoneHandleNoNotification) |
| 59 { | 60 { |
| 60 RefPtr<DataConsumerHandleTestUtil::ThreadingHandleNoNotificationTest> test =
DataConsumerHandleTestUtil::ThreadingHandleNoNotificationTest::create(); | 61 RefPtr<DataConsumerHandleTestUtil::ThreadingHandleNoNotificationTest> test =
DataConsumerHandleTestUtil::ThreadingHandleNoNotificationTest::create(); |
| 61 // Test this function doesn't crash. | 62 // Test this function doesn't crash. |
| 62 test->run(createDoneDataConsumerHandle()); | 63 test->run(createDoneDataConsumerHandle()); |
| 63 } | 64 } |
| 64 | 65 |
| 65 TEST(DataConsumerHandleUtilTest, CreateUnexpectedErrorHandle) | 66 TEST(DataConsumerHandleUtilTest, CreateUnexpectedErrorHandle) |
| 66 { | 67 { |
| 67 char buffer[20]; | 68 char buffer[20]; |
| 68 const void* p = nullptr; | 69 const void* p = nullptr; |
| 69 size_t size = 0; | 70 size_t size = 0; |
| 70 OwnPtr<WebDataConsumerHandle> handle = createUnexpectedErrorDataConsumerHand
le(); | 71 std::unique_ptr<WebDataConsumerHandle> handle = createUnexpectedErrorDataCon
sumerHandle(); |
| 71 OwnPtr<WebDataConsumerHandle::Reader> reader = handle->obtainReader(nullptr)
; | 72 std::unique_ptr<WebDataConsumerHandle::Reader> reader = handle->obtainReader
(nullptr); |
| 72 | 73 |
| 73 EXPECT_EQ(kUnexpectedError, reader->read(buffer, sizeof(buffer), kNone, &siz
e)); | 74 EXPECT_EQ(kUnexpectedError, reader->read(buffer, sizeof(buffer), kNone, &siz
e)); |
| 74 EXPECT_EQ(kUnexpectedError, reader->beginRead(&p, kNone, &size)); | 75 EXPECT_EQ(kUnexpectedError, reader->beginRead(&p, kNone, &size)); |
| 75 EXPECT_EQ(kUnexpectedError, reader->endRead(99)); | 76 EXPECT_EQ(kUnexpectedError, reader->endRead(99)); |
| 76 } | 77 } |
| 77 | 78 |
| 78 TEST(DataConsumerHandleUtilTest, UnexpectedErrorHandleNotification) | 79 TEST(DataConsumerHandleUtilTest, UnexpectedErrorHandleNotification) |
| 79 { | 80 { |
| 80 RefPtr<DataConsumerHandleTestUtil::ThreadingHandleNotificationTest> test = D
ataConsumerHandleTestUtil::ThreadingHandleNotificationTest::create(); | 81 RefPtr<DataConsumerHandleTestUtil::ThreadingHandleNotificationTest> test = D
ataConsumerHandleTestUtil::ThreadingHandleNotificationTest::create(); |
| 81 // Test this function returns. | 82 // Test this function returns. |
| 82 test->run(createUnexpectedErrorDataConsumerHandle()); | 83 test->run(createUnexpectedErrorDataConsumerHandle()); |
| 83 } | 84 } |
| 84 | 85 |
| 85 TEST(DataConsumerHandleUtilTest, UnexpectedErrorHandleNoNotification) | 86 TEST(DataConsumerHandleUtilTest, UnexpectedErrorHandleNoNotification) |
| 86 { | 87 { |
| 87 RefPtr<DataConsumerHandleTestUtil::ThreadingHandleNoNotificationTest> test =
DataConsumerHandleTestUtil::ThreadingHandleNoNotificationTest::create(); | 88 RefPtr<DataConsumerHandleTestUtil::ThreadingHandleNoNotificationTest> test =
DataConsumerHandleTestUtil::ThreadingHandleNoNotificationTest::create(); |
| 88 // Test this function doesn't crash. | 89 // Test this function doesn't crash. |
| 89 test->run(createUnexpectedErrorDataConsumerHandle()); | 90 test->run(createUnexpectedErrorDataConsumerHandle()); |
| 90 } | 91 } |
| 91 | 92 |
| 92 } // namespace | 93 } // namespace |
| 93 | 94 |
| 94 } // namespace blink | 95 } // namespace blink |
| OLD | NEW |