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/FetchBlobDataConsumerHandle.h" | 5 #include "modules/fetch/FetchBlobDataConsumerHandle.h" |
6 | 6 |
7 #include "core/dom/ExecutionContext.h" | 7 #include "core/dom/ExecutionContext.h" |
8 #include "core/fetch/ResourceLoaderOptions.h" | 8 #include "core/fetch/ResourceLoaderOptions.h" |
9 #include "core/loader/MockThreadableLoader.h" | 9 #include "core/loader/MockThreadableLoader.h" |
10 #include "core/loader/ThreadableLoaderClient.h" | 10 #include "core/loader/ThreadableLoaderClient.h" |
11 #include "core/testing/DummyPageHolder.h" | 11 #include "core/testing/DummyPageHolder.h" |
12 #include "modules/fetch/DataConsumerHandleTestUtil.h" | 12 #include "modules/fetch/DataConsumerHandleTestUtil.h" |
13 #include "platform/blob/BlobData.h" | 13 #include "platform/blob/BlobData.h" |
14 #include "platform/blob/BlobURL.h" | 14 #include "platform/blob/BlobURL.h" |
15 #include "platform/network/ResourceError.h" | 15 #include "platform/network/ResourceError.h" |
16 #include "platform/network/ResourceRequest.h" | 16 #include "platform/network/ResourceRequest.h" |
17 #include "platform/network/ResourceResponse.h" | 17 #include "platform/network/ResourceResponse.h" |
18 #include "platform/testing/UnitTestHelpers.h" | 18 #include "platform/testing/UnitTestHelpers.h" |
19 #include "testing/gmock/include/gmock/gmock.h" | 19 #include "testing/gmock/include/gmock/gmock.h" |
20 #include "testing/gtest/include/gtest/gtest.h" | 20 #include "testing/gtest/include/gtest/gtest.h" |
21 #include "wtf/OwnPtr.h" | |
22 #include "wtf/PassRefPtr.h" | 21 #include "wtf/PassRefPtr.h" |
| 22 #include "wtf/PtrUtil.h" |
23 #include "wtf/RefPtr.h" | 23 #include "wtf/RefPtr.h" |
| 24 #include <memory> |
24 #include <string.h> | 25 #include <string.h> |
25 | 26 |
26 namespace blink { | 27 namespace blink { |
27 namespace { | 28 namespace { |
28 | 29 |
29 using Result = WebDataConsumerHandle::Result; | 30 using Result = WebDataConsumerHandle::Result; |
30 const Result kShouldWait = WebDataConsumerHandle::ShouldWait; | 31 const Result kShouldWait = WebDataConsumerHandle::ShouldWait; |
31 const Result kUnexpectedError = WebDataConsumerHandle::UnexpectedError; | 32 const Result kUnexpectedError = WebDataConsumerHandle::UnexpectedError; |
32 const Result kDone = WebDataConsumerHandle::Done; | 33 const Result kDone = WebDataConsumerHandle::Done; |
33 using Flags = WebDataConsumerHandle::Flags; | 34 using Flags = WebDataConsumerHandle::Flags; |
(...skipping 11 matching lines...) Expand all Loading... |
45 using ::testing::DoAll; | 46 using ::testing::DoAll; |
46 using ::testing::InSequence; | 47 using ::testing::InSequence; |
47 using ::testing::Ref; | 48 using ::testing::Ref; |
48 using ::testing::Return; | 49 using ::testing::Return; |
49 using ::testing::SaveArg; | 50 using ::testing::SaveArg; |
50 using ::testing::StrictMock; | 51 using ::testing::StrictMock; |
51 using Checkpoint = StrictMock<::testing::MockFunction<void(int)>>; | 52 using Checkpoint = StrictMock<::testing::MockFunction<void(int)>>; |
52 | 53 |
53 class MockLoaderFactory : public FetchBlobDataConsumerHandle::LoaderFactory { | 54 class MockLoaderFactory : public FetchBlobDataConsumerHandle::LoaderFactory { |
54 public: | 55 public: |
55 PassOwnPtr<ThreadableLoader> create(ExecutionContext& executionContext, Thre
adableLoaderClient* client, const ThreadableLoaderOptions& threadableLoaderOptio
ns, const ResourceLoaderOptions& resourceLoaderOptions) override | 56 std::unique_ptr<ThreadableLoader> create(ExecutionContext& executionContext,
ThreadableLoaderClient* client, const ThreadableLoaderOptions& threadableLoader
Options, const ResourceLoaderOptions& resourceLoaderOptions) override |
56 { | 57 { |
57 return adoptPtr(createInternal(executionContext, client, threadableLoade
rOptions, resourceLoaderOptions)); | 58 return wrapUnique(createInternal(executionContext, client, threadableLoa
derOptions, resourceLoaderOptions)); |
58 } | 59 } |
59 | 60 |
60 MOCK_METHOD4(createInternal, ThreadableLoader*(ExecutionContext&, Threadable
LoaderClient*, const ThreadableLoaderOptions&, const ResourceLoaderOptions&)); | 61 MOCK_METHOD4(createInternal, ThreadableLoader*(ExecutionContext&, Threadable
LoaderClient*, const ThreadableLoaderOptions&, const ResourceLoaderOptions&)); |
61 }; | 62 }; |
62 | 63 |
63 PassRefPtr<BlobDataHandle> createBlobDataHandle(const char* s) | 64 PassRefPtr<BlobDataHandle> createBlobDataHandle(const char* s) |
64 { | 65 { |
65 OwnPtr<BlobData> data = BlobData::create(); | 66 std::unique_ptr<BlobData> data = BlobData::create(); |
66 data->appendText(s, false); | 67 data->appendText(s, false); |
67 auto size = data->length(); | 68 auto size = data->length(); |
68 return BlobDataHandle::create(std::move(data), size); | 69 return BlobDataHandle::create(std::move(data), size); |
69 } | 70 } |
70 | 71 |
71 String toString(const Vector<char>& data) | 72 String toString(const Vector<char>& data) |
72 { | 73 { |
73 return String(data.data(), data.size()); | 74 return String(data.data(), data.size()); |
74 } | 75 } |
75 | 76 |
76 class FetchBlobDataConsumerHandleTest : public ::testing::Test { | 77 class FetchBlobDataConsumerHandleTest : public ::testing::Test { |
77 public: | 78 public: |
78 FetchBlobDataConsumerHandleTest() | 79 FetchBlobDataConsumerHandleTest() |
79 : m_dummyPageHolder(DummyPageHolder::create(IntSize(1, 1))) {} | 80 : m_dummyPageHolder(DummyPageHolder::create(IntSize(1, 1))) {} |
80 ~FetchBlobDataConsumerHandleTest() override | 81 ~FetchBlobDataConsumerHandleTest() override |
81 { | 82 { |
82 m_dummyPageHolder = nullptr; | 83 m_dummyPageHolder = nullptr; |
83 // We need this to collect garbage-collected mocks. | 84 // We need this to collect garbage-collected mocks. |
84 ThreadHeap::collectAllGarbage(); | 85 ThreadHeap::collectAllGarbage(); |
85 } | 86 } |
86 | 87 |
87 Document& document() { return m_dummyPageHolder->document(); } | 88 Document& document() { return m_dummyPageHolder->document(); } |
88 | 89 |
89 private: | 90 private: |
90 OwnPtr<DummyPageHolder> m_dummyPageHolder; | 91 std::unique_ptr<DummyPageHolder> m_dummyPageHolder; |
91 }; | 92 }; |
92 | 93 |
93 TEST_F(FetchBlobDataConsumerHandleTest, CreateLoader) | 94 TEST_F(FetchBlobDataConsumerHandleTest, CreateLoader) |
94 { | 95 { |
95 auto factory = new StrictMock<MockLoaderFactory>; | 96 auto factory = new StrictMock<MockLoaderFactory>; |
96 Checkpoint checkpoint; | 97 Checkpoint checkpoint; |
97 | 98 |
98 ResourceRequest request; | 99 ResourceRequest request; |
99 ThreadableLoaderOptions options; | 100 ThreadableLoaderOptions options; |
100 ResourceLoaderOptions resourceLoaderOptions; | 101 ResourceLoaderOptions resourceLoaderOptions; |
101 | 102 |
102 OwnPtr<MockThreadableLoader> loader = MockThreadableLoader::create(); | 103 std::unique_ptr<MockThreadableLoader> loader = MockThreadableLoader::create(
); |
103 MockThreadableLoader* loaderPtr = loader.get(); | 104 MockThreadableLoader* loaderPtr = loader.get(); |
104 | 105 |
105 InSequence s; | 106 InSequence s; |
106 EXPECT_CALL(checkpoint, Call(1)); | 107 EXPECT_CALL(checkpoint, Call(1)); |
107 EXPECT_CALL(*factory, createInternal(Ref(document()), _, _, _)).WillOnce(DoA
ll( | 108 EXPECT_CALL(*factory, createInternal(Ref(document()), _, _, _)).WillOnce(DoA
ll( |
108 SaveArg<2>(&options), | 109 SaveArg<2>(&options), |
109 SaveArg<3>(&resourceLoaderOptions), | 110 SaveArg<3>(&resourceLoaderOptions), |
110 Return(loader.leakPtr()))); | 111 Return(loader.release()))); |
111 EXPECT_CALL(*loaderPtr, start(_)).WillOnce(SaveArg<0>(&request)); | 112 EXPECT_CALL(*loaderPtr, start(_)).WillOnce(SaveArg<0>(&request)); |
112 EXPECT_CALL(checkpoint, Call(2)); | 113 EXPECT_CALL(checkpoint, Call(2)); |
113 EXPECT_CALL(*loaderPtr, cancel()); | 114 EXPECT_CALL(*loaderPtr, cancel()); |
114 | 115 |
115 RefPtr<BlobDataHandle> blobDataHandle = createBlobDataHandle("Once upon a ti
me"); | 116 RefPtr<BlobDataHandle> blobDataHandle = createBlobDataHandle("Once upon a ti
me"); |
116 OwnPtr<WebDataConsumerHandle> handle | 117 std::unique_ptr<WebDataConsumerHandle> handle |
117 = FetchBlobDataConsumerHandle::create(&document(), blobDataHandle, facto
ry); | 118 = FetchBlobDataConsumerHandle::create(&document(), blobDataHandle, facto
ry); |
118 testing::runPendingTasks(); | 119 testing::runPendingTasks(); |
119 | 120 |
120 size_t size = 0; | 121 size_t size = 0; |
121 handle->obtainReader(nullptr)->read(nullptr, 0, kNone, &size); | 122 handle->obtainReader(nullptr)->read(nullptr, 0, kNone, &size); |
122 checkpoint.Call(1); | 123 checkpoint.Call(1); |
123 testing::runPendingTasks(); | 124 testing::runPendingTasks(); |
124 checkpoint.Call(2); | 125 checkpoint.Call(2); |
125 | 126 |
126 EXPECT_TRUE(request.url().getString().startsWith("blob:")); | 127 EXPECT_TRUE(request.url().getString().startsWith("blob:")); |
(...skipping 10 matching lines...) Expand all Loading... |
137 EXPECT_EQ(DocumentContext, resourceLoaderOptions.requestInitiatorContext); | 138 EXPECT_EQ(DocumentContext, resourceLoaderOptions.requestInitiatorContext); |
138 EXPECT_EQ(RequestAsynchronously, resourceLoaderOptions.synchronousPolicy); | 139 EXPECT_EQ(RequestAsynchronously, resourceLoaderOptions.synchronousPolicy); |
139 EXPECT_EQ(NotCORSEnabled, resourceLoaderOptions.corsEnabled); | 140 EXPECT_EQ(NotCORSEnabled, resourceLoaderOptions.corsEnabled); |
140 } | 141 } |
141 | 142 |
142 TEST_F(FetchBlobDataConsumerHandleTest, CancelLoaderWhenStopped) | 143 TEST_F(FetchBlobDataConsumerHandleTest, CancelLoaderWhenStopped) |
143 { | 144 { |
144 auto factory = new StrictMock<MockLoaderFactory>; | 145 auto factory = new StrictMock<MockLoaderFactory>; |
145 Checkpoint checkpoint; | 146 Checkpoint checkpoint; |
146 | 147 |
147 OwnPtr<MockThreadableLoader> loader = MockThreadableLoader::create(); | 148 std::unique_ptr<MockThreadableLoader> loader = MockThreadableLoader::create(
); |
148 MockThreadableLoader* loaderPtr = loader.get(); | 149 MockThreadableLoader* loaderPtr = loader.get(); |
149 | 150 |
150 InSequence s; | 151 InSequence s; |
151 EXPECT_CALL(checkpoint, Call(1)); | 152 EXPECT_CALL(checkpoint, Call(1)); |
152 EXPECT_CALL(*factory, createInternal(Ref(document()), _, _, _)).WillOnce(Ret
urn(loader.leakPtr())); | 153 EXPECT_CALL(*factory, createInternal(Ref(document()), _, _, _)).WillOnce(Ret
urn(loader.release())); |
153 EXPECT_CALL(*loaderPtr, start(_)); | 154 EXPECT_CALL(*loaderPtr, start(_)); |
154 EXPECT_CALL(checkpoint, Call(2)); | 155 EXPECT_CALL(checkpoint, Call(2)); |
155 EXPECT_CALL(*loaderPtr, cancel()); | 156 EXPECT_CALL(*loaderPtr, cancel()); |
156 EXPECT_CALL(checkpoint, Call(3)); | 157 EXPECT_CALL(checkpoint, Call(3)); |
157 | 158 |
158 RefPtr<BlobDataHandle> blobDataHandle = createBlobDataHandle("Once upon a ti
me"); | 159 RefPtr<BlobDataHandle> blobDataHandle = createBlobDataHandle("Once upon a ti
me"); |
159 OwnPtr<WebDataConsumerHandle> handle | 160 std::unique_ptr<WebDataConsumerHandle> handle |
160 = FetchBlobDataConsumerHandle::create(&document(), blobDataHandle, facto
ry); | 161 = FetchBlobDataConsumerHandle::create(&document(), blobDataHandle, facto
ry); |
161 testing::runPendingTasks(); | 162 testing::runPendingTasks(); |
162 | 163 |
163 size_t size = 0; | 164 size_t size = 0; |
164 handle->obtainReader(nullptr)->read(nullptr, 0, kNone, &size); | 165 handle->obtainReader(nullptr)->read(nullptr, 0, kNone, &size); |
165 checkpoint.Call(1); | 166 checkpoint.Call(1); |
166 testing::runPendingTasks(); | 167 testing::runPendingTasks(); |
167 checkpoint.Call(2); | 168 checkpoint.Call(2); |
168 document().stopActiveDOMObjects(); | 169 document().stopActiveDOMObjects(); |
169 checkpoint.Call(3); | 170 checkpoint.Call(3); |
170 } | 171 } |
171 | 172 |
172 TEST_F(FetchBlobDataConsumerHandleTest, CancelLoaderWhenDestinationDetached) | 173 TEST_F(FetchBlobDataConsumerHandleTest, CancelLoaderWhenDestinationDetached) |
173 { | 174 { |
174 auto factory = new StrictMock<MockLoaderFactory>; | 175 auto factory = new StrictMock<MockLoaderFactory>; |
175 Checkpoint checkpoint; | 176 Checkpoint checkpoint; |
176 | 177 |
177 OwnPtr<MockThreadableLoader> loader = MockThreadableLoader::create(); | 178 std::unique_ptr<MockThreadableLoader> loader = MockThreadableLoader::create(
); |
178 MockThreadableLoader* loaderPtr = loader.get(); | 179 MockThreadableLoader* loaderPtr = loader.get(); |
179 | 180 |
180 InSequence s; | 181 InSequence s; |
181 EXPECT_CALL(checkpoint, Call(1)); | 182 EXPECT_CALL(checkpoint, Call(1)); |
182 EXPECT_CALL(*factory, createInternal(Ref(document()), _, _, _)).WillOnce(Ret
urn(loader.leakPtr())); | 183 EXPECT_CALL(*factory, createInternal(Ref(document()), _, _, _)).WillOnce(Ret
urn(loader.release())); |
183 EXPECT_CALL(*loaderPtr, start(_)); | 184 EXPECT_CALL(*loaderPtr, start(_)); |
184 EXPECT_CALL(checkpoint, Call(2)); | 185 EXPECT_CALL(checkpoint, Call(2)); |
185 EXPECT_CALL(checkpoint, Call(3)); | 186 EXPECT_CALL(checkpoint, Call(3)); |
186 EXPECT_CALL(*loaderPtr, cancel()); | 187 EXPECT_CALL(*loaderPtr, cancel()); |
187 EXPECT_CALL(checkpoint, Call(4)); | 188 EXPECT_CALL(checkpoint, Call(4)); |
188 | 189 |
189 RefPtr<BlobDataHandle> blobDataHandle = createBlobDataHandle("Once upon a ti
me"); | 190 RefPtr<BlobDataHandle> blobDataHandle = createBlobDataHandle("Once upon a ti
me"); |
190 OwnPtr<WebDataConsumerHandle> handle | 191 std::unique_ptr<WebDataConsumerHandle> handle |
191 = FetchBlobDataConsumerHandle::create(&document(), blobDataHandle, facto
ry); | 192 = FetchBlobDataConsumerHandle::create(&document(), blobDataHandle, facto
ry); |
192 OwnPtr<WebDataConsumerHandle::Reader> reader = handle->obtainReader(nullptr)
; | 193 std::unique_ptr<WebDataConsumerHandle::Reader> reader = handle->obtainReader
(nullptr); |
193 testing::runPendingTasks(); | 194 testing::runPendingTasks(); |
194 | 195 |
195 size_t size = 0; | 196 size_t size = 0; |
196 reader->read(nullptr, 0, kNone, &size); | 197 reader->read(nullptr, 0, kNone, &size); |
197 checkpoint.Call(1); | 198 checkpoint.Call(1); |
198 testing::runPendingTasks(); | 199 testing::runPendingTasks(); |
199 checkpoint.Call(2); | 200 checkpoint.Call(2); |
200 handle = nullptr; | 201 handle = nullptr; |
201 reader = nullptr; | 202 reader = nullptr; |
202 checkpoint.Call(3); | 203 checkpoint.Call(3); |
203 ThreadHeap::collectAllGarbage(); | 204 ThreadHeap::collectAllGarbage(); |
204 checkpoint.Call(4); | 205 checkpoint.Call(4); |
205 } | 206 } |
206 | 207 |
207 TEST_F(FetchBlobDataConsumerHandleTest, ReadTest) | 208 TEST_F(FetchBlobDataConsumerHandleTest, ReadTest) |
208 { | 209 { |
209 auto factory = new StrictMock<MockLoaderFactory>; | 210 auto factory = new StrictMock<MockLoaderFactory>; |
210 Checkpoint checkpoint; | 211 Checkpoint checkpoint; |
211 | 212 |
212 OwnPtr<MockThreadableLoader> loader = MockThreadableLoader::create(); | 213 std::unique_ptr<MockThreadableLoader> loader = MockThreadableLoader::create(
); |
213 MockThreadableLoader* loaderPtr = loader.get(); | 214 MockThreadableLoader* loaderPtr = loader.get(); |
214 ThreadableLoaderClient* client = nullptr; | 215 ThreadableLoaderClient* client = nullptr; |
215 | 216 |
216 InSequence s; | 217 InSequence s; |
217 EXPECT_CALL(checkpoint, Call(1)); | 218 EXPECT_CALL(checkpoint, Call(1)); |
218 EXPECT_CALL(*factory, createInternal(Ref(document()), _, _, _)).WillOnce(DoA
ll(SaveArg<1>(&client), Return(loader.leakPtr()))); | 219 EXPECT_CALL(*factory, createInternal(Ref(document()), _, _, _)).WillOnce(DoA
ll(SaveArg<1>(&client), Return(loader.release()))); |
219 EXPECT_CALL(*loaderPtr, start(_)); | 220 EXPECT_CALL(*loaderPtr, start(_)); |
220 EXPECT_CALL(checkpoint, Call(2)); | 221 EXPECT_CALL(checkpoint, Call(2)); |
221 EXPECT_CALL(*loaderPtr, cancel()); | 222 EXPECT_CALL(*loaderPtr, cancel()); |
222 | 223 |
223 RefPtr<BlobDataHandle> blobDataHandle = createBlobDataHandle("Once upon a ti
me"); | 224 RefPtr<BlobDataHandle> blobDataHandle = createBlobDataHandle("Once upon a ti
me"); |
224 OwnPtr<WebDataConsumerHandle> handle | 225 std::unique_ptr<WebDataConsumerHandle> handle |
225 = FetchBlobDataConsumerHandle::create(&document(), blobDataHandle, facto
ry); | 226 = FetchBlobDataConsumerHandle::create(&document(), blobDataHandle, facto
ry); |
226 | 227 |
227 OwnPtr<ReplayingHandle> src = ReplayingHandle::create(); | 228 std::unique_ptr<ReplayingHandle> src = ReplayingHandle::create(); |
228 src->add(Command(Command::Wait)); | 229 src->add(Command(Command::Wait)); |
229 src->add(Command(Command::Data, "hello, ")); | 230 src->add(Command(Command::Data, "hello, ")); |
230 src->add(Command(Command::Data, "world")); | 231 src->add(Command(Command::Data, "world")); |
231 src->add(Command(Command::Wait)); | 232 src->add(Command(Command::Wait)); |
232 src->add(Command(Command::Done)); | 233 src->add(Command(Command::Done)); |
233 | 234 |
234 size_t size = 0; | 235 size_t size = 0; |
235 handle->obtainReader(nullptr)->read(nullptr, 0, kNone, &size); | 236 handle->obtainReader(nullptr)->read(nullptr, 0, kNone, &size); |
236 checkpoint.Call(1); | 237 checkpoint.Call(1); |
237 testing::runPendingTasks(); | 238 testing::runPendingTasks(); |
238 checkpoint.Call(2); | 239 checkpoint.Call(2); |
239 client->didReceiveResponse(0, ResourceResponse(), std::move(src)); | 240 client->didReceiveResponse(0, ResourceResponse(), std::move(src)); |
240 HandleReaderRunner<HandleReader> runner(std::move(handle)); | 241 HandleReaderRunner<HandleReader> runner(std::move(handle)); |
241 OwnPtr<HandleReadResult> r = runner.wait(); | 242 std::unique_ptr<HandleReadResult> r = runner.wait(); |
242 EXPECT_EQ(kDone, r->result()); | 243 EXPECT_EQ(kDone, r->result()); |
243 EXPECT_EQ("hello, world", toString(r->data())); | 244 EXPECT_EQ("hello, world", toString(r->data())); |
244 } | 245 } |
245 | 246 |
246 TEST_F(FetchBlobDataConsumerHandleTest, TwoPhaseReadTest) | 247 TEST_F(FetchBlobDataConsumerHandleTest, TwoPhaseReadTest) |
247 { | 248 { |
248 auto factory = new StrictMock<MockLoaderFactory>; | 249 auto factory = new StrictMock<MockLoaderFactory>; |
249 Checkpoint checkpoint; | 250 Checkpoint checkpoint; |
250 | 251 |
251 OwnPtr<MockThreadableLoader> loader = MockThreadableLoader::create(); | 252 std::unique_ptr<MockThreadableLoader> loader = MockThreadableLoader::create(
); |
252 MockThreadableLoader* loaderPtr = loader.get(); | 253 MockThreadableLoader* loaderPtr = loader.get(); |
253 ThreadableLoaderClient* client = nullptr; | 254 ThreadableLoaderClient* client = nullptr; |
254 | 255 |
255 InSequence s; | 256 InSequence s; |
256 EXPECT_CALL(checkpoint, Call(1)); | 257 EXPECT_CALL(checkpoint, Call(1)); |
257 EXPECT_CALL(*factory, createInternal(Ref(document()), _, _, _)).WillOnce(DoA
ll(SaveArg<1>(&client), Return(loader.leakPtr()))); | 258 EXPECT_CALL(*factory, createInternal(Ref(document()), _, _, _)).WillOnce(DoA
ll(SaveArg<1>(&client), Return(loader.release()))); |
258 EXPECT_CALL(*loaderPtr, start(_)); | 259 EXPECT_CALL(*loaderPtr, start(_)); |
259 EXPECT_CALL(checkpoint, Call(2)); | 260 EXPECT_CALL(checkpoint, Call(2)); |
260 EXPECT_CALL(*loaderPtr, cancel()); | 261 EXPECT_CALL(*loaderPtr, cancel()); |
261 | 262 |
262 RefPtr<BlobDataHandle> blobDataHandle = createBlobDataHandle("Once upon a ti
me"); | 263 RefPtr<BlobDataHandle> blobDataHandle = createBlobDataHandle("Once upon a ti
me"); |
263 OwnPtr<WebDataConsumerHandle> handle | 264 std::unique_ptr<WebDataConsumerHandle> handle |
264 = FetchBlobDataConsumerHandle::create(&document(), blobDataHandle, facto
ry); | 265 = FetchBlobDataConsumerHandle::create(&document(), blobDataHandle, facto
ry); |
265 | 266 |
266 OwnPtr<ReplayingHandle> src = ReplayingHandle::create(); | 267 std::unique_ptr<ReplayingHandle> src = ReplayingHandle::create(); |
267 src->add(Command(Command::Wait)); | 268 src->add(Command(Command::Wait)); |
268 src->add(Command(Command::Data, "hello, ")); | 269 src->add(Command(Command::Data, "hello, ")); |
269 src->add(Command(Command::Data, "world")); | 270 src->add(Command(Command::Data, "world")); |
270 src->add(Command(Command::Wait)); | 271 src->add(Command(Command::Wait)); |
271 src->add(Command(Command::Done)); | 272 src->add(Command(Command::Done)); |
272 | 273 |
273 size_t size = 0; | 274 size_t size = 0; |
274 handle->obtainReader(nullptr)->read(nullptr, 0, kNone, &size); | 275 handle->obtainReader(nullptr)->read(nullptr, 0, kNone, &size); |
275 checkpoint.Call(1); | 276 checkpoint.Call(1); |
276 testing::runPendingTasks(); | 277 testing::runPendingTasks(); |
277 checkpoint.Call(2); | 278 checkpoint.Call(2); |
278 client->didReceiveResponse(0, ResourceResponse(), std::move(src)); | 279 client->didReceiveResponse(0, ResourceResponse(), std::move(src)); |
279 HandleReaderRunner<HandleTwoPhaseReader> runner(std::move(handle)); | 280 HandleReaderRunner<HandleTwoPhaseReader> runner(std::move(handle)); |
280 OwnPtr<HandleReadResult> r = runner.wait(); | 281 std::unique_ptr<HandleReadResult> r = runner.wait(); |
281 EXPECT_EQ(kDone, r->result()); | 282 EXPECT_EQ(kDone, r->result()); |
282 EXPECT_EQ("hello, world", toString(r->data())); | 283 EXPECT_EQ("hello, world", toString(r->data())); |
283 } | 284 } |
284 | 285 |
285 TEST_F(FetchBlobDataConsumerHandleTest, LoadErrorTest) | 286 TEST_F(FetchBlobDataConsumerHandleTest, LoadErrorTest) |
286 { | 287 { |
287 auto factory = new StrictMock<MockLoaderFactory>; | 288 auto factory = new StrictMock<MockLoaderFactory>; |
288 Checkpoint checkpoint; | 289 Checkpoint checkpoint; |
289 | 290 |
290 OwnPtr<MockThreadableLoader> loader = MockThreadableLoader::create(); | 291 std::unique_ptr<MockThreadableLoader> loader = MockThreadableLoader::create(
); |
291 MockThreadableLoader* loaderPtr = loader.get(); | 292 MockThreadableLoader* loaderPtr = loader.get(); |
292 ThreadableLoaderClient* client = nullptr; | 293 ThreadableLoaderClient* client = nullptr; |
293 | 294 |
294 InSequence s; | 295 InSequence s; |
295 EXPECT_CALL(checkpoint, Call(1)); | 296 EXPECT_CALL(checkpoint, Call(1)); |
296 EXPECT_CALL(*factory, createInternal(Ref(document()), _, _, _)).WillOnce(DoA
ll(SaveArg<1>(&client), Return(loader.leakPtr()))); | 297 EXPECT_CALL(*factory, createInternal(Ref(document()), _, _, _)).WillOnce(DoA
ll(SaveArg<1>(&client), Return(loader.release()))); |
297 EXPECT_CALL(*loaderPtr, start(_)); | 298 EXPECT_CALL(*loaderPtr, start(_)); |
298 EXPECT_CALL(checkpoint, Call(2)); | 299 EXPECT_CALL(checkpoint, Call(2)); |
299 | 300 |
300 RefPtr<BlobDataHandle> blobDataHandle = createBlobDataHandle("Once upon a ti
me"); | 301 RefPtr<BlobDataHandle> blobDataHandle = createBlobDataHandle("Once upon a ti
me"); |
301 OwnPtr<WebDataConsumerHandle> handle | 302 std::unique_ptr<WebDataConsumerHandle> handle |
302 = FetchBlobDataConsumerHandle::create(&document(), blobDataHandle, facto
ry); | 303 = FetchBlobDataConsumerHandle::create(&document(), blobDataHandle, facto
ry); |
303 | 304 |
304 size_t size = 0; | 305 size_t size = 0; |
305 handle->obtainReader(nullptr)->read(nullptr, 0, kNone, &size); | 306 handle->obtainReader(nullptr)->read(nullptr, 0, kNone, &size); |
306 checkpoint.Call(1); | 307 checkpoint.Call(1); |
307 testing::runPendingTasks(); | 308 testing::runPendingTasks(); |
308 checkpoint.Call(2); | 309 checkpoint.Call(2); |
309 client->didFail(ResourceError()); | 310 client->didFail(ResourceError()); |
310 HandleReaderRunner<HandleReader> runner(std::move(handle)); | 311 HandleReaderRunner<HandleReader> runner(std::move(handle)); |
311 OwnPtr<HandleReadResult> r = runner.wait(); | 312 std::unique_ptr<HandleReadResult> r = runner.wait(); |
312 EXPECT_EQ(kUnexpectedError, r->result()); | 313 EXPECT_EQ(kUnexpectedError, r->result()); |
313 } | 314 } |
314 | 315 |
315 TEST_F(FetchBlobDataConsumerHandleTest, BodyLoadErrorTest) | 316 TEST_F(FetchBlobDataConsumerHandleTest, BodyLoadErrorTest) |
316 { | 317 { |
317 auto factory = new StrictMock<MockLoaderFactory>; | 318 auto factory = new StrictMock<MockLoaderFactory>; |
318 Checkpoint checkpoint; | 319 Checkpoint checkpoint; |
319 | 320 |
320 OwnPtr<MockThreadableLoader> loader = MockThreadableLoader::create(); | 321 std::unique_ptr<MockThreadableLoader> loader = MockThreadableLoader::create(
); |
321 MockThreadableLoader* loaderPtr = loader.get(); | 322 MockThreadableLoader* loaderPtr = loader.get(); |
322 ThreadableLoaderClient* client = nullptr; | 323 ThreadableLoaderClient* client = nullptr; |
323 | 324 |
324 InSequence s; | 325 InSequence s; |
325 EXPECT_CALL(checkpoint, Call(1)); | 326 EXPECT_CALL(checkpoint, Call(1)); |
326 EXPECT_CALL(*factory, createInternal(Ref(document()), _, _, _)).WillOnce(DoA
ll(SaveArg<1>(&client), Return(loader.leakPtr()))); | 327 EXPECT_CALL(*factory, createInternal(Ref(document()), _, _, _)).WillOnce(DoA
ll(SaveArg<1>(&client), Return(loader.release()))); |
327 EXPECT_CALL(*loaderPtr, start(_)); | 328 EXPECT_CALL(*loaderPtr, start(_)); |
328 EXPECT_CALL(checkpoint, Call(2)); | 329 EXPECT_CALL(checkpoint, Call(2)); |
329 EXPECT_CALL(*loaderPtr, cancel()); | 330 EXPECT_CALL(*loaderPtr, cancel()); |
330 | 331 |
331 RefPtr<BlobDataHandle> blobDataHandle = createBlobDataHandle("Once upon a ti
me"); | 332 RefPtr<BlobDataHandle> blobDataHandle = createBlobDataHandle("Once upon a ti
me"); |
332 OwnPtr<WebDataConsumerHandle> handle | 333 std::unique_ptr<WebDataConsumerHandle> handle |
333 = FetchBlobDataConsumerHandle::create(&document(), blobDataHandle, facto
ry); | 334 = FetchBlobDataConsumerHandle::create(&document(), blobDataHandle, facto
ry); |
334 | 335 |
335 OwnPtr<ReplayingHandle> src = ReplayingHandle::create(); | 336 std::unique_ptr<ReplayingHandle> src = ReplayingHandle::create(); |
336 src->add(Command(Command::Wait)); | 337 src->add(Command(Command::Wait)); |
337 src->add(Command(Command::Data, "hello, ")); | 338 src->add(Command(Command::Data, "hello, ")); |
338 src->add(Command(Command::Error)); | 339 src->add(Command(Command::Error)); |
339 | 340 |
340 size_t size = 0; | 341 size_t size = 0; |
341 handle->obtainReader(nullptr)->read(nullptr, 0, kNone, &size); | 342 handle->obtainReader(nullptr)->read(nullptr, 0, kNone, &size); |
342 checkpoint.Call(1); | 343 checkpoint.Call(1); |
343 testing::runPendingTasks(); | 344 testing::runPendingTasks(); |
344 checkpoint.Call(2); | 345 checkpoint.Call(2); |
345 client->didReceiveResponse(0, ResourceResponse(), std::move(src)); | 346 client->didReceiveResponse(0, ResourceResponse(), std::move(src)); |
346 HandleReaderRunner<HandleReader> runner(std::move(handle)); | 347 HandleReaderRunner<HandleReader> runner(std::move(handle)); |
347 OwnPtr<HandleReadResult> r = runner.wait(); | 348 std::unique_ptr<HandleReadResult> r = runner.wait(); |
348 EXPECT_EQ(kUnexpectedError, r->result()); | 349 EXPECT_EQ(kUnexpectedError, r->result()); |
349 } | 350 } |
350 | 351 |
351 TEST_F(FetchBlobDataConsumerHandleTest, DrainAsBlobDataHandle) | 352 TEST_F(FetchBlobDataConsumerHandleTest, DrainAsBlobDataHandle) |
352 { | 353 { |
353 auto factory = new StrictMock<MockLoaderFactory>; | 354 auto factory = new StrictMock<MockLoaderFactory>; |
354 | 355 |
355 RefPtr<BlobDataHandle> blobDataHandle = createBlobDataHandle("Once upon a ti
me"); | 356 RefPtr<BlobDataHandle> blobDataHandle = createBlobDataHandle("Once upon a ti
me"); |
356 OwnPtr<FetchDataConsumerHandle> handle | 357 std::unique_ptr<FetchDataConsumerHandle> handle |
357 = FetchBlobDataConsumerHandle::create(&document(), blobDataHandle, facto
ry); | 358 = FetchBlobDataConsumerHandle::create(&document(), blobDataHandle, facto
ry); |
358 | 359 |
359 size_t size = 0; | 360 size_t size = 0; |
360 EXPECT_EQ(blobDataHandle, handle->obtainReader(nullptr)->drainAsBlobDataHand
le()); | 361 EXPECT_EQ(blobDataHandle, handle->obtainReader(nullptr)->drainAsBlobDataHand
le()); |
361 EXPECT_FALSE(handle->obtainReader(nullptr)->drainAsFormData()); | 362 EXPECT_FALSE(handle->obtainReader(nullptr)->drainAsFormData()); |
362 | 363 |
363 EXPECT_EQ(kDone, handle->obtainReader(nullptr)->read(nullptr, 0, kNone, &siz
e)); | 364 EXPECT_EQ(kDone, handle->obtainReader(nullptr)->read(nullptr, 0, kNone, &siz
e)); |
364 } | 365 } |
365 | 366 |
366 TEST_F(FetchBlobDataConsumerHandleTest, DrainAsFormData) | 367 TEST_F(FetchBlobDataConsumerHandleTest, DrainAsFormData) |
367 { | 368 { |
368 auto factory = new StrictMock<MockLoaderFactory>; | 369 auto factory = new StrictMock<MockLoaderFactory>; |
369 | 370 |
370 RefPtr<BlobDataHandle> blobDataHandle = createBlobDataHandle("Once upon a ti
me"); | 371 RefPtr<BlobDataHandle> blobDataHandle = createBlobDataHandle("Once upon a ti
me"); |
371 OwnPtr<FetchDataConsumerHandle> handle | 372 std::unique_ptr<FetchDataConsumerHandle> handle |
372 = FetchBlobDataConsumerHandle::create(&document(), blobDataHandle, facto
ry); | 373 = FetchBlobDataConsumerHandle::create(&document(), blobDataHandle, facto
ry); |
373 | 374 |
374 RefPtr<EncodedFormData> formData = handle->obtainReader(nullptr)->drainAsFor
mData(); | 375 RefPtr<EncodedFormData> formData = handle->obtainReader(nullptr)->drainAsFor
mData(); |
375 ASSERT_TRUE(formData); | 376 ASSERT_TRUE(formData); |
376 EXPECT_TRUE(formData->isSafeToSendToAnotherThread()); | 377 EXPECT_TRUE(formData->isSafeToSendToAnotherThread()); |
377 ASSERT_EQ(1u, formData->elements().size()); | 378 ASSERT_EQ(1u, formData->elements().size()); |
378 EXPECT_EQ(FormDataElement::encodedBlob, formData->elements()[0].m_type); | 379 EXPECT_EQ(FormDataElement::encodedBlob, formData->elements()[0].m_type); |
379 EXPECT_EQ(blobDataHandle->uuid(), formData->elements()[0].m_blobUUID); | 380 EXPECT_EQ(blobDataHandle->uuid(), formData->elements()[0].m_blobUUID); |
380 EXPECT_EQ(blobDataHandle, formData->elements()[0].m_optionalBlobDataHandle); | 381 EXPECT_EQ(blobDataHandle, formData->elements()[0].m_optionalBlobDataHandle); |
381 | 382 |
382 EXPECT_FALSE(handle->obtainReader(nullptr)->drainAsBlobDataHandle()); | 383 EXPECT_FALSE(handle->obtainReader(nullptr)->drainAsBlobDataHandle()); |
383 size_t size; | 384 size_t size; |
384 EXPECT_EQ(kDone, handle->obtainReader(nullptr)->read(nullptr, 0, kNone, &siz
e)); | 385 EXPECT_EQ(kDone, handle->obtainReader(nullptr)->read(nullptr, 0, kNone, &siz
e)); |
385 } | 386 } |
386 | 387 |
387 TEST_F(FetchBlobDataConsumerHandleTest, ZeroByteReadDoesNotAffectDraining) | 388 TEST_F(FetchBlobDataConsumerHandleTest, ZeroByteReadDoesNotAffectDraining) |
388 { | 389 { |
389 auto factory = new StrictMock<MockLoaderFactory>; | 390 auto factory = new StrictMock<MockLoaderFactory>; |
390 | 391 |
391 RefPtr<BlobDataHandle> blobDataHandle = createBlobDataHandle("Once upon a ti
me"); | 392 RefPtr<BlobDataHandle> blobDataHandle = createBlobDataHandle("Once upon a ti
me"); |
392 OwnPtr<FetchDataConsumerHandle> handle | 393 std::unique_ptr<FetchDataConsumerHandle> handle |
393 = FetchBlobDataConsumerHandle::create(&document(), blobDataHandle, facto
ry); | 394 = FetchBlobDataConsumerHandle::create(&document(), blobDataHandle, facto
ry); |
394 OwnPtr<FetchDataConsumerHandle::Reader> reader = handle->obtainReader(nullpt
r); | 395 std::unique_ptr<FetchDataConsumerHandle::Reader> reader = handle->obtainRead
er(nullptr); |
395 | 396 |
396 size_t readSize; | 397 size_t readSize; |
397 EXPECT_EQ(kShouldWait, reader->read(nullptr, 0, kNone, &readSize)); | 398 EXPECT_EQ(kShouldWait, reader->read(nullptr, 0, kNone, &readSize)); |
398 EXPECT_EQ(blobDataHandle, reader->drainAsBlobDataHandle()); | 399 EXPECT_EQ(blobDataHandle, reader->drainAsBlobDataHandle()); |
399 } | 400 } |
400 | 401 |
401 TEST_F(FetchBlobDataConsumerHandleTest, OneByteReadAffectsDraining) | 402 TEST_F(FetchBlobDataConsumerHandleTest, OneByteReadAffectsDraining) |
402 { | 403 { |
403 auto factory = new StrictMock<MockLoaderFactory>; | 404 auto factory = new StrictMock<MockLoaderFactory>; |
404 | 405 |
405 RefPtr<BlobDataHandle> blobDataHandle = createBlobDataHandle("Once upon a ti
me"); | 406 RefPtr<BlobDataHandle> blobDataHandle = createBlobDataHandle("Once upon a ti
me"); |
406 OwnPtr<FetchDataConsumerHandle> handle | 407 std::unique_ptr<FetchDataConsumerHandle> handle |
407 = FetchBlobDataConsumerHandle::create(&document(), blobDataHandle, facto
ry); | 408 = FetchBlobDataConsumerHandle::create(&document(), blobDataHandle, facto
ry); |
408 OwnPtr<FetchDataConsumerHandle::Reader> reader = handle->obtainReader(nullpt
r); | 409 std::unique_ptr<FetchDataConsumerHandle::Reader> reader = handle->obtainRead
er(nullptr); |
409 | 410 |
410 size_t readSize; | 411 size_t readSize; |
411 char c; | 412 char c; |
412 EXPECT_EQ(kShouldWait, reader->read(&c, 1, kNone, &readSize)); | 413 EXPECT_EQ(kShouldWait, reader->read(&c, 1, kNone, &readSize)); |
413 EXPECT_FALSE(reader->drainAsFormData()); | 414 EXPECT_FALSE(reader->drainAsFormData()); |
414 } | 415 } |
415 | 416 |
416 TEST_F(FetchBlobDataConsumerHandleTest, BeginReadAffectsDraining) | 417 TEST_F(FetchBlobDataConsumerHandleTest, BeginReadAffectsDraining) |
417 { | 418 { |
418 auto factory = new StrictMock<MockLoaderFactory>; | 419 auto factory = new StrictMock<MockLoaderFactory>; |
419 | 420 |
420 RefPtr<BlobDataHandle> blobDataHandle = createBlobDataHandle("Once upon a ti
me"); | 421 RefPtr<BlobDataHandle> blobDataHandle = createBlobDataHandle("Once upon a ti
me"); |
421 OwnPtr<FetchDataConsumerHandle> handle | 422 std::unique_ptr<FetchDataConsumerHandle> handle |
422 = FetchBlobDataConsumerHandle::create(&document(), blobDataHandle, facto
ry); | 423 = FetchBlobDataConsumerHandle::create(&document(), blobDataHandle, facto
ry); |
423 OwnPtr<FetchDataConsumerHandle::Reader> reader = handle->obtainReader(nullpt
r); | 424 std::unique_ptr<FetchDataConsumerHandle::Reader> reader = handle->obtainRead
er(nullptr); |
424 | 425 |
425 const void* buffer; | 426 const void* buffer; |
426 size_t available; | 427 size_t available; |
427 EXPECT_EQ(kShouldWait, reader->beginRead(&buffer, kNone, &available)); | 428 EXPECT_EQ(kShouldWait, reader->beginRead(&buffer, kNone, &available)); |
428 EXPECT_FALSE(reader->drainAsBlobDataHandle()); | 429 EXPECT_FALSE(reader->drainAsBlobDataHandle()); |
429 } | 430 } |
430 | 431 |
431 } // namespace | 432 } // namespace |
432 } // namespace blink | 433 } // namespace blink |
OLD | NEW |