Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(701)

Side by Side Diff: third_party/WebKit/Source/modules/fetch/FetchFormDataConsumerHandleTest.cpp

Issue 2172183003: Return unique_ptr<WebDataConsumerHandle::Reader> directly from obtainReader (Closed) Base URL: https://chromium.googlesource.com/chromium/src.git@gmock_cxx11
Patch Set: rebase Created 4 years, 4 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View unified diff | Download patch
OLDNEW
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/FetchFormDataConsumerHandle.h" 5 #include "modules/fetch/FetchFormDataConsumerHandle.h"
6 6
7 #include "core/dom/DOMTypedArray.h" 7 #include "core/dom/DOMTypedArray.h"
8 #include "core/html/FormData.h" 8 #include "core/html/FormData.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"
(...skipping 219 matching lines...) Expand 10 before | Expand all | Expand 10 after
230 HandleReaderRunner<HandleTwoPhaseReader> runner(std::move(handle)); 230 HandleReaderRunner<HandleTwoPhaseReader> runner(std::move(handle));
231 testing::runPendingTasks(); 231 testing::runPendingTasks();
232 std::unique_ptr<HandleReadResult> r = runner.wait(); 232 std::unique_ptr<HandleReadResult> r = runner.wait();
233 EXPECT_EQ(kDone, r->result()); 233 EXPECT_EQ(kDone, r->result());
234 EXPECT_EQ("bar", toString(r->data())); 234 EXPECT_EQ("bar", toString(r->data()));
235 } 235 }
236 236
237 TEST_F(FetchFormDataConsumerHandleTest, DrainAsBlobDataHandleFromString) 237 TEST_F(FetchFormDataConsumerHandleTest, DrainAsBlobDataHandleFromString)
238 { 238 {
239 std::unique_ptr<FetchDataConsumerHandle> handle = FetchFormDataConsumerHandl e::create(String("hello, world")); 239 std::unique_ptr<FetchDataConsumerHandle> handle = FetchFormDataConsumerHandl e::create(String("hello, world"));
240 std::unique_ptr<FetchDataConsumerHandle::Reader> reader = handle->obtainRead er(nullptr); 240 std::unique_ptr<FetchDataConsumerHandle::Reader> reader = handle->obtainFetc hDataReader(nullptr);
241 RefPtr<BlobDataHandle> blobDataHandle = reader->drainAsBlobDataHandle(); 241 RefPtr<BlobDataHandle> blobDataHandle = reader->drainAsBlobDataHandle();
242 ASSERT_TRUE(blobDataHandle); 242 ASSERT_TRUE(blobDataHandle);
243 243
244 EXPECT_EQ(String(), blobDataHandle->type()); 244 EXPECT_EQ(String(), blobDataHandle->type());
245 EXPECT_EQ(12u, blobDataHandle->size()); 245 EXPECT_EQ(12u, blobDataHandle->size());
246 EXPECT_EQ(nullptr, reader->drainAsFormData()); 246 EXPECT_EQ(nullptr, reader->drainAsFormData());
247 char c; 247 char c;
248 size_t readSize; 248 size_t readSize;
249 EXPECT_EQ(kDone, reader->read(&c, 1, kNone, &readSize)); 249 EXPECT_EQ(kDone, reader->read(&c, 1, kNone, &readSize));
250 } 250 }
251 251
252 TEST_F(FetchFormDataConsumerHandleTest, DrainAsBlobDataHandleFromArrayBuffer) 252 TEST_F(FetchFormDataConsumerHandleTest, DrainAsBlobDataHandleFromArrayBuffer)
253 { 253 {
254 std::unique_ptr<FetchDataConsumerHandle> handle = FetchFormDataConsumerHandl e::create(DOMArrayBuffer::create("foo", 3)); 254 std::unique_ptr<FetchDataConsumerHandle> handle = FetchFormDataConsumerHandl e::create(DOMArrayBuffer::create("foo", 3));
255 std::unique_ptr<FetchDataConsumerHandle::Reader> reader = handle->obtainRead er(nullptr); 255 std::unique_ptr<FetchDataConsumerHandle::Reader> reader = handle->obtainFetc hDataReader(nullptr);
256 RefPtr<BlobDataHandle> blobDataHandle = reader->drainAsBlobDataHandle(); 256 RefPtr<BlobDataHandle> blobDataHandle = reader->drainAsBlobDataHandle();
257 ASSERT_TRUE(blobDataHandle); 257 ASSERT_TRUE(blobDataHandle);
258 258
259 EXPECT_EQ(String(), blobDataHandle->type()); 259 EXPECT_EQ(String(), blobDataHandle->type());
260 EXPECT_EQ(3u, blobDataHandle->size()); 260 EXPECT_EQ(3u, blobDataHandle->size());
261 EXPECT_EQ(nullptr, reader->drainAsFormData()); 261 EXPECT_EQ(nullptr, reader->drainAsFormData());
262 char c; 262 char c;
263 size_t readSize; 263 size_t readSize;
264 EXPECT_EQ(kDone, reader->read(&c, 1, kNone, &readSize)); 264 EXPECT_EQ(kDone, reader->read(&c, 1, kNone, &readSize));
265 } 265 }
266 266
267 TEST_F(FetchFormDataConsumerHandleTest, DrainAsBlobDataHandleFromSimpleFormData) 267 TEST_F(FetchFormDataConsumerHandleTest, DrainAsBlobDataHandleFromSimpleFormData)
268 { 268 {
269 FormData* data = FormData::create(UTF8Encoding()); 269 FormData* data = FormData::create(UTF8Encoding());
270 data->append("name1", "value1"); 270 data->append("name1", "value1");
271 data->append("name2", "value2"); 271 data->append("name2", "value2");
272 RefPtr<EncodedFormData> inputFormData = data->encodeMultiPartFormData(); 272 RefPtr<EncodedFormData> inputFormData = data->encodeMultiPartFormData();
273 273
274 std::unique_ptr<FetchDataConsumerHandle> handle = FetchFormDataConsumerHandl e::create(getDocument(), inputFormData); 274 std::unique_ptr<FetchDataConsumerHandle> handle = FetchFormDataConsumerHandl e::create(getDocument(), inputFormData);
275 std::unique_ptr<FetchDataConsumerHandle::Reader> reader = handle->obtainRead er(nullptr); 275 std::unique_ptr<FetchDataConsumerHandle::Reader> reader = handle->obtainFetc hDataReader(nullptr);
276 RefPtr<BlobDataHandle> blobDataHandle = reader->drainAsBlobDataHandle(); 276 RefPtr<BlobDataHandle> blobDataHandle = reader->drainAsBlobDataHandle();
277 ASSERT_TRUE(blobDataHandle); 277 ASSERT_TRUE(blobDataHandle);
278 278
279 EXPECT_EQ(String(), blobDataHandle->type()); 279 EXPECT_EQ(String(), blobDataHandle->type());
280 EXPECT_EQ(inputFormData->flattenToString().utf8().length(), blobDataHandle-> size()); 280 EXPECT_EQ(inputFormData->flattenToString().utf8().length(), blobDataHandle-> size());
281 EXPECT_EQ(nullptr, reader->drainAsFormData()); 281 EXPECT_EQ(nullptr, reader->drainAsFormData());
282 char c; 282 char c;
283 size_t readSize; 283 size_t readSize;
284 EXPECT_EQ(kDone, reader->read(&c, 1, kNone, &readSize)); 284 EXPECT_EQ(kDone, reader->read(&c, 1, kNone, &readSize));
285 } 285 }
286 286
287 TEST_F(FetchFormDataConsumerHandleTest, DrainAsBlobDataHandleFromComplexFormData ) 287 TEST_F(FetchFormDataConsumerHandleTest, DrainAsBlobDataHandleFromComplexFormData )
288 { 288 {
289 RefPtr<EncodedFormData> inputFormData = complexFormData(); 289 RefPtr<EncodedFormData> inputFormData = complexFormData();
290 290
291 std::unique_ptr<FetchDataConsumerHandle> handle = FetchFormDataConsumerHandl e::create(getDocument(), inputFormData); 291 std::unique_ptr<FetchDataConsumerHandle> handle = FetchFormDataConsumerHandl e::create(getDocument(), inputFormData);
292 std::unique_ptr<FetchDataConsumerHandle::Reader> reader = handle->obtainRead er(nullptr); 292 std::unique_ptr<FetchDataConsumerHandle::Reader> reader = handle->obtainFetc hDataReader(nullptr);
293 RefPtr<BlobDataHandle> blobDataHandle = reader->drainAsBlobDataHandle(); 293 RefPtr<BlobDataHandle> blobDataHandle = reader->drainAsBlobDataHandle();
294 ASSERT_TRUE(blobDataHandle); 294 ASSERT_TRUE(blobDataHandle);
295 295
296 EXPECT_EQ(nullptr, reader->drainAsFormData()); 296 EXPECT_EQ(nullptr, reader->drainAsFormData());
297 char c; 297 char c;
298 size_t readSize; 298 size_t readSize;
299 EXPECT_EQ(kDone, reader->read(&c, 1, kNone, &readSize)); 299 EXPECT_EQ(kDone, reader->read(&c, 1, kNone, &readSize));
300 } 300 }
301 301
302 TEST_F(FetchFormDataConsumerHandleTest, DrainAsFormDataFromString) 302 TEST_F(FetchFormDataConsumerHandleTest, DrainAsFormDataFromString)
303 { 303 {
304 std::unique_ptr<FetchDataConsumerHandle> handle = FetchFormDataConsumerHandl e::create(String("hello, world")); 304 std::unique_ptr<FetchDataConsumerHandle> handle = FetchFormDataConsumerHandl e::create(String("hello, world"));
305 std::unique_ptr<FetchDataConsumerHandle::Reader> reader = handle->obtainRead er(nullptr); 305 std::unique_ptr<FetchDataConsumerHandle::Reader> reader = handle->obtainFetc hDataReader(nullptr);
306 RefPtr<EncodedFormData> formData = reader->drainAsFormData(); 306 RefPtr<EncodedFormData> formData = reader->drainAsFormData();
307 ASSERT_TRUE(formData); 307 ASSERT_TRUE(formData);
308 EXPECT_TRUE(formData->isSafeToSendToAnotherThread()); 308 EXPECT_TRUE(formData->isSafeToSendToAnotherThread());
309 EXPECT_EQ("hello, world", formData->flattenToString()); 309 EXPECT_EQ("hello, world", formData->flattenToString());
310 310
311 const void* buffer = nullptr; 311 const void* buffer = nullptr;
312 size_t size; 312 size_t size;
313 EXPECT_EQ(kDone, reader->read(nullptr, 0, kNone, &size)); 313 EXPECT_EQ(kDone, reader->read(nullptr, 0, kNone, &size));
314 EXPECT_EQ(kDone, reader->beginRead(&buffer, kNone, &size)); 314 EXPECT_EQ(kDone, reader->beginRead(&buffer, kNone, &size));
315 } 315 }
316 316
317 TEST_F(FetchFormDataConsumerHandleTest, DrainAsFormDataFromArrayBuffer) 317 TEST_F(FetchFormDataConsumerHandleTest, DrainAsFormDataFromArrayBuffer)
318 { 318 {
319 std::unique_ptr<FetchDataConsumerHandle> handle = FetchFormDataConsumerHandl e::create(DOMArrayBuffer::create("foo", 3)); 319 std::unique_ptr<FetchDataConsumerHandle> handle = FetchFormDataConsumerHandl e::create(DOMArrayBuffer::create("foo", 3));
320 std::unique_ptr<FetchDataConsumerHandle::Reader> reader = handle->obtainRead er(nullptr); 320 std::unique_ptr<FetchDataConsumerHandle::Reader> reader = handle->obtainFetc hDataReader(nullptr);
321 RefPtr<EncodedFormData> formData = reader->drainAsFormData(); 321 RefPtr<EncodedFormData> formData = reader->drainAsFormData();
322 ASSERT_TRUE(formData); 322 ASSERT_TRUE(formData);
323 EXPECT_TRUE(formData->isSafeToSendToAnotherThread()); 323 EXPECT_TRUE(formData->isSafeToSendToAnotherThread());
324 EXPECT_EQ("foo", formData->flattenToString()); 324 EXPECT_EQ("foo", formData->flattenToString());
325 } 325 }
326 326
327 TEST_F(FetchFormDataConsumerHandleTest, DrainAsFormDataFromSimpleFormData) 327 TEST_F(FetchFormDataConsumerHandleTest, DrainAsFormDataFromSimpleFormData)
328 { 328 {
329 FormData* data = FormData::create(UTF8Encoding()); 329 FormData* data = FormData::create(UTF8Encoding());
330 data->append("name1", "value1"); 330 data->append("name1", "value1");
331 data->append("name2", "value2"); 331 data->append("name2", "value2");
332 RefPtr<EncodedFormData> inputFormData = data->encodeMultiPartFormData(); 332 RefPtr<EncodedFormData> inputFormData = data->encodeMultiPartFormData();
333 333
334 std::unique_ptr<FetchDataConsumerHandle> handle = FetchFormDataConsumerHandl e::create(getDocument(), inputFormData); 334 std::unique_ptr<FetchDataConsumerHandle> handle = FetchFormDataConsumerHandl e::create(getDocument(), inputFormData);
335 std::unique_ptr<FetchDataConsumerHandle::Reader> reader = handle->obtainRead er(nullptr); 335 std::unique_ptr<FetchDataConsumerHandle::Reader> reader = handle->obtainFetc hDataReader(nullptr);
336 RefPtr<EncodedFormData> outputFormData = reader->drainAsFormData(); 336 RefPtr<EncodedFormData> outputFormData = reader->drainAsFormData();
337 ASSERT_TRUE(outputFormData); 337 ASSERT_TRUE(outputFormData);
338 EXPECT_TRUE(outputFormData->isSafeToSendToAnotherThread()); 338 EXPECT_TRUE(outputFormData->isSafeToSendToAnotherThread());
339 EXPECT_NE(outputFormData.get(), inputFormData.get()); 339 EXPECT_NE(outputFormData.get(), inputFormData.get());
340 EXPECT_EQ(inputFormData->flattenToString(), outputFormData->flattenToString( )); 340 EXPECT_EQ(inputFormData->flattenToString(), outputFormData->flattenToString( ));
341 } 341 }
342 342
343 TEST_F(FetchFormDataConsumerHandleTest, DrainAsFormDataFromComplexFormData) 343 TEST_F(FetchFormDataConsumerHandleTest, DrainAsFormDataFromComplexFormData)
344 { 344 {
345 RefPtr<EncodedFormData> inputFormData = complexFormData(); 345 RefPtr<EncodedFormData> inputFormData = complexFormData();
346 346
347 std::unique_ptr<FetchDataConsumerHandle> handle = FetchFormDataConsumerHandl e::create(getDocument(), inputFormData); 347 std::unique_ptr<FetchDataConsumerHandle> handle = FetchFormDataConsumerHandl e::create(getDocument(), inputFormData);
348 std::unique_ptr<FetchDataConsumerHandle::Reader> reader = handle->obtainRead er(nullptr); 348 std::unique_ptr<FetchDataConsumerHandle::Reader> reader = handle->obtainFetc hDataReader(nullptr);
349 RefPtr<EncodedFormData> outputFormData = reader->drainAsFormData(); 349 RefPtr<EncodedFormData> outputFormData = reader->drainAsFormData();
350 ASSERT_TRUE(outputFormData); 350 ASSERT_TRUE(outputFormData);
351 EXPECT_TRUE(outputFormData->isSafeToSendToAnotherThread()); 351 EXPECT_TRUE(outputFormData->isSafeToSendToAnotherThread());
352 EXPECT_NE(outputFormData.get(), inputFormData.get()); 352 EXPECT_NE(outputFormData.get(), inputFormData.get());
353 verifyComplexFormData(outputFormData.get()); 353 verifyComplexFormData(outputFormData.get());
354 } 354 }
355 355
356 TEST_F(FetchFormDataConsumerHandleTest, ZeroByteReadDoesNotAffectDraining) 356 TEST_F(FetchFormDataConsumerHandleTest, ZeroByteReadDoesNotAffectDraining)
357 { 357 {
358 std::unique_ptr<FetchDataConsumerHandle> handle = FetchFormDataConsumerHandl e::create(String("hello, world")); 358 std::unique_ptr<FetchDataConsumerHandle> handle = FetchFormDataConsumerHandl e::create(String("hello, world"));
359 std::unique_ptr<FetchDataConsumerHandle::Reader> reader = handle->obtainRead er(nullptr); 359 std::unique_ptr<FetchDataConsumerHandle::Reader> reader = handle->obtainFetc hDataReader(nullptr);
360 size_t readSize; 360 size_t readSize;
361 EXPECT_EQ(kOk, reader->read(nullptr, 0, kNone, &readSize)); 361 EXPECT_EQ(kOk, reader->read(nullptr, 0, kNone, &readSize));
362 RefPtr<EncodedFormData> formData = reader->drainAsFormData(); 362 RefPtr<EncodedFormData> formData = reader->drainAsFormData();
363 ASSERT_TRUE(formData); 363 ASSERT_TRUE(formData);
364 EXPECT_TRUE(formData->isSafeToSendToAnotherThread()); 364 EXPECT_TRUE(formData->isSafeToSendToAnotherThread());
365 EXPECT_EQ("hello, world", formData->flattenToString()); 365 EXPECT_EQ("hello, world", formData->flattenToString());
366 } 366 }
367 367
368 TEST_F(FetchFormDataConsumerHandleTest, OneByteReadAffectsDraining) 368 TEST_F(FetchFormDataConsumerHandleTest, OneByteReadAffectsDraining)
369 { 369 {
370 char c; 370 char c;
371 std::unique_ptr<FetchDataConsumerHandle> handle = FetchFormDataConsumerHandl e::create(String("hello, world")); 371 std::unique_ptr<FetchDataConsumerHandle> handle = FetchFormDataConsumerHandl e::create(String("hello, world"));
372 std::unique_ptr<FetchDataConsumerHandle::Reader> reader = handle->obtainRead er(nullptr); 372 std::unique_ptr<FetchDataConsumerHandle::Reader> reader = handle->obtainFetc hDataReader(nullptr);
373 size_t readSize; 373 size_t readSize;
374 EXPECT_EQ(kOk, reader->read(&c, 1, kNone, &readSize)); 374 EXPECT_EQ(kOk, reader->read(&c, 1, kNone, &readSize));
375 EXPECT_EQ(1u, readSize); 375 EXPECT_EQ(1u, readSize);
376 EXPECT_EQ('h', c); 376 EXPECT_EQ('h', c);
377 EXPECT_FALSE(reader->drainAsFormData()); 377 EXPECT_FALSE(reader->drainAsFormData());
378 } 378 }
379 379
380 TEST_F(FetchFormDataConsumerHandleTest, BeginReadAffectsDraining) 380 TEST_F(FetchFormDataConsumerHandleTest, BeginReadAffectsDraining)
381 { 381 {
382 const void* buffer = nullptr; 382 const void* buffer = nullptr;
383 std::unique_ptr<FetchDataConsumerHandle> handle = FetchFormDataConsumerHandl e::create(String("hello, world")); 383 std::unique_ptr<FetchDataConsumerHandle> handle = FetchFormDataConsumerHandl e::create(String("hello, world"));
384 std::unique_ptr<FetchDataConsumerHandle::Reader> reader = handle->obtainRead er(nullptr); 384 std::unique_ptr<FetchDataConsumerHandle::Reader> reader = handle->obtainFetc hDataReader(nullptr);
385 size_t available; 385 size_t available;
386 EXPECT_EQ(kOk, reader->beginRead(&buffer, kNone, &available)); 386 EXPECT_EQ(kOk, reader->beginRead(&buffer, kNone, &available));
387 ASSERT_TRUE(buffer); 387 ASSERT_TRUE(buffer);
388 EXPECT_EQ("hello, world", String(static_cast<const char*>(buffer), available )); 388 EXPECT_EQ("hello, world", String(static_cast<const char*>(buffer), available ));
389 EXPECT_FALSE(reader->drainAsFormData()); 389 EXPECT_FALSE(reader->drainAsFormData());
390 reader->endRead(0); 390 reader->endRead(0);
391 EXPECT_FALSE(reader->drainAsFormData()); 391 EXPECT_FALSE(reader->drainAsFormData());
392 } 392 }
393 393
394 TEST_F(FetchFormDataConsumerHandleTest, ZeroByteReadDoesNotAffectDrainingForComp lexFormData) 394 TEST_F(FetchFormDataConsumerHandleTest, ZeroByteReadDoesNotAffectDrainingForComp lexFormData)
395 { 395 {
396 std::unique_ptr<ReplayingHandle> src = ReplayingHandle::create(); 396 std::unique_ptr<ReplayingHandle> src = ReplayingHandle::create();
397 src->add(Command(Command::Data, "bar")); 397 src->add(Command(Command::Data, "bar"));
398 src->add(Command(Command::Done)); 398 src->add(Command(Command::Done));
399 std::unique_ptr<FetchDataConsumerHandle> handle = FetchFormDataConsumerHandl e::createForTest(getDocument(), complexFormData(), new LoaderFactory(std::move(s rc))); 399 std::unique_ptr<FetchDataConsumerHandle> handle = FetchFormDataConsumerHandl e::createForTest(getDocument(), complexFormData(), new LoaderFactory(std::move(s rc)));
400 std::unique_ptr<FetchDataConsumerHandle::Reader> reader = handle->obtainRead er(nullptr); 400 std::unique_ptr<FetchDataConsumerHandle::Reader> reader = handle->obtainFetc hDataReader(nullptr);
401 size_t readSize; 401 size_t readSize;
402 EXPECT_EQ(kShouldWait, reader->read(nullptr, 0, kNone, &readSize)); 402 EXPECT_EQ(kShouldWait, reader->read(nullptr, 0, kNone, &readSize));
403 testing::runPendingTasks(); 403 testing::runPendingTasks();
404 EXPECT_EQ(kOk, reader->read(nullptr, 0, kNone, &readSize)); 404 EXPECT_EQ(kOk, reader->read(nullptr, 0, kNone, &readSize));
405 RefPtr<EncodedFormData> formData = reader->drainAsFormData(); 405 RefPtr<EncodedFormData> formData = reader->drainAsFormData();
406 ASSERT_TRUE(formData); 406 ASSERT_TRUE(formData);
407 EXPECT_TRUE(formData->isSafeToSendToAnotherThread()); 407 EXPECT_TRUE(formData->isSafeToSendToAnotherThread());
408 verifyComplexFormData(formData.get()); 408 verifyComplexFormData(formData.get());
409 } 409 }
410 410
411 TEST_F(FetchFormDataConsumerHandleTest, OneByteReadAffectsDrainingForComplexForm Data) 411 TEST_F(FetchFormDataConsumerHandleTest, OneByteReadAffectsDrainingForComplexForm Data)
412 { 412 {
413 std::unique_ptr<ReplayingHandle> src = ReplayingHandle::create(); 413 std::unique_ptr<ReplayingHandle> src = ReplayingHandle::create();
414 src->add(Command(Command::Data, "bar")); 414 src->add(Command(Command::Data, "bar"));
415 src->add(Command(Command::Done)); 415 src->add(Command(Command::Done));
416 std::unique_ptr<FetchDataConsumerHandle> handle = FetchFormDataConsumerHandl e::createForTest(getDocument(), complexFormData(), new LoaderFactory(std::move(s rc))); 416 std::unique_ptr<FetchDataConsumerHandle> handle = FetchFormDataConsumerHandl e::createForTest(getDocument(), complexFormData(), new LoaderFactory(std::move(s rc)));
417 std::unique_ptr<FetchDataConsumerHandle::Reader> reader = handle->obtainRead er(nullptr); 417 std::unique_ptr<FetchDataConsumerHandle::Reader> reader = handle->obtainFetc hDataReader(nullptr);
418 char c; 418 char c;
419 size_t readSize; 419 size_t readSize;
420 EXPECT_EQ(kShouldWait, reader->read(&c, 1, kNone, &readSize)); 420 EXPECT_EQ(kShouldWait, reader->read(&c, 1, kNone, &readSize));
421 testing::runPendingTasks(); 421 testing::runPendingTasks();
422 EXPECT_EQ(kOk, reader->read(&c, 1, kNone, &readSize)); 422 EXPECT_EQ(kOk, reader->read(&c, 1, kNone, &readSize));
423 EXPECT_EQ(1u, readSize); 423 EXPECT_EQ(1u, readSize);
424 EXPECT_EQ('b', c); 424 EXPECT_EQ('b', c);
425 EXPECT_FALSE(reader->drainAsFormData()); 425 EXPECT_FALSE(reader->drainAsFormData());
426 } 426 }
427 427
428 TEST_F(FetchFormDataConsumerHandleTest, BeginReadAffectsDrainingForComplexFormDa ta) 428 TEST_F(FetchFormDataConsumerHandleTest, BeginReadAffectsDrainingForComplexFormDa ta)
429 { 429 {
430 std::unique_ptr<ReplayingHandle> src = ReplayingHandle::create(); 430 std::unique_ptr<ReplayingHandle> src = ReplayingHandle::create();
431 src->add(Command(Command::Data, "bar")); 431 src->add(Command(Command::Data, "bar"));
432 src->add(Command(Command::Done)); 432 src->add(Command(Command::Done));
433 const void* buffer = nullptr; 433 const void* buffer = nullptr;
434 std::unique_ptr<FetchDataConsumerHandle> handle = FetchFormDataConsumerHandl e::createForTest(getDocument(), complexFormData(), new LoaderFactory(std::move(s rc))); 434 std::unique_ptr<FetchDataConsumerHandle> handle = FetchFormDataConsumerHandl e::createForTest(getDocument(), complexFormData(), new LoaderFactory(std::move(s rc)));
435 std::unique_ptr<FetchDataConsumerHandle::Reader> reader = handle->obtainRead er(nullptr); 435 std::unique_ptr<FetchDataConsumerHandle::Reader> reader = handle->obtainFetc hDataReader(nullptr);
436 size_t available; 436 size_t available;
437 EXPECT_EQ(kShouldWait, reader->beginRead(&buffer, kNone, &available)); 437 EXPECT_EQ(kShouldWait, reader->beginRead(&buffer, kNone, &available));
438 testing::runPendingTasks(); 438 testing::runPendingTasks();
439 EXPECT_EQ(kOk, reader->beginRead(&buffer, kNone, &available)); 439 EXPECT_EQ(kOk, reader->beginRead(&buffer, kNone, &available));
440 EXPECT_FALSE(reader->drainAsFormData()); 440 EXPECT_FALSE(reader->drainAsFormData());
441 reader->endRead(0); 441 reader->endRead(0);
442 EXPECT_FALSE(reader->drainAsFormData()); 442 EXPECT_FALSE(reader->drainAsFormData());
443 } 443 }
444 444
445 } // namespace 445 } // namespace
446 } // namespace blink 446 } // namespace blink
OLDNEW

Powered by Google App Engine
This is Rietveld 408576698