Add FetchDataConsumerHandle and utility functions/classes

Source/modules/fetch/DataConsumerHandleUtilTest.cpp

+// Copyright 2015 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 "config.h"
+#include "modules/fetch/DataConsumerHandleUtilTest.h"
+
+namespace blink {
+
+namespace {
+
+TEST(DataConsumerHandleUtilTest, CreateWaitingHandle)
+{
+    char buffer[20];
+    const void* p = nullptr;
+    size_t size = 0;
+    OwnPtr<WebDataConsumerHandle> handle = createWaitingHandle();
+    OwnPtr<WebDataConsumerHandle::Reader> reader = handle->obtainReader(nullptr);
+
+    EXPECT_EQ(kShouldWait, reader->read(buffer, sizeof(buffer), kNone, &size));
+    EXPECT_EQ(kShouldWait, reader->beginRead(&p, kNone, &size));
+    EXPECT_EQ(kUnexpectedError, reader->endRead(99));
+}
+
+TEST(CompositeDataConsumerHandleTest, WaitingHandleNoNotification)
+{
+    ThreadingHandleNoNotificationTest test;
+    // Test this function doesn't crash.
+    test.run(createWaitingHandle());
+}
+
+TEST(DataConsumerHandleUtilTest, CreateDoneHandle)
+{
+    char buffer[20];
+    const void* p = nullptr;
+    size_t size = 0;
+    OwnPtr<WebDataConsumerHandle> handle = createDoneHandle();
+    OwnPtr<WebDataConsumerHandle::Reader> reader = handle->obtainReader(nullptr);
+
+    EXPECT_EQ(kDone, reader->read(buffer, sizeof(buffer), kNone, &size));
+    EXPECT_EQ(kDone, reader->beginRead(&p, kNone, &size));
+    EXPECT_EQ(kUnexpectedError, reader->endRead(99));
+}
+
+TEST(DataConsumerHandleUtilTest, DoneHandleNotification)
+{
+    ThreadingHandleNotificationTest test;
+    // Test this function returns.
+    test.run(createDoneHandle());
+}
+
+TEST(CompositeDataConsumerHandleTest, DoneHandleNoNotification)
+{
+    ThreadingHandleNoNotificationTest test;
+    // Test this function doesn't crash.
+    test.run(createDoneHandle());
+}
+
+TEST(DataConsumerHandleUtilTest, CreateUnexpectedErrorHandle)
+{
+    char buffer[20];
+    const void* p = nullptr;
+    size_t size = 0;
+    OwnPtr<WebDataConsumerHandle> handle = createUnexpectedErrorHandle();
+    OwnPtr<WebDataConsumerHandle::Reader> reader = handle->obtainReader(nullptr);
+
+    EXPECT_EQ(kUnexpectedError, reader->read(buffer, sizeof(buffer), kNone, &size));
+    EXPECT_EQ(kUnexpectedError, reader->beginRead(&p, kNone, &size));
+    EXPECT_EQ(kUnexpectedError, reader->endRead(99));
+}
+
+TEST(DataConsumerHandleUtilTest, UnexpectedErrorHandleNotification)
+{
+    ThreadingHandleNotificationTest test;
+    // Test this function returns.
+    test.run(createUnexpectedErrorHandle());
+}
+
+TEST(CompositeDataConsumerHandleTest, UnexpectedErrorHandleNoNotification)
+{
+    ThreadingHandleNoNotificationTest test;
+    // Test this function doesn't crash.
+    test.run(createUnexpectedErrorHandle());
+}
+
+} // namespace
+
+} // namespace blink