[wrapper-tracing] Untangle non-trivial mixin ctors

third_party/WebKit/Source/modules/fetch/BodyStreamBufferTest.cpp

 // Copyright 2014 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 "modules/fetch/BodyStreamBuffer.h"
 
 #include "bindings/core/v8/V8BindingForTesting.h"
 #include "core/dom/Document.h"
 #include "core/html/FormData.h"
 #include "modules/fetch/BlobBytesConsumer.h"
@@ skipping 68 matching lines @@
   EXPECT_CALL(checkpoint, Call(1));
   EXPECT_CALL(checkpoint, Call(2));
   EXPECT_CALL(*client2, didFetchDataLoadedString(String("hello, world")));
   EXPECT_CALL(checkpoint, Call(3));
   EXPECT_CALL(checkpoint, Call(4));
 
   ReplayingBytesConsumer* src = new ReplayingBytesConsumer(&scope.document());
   src->add(Command(Command::Data, "hello, "));
   src->add(Command(Command::Data, "world"));
   src->add(Command(Command::Done));
-  BodyStreamBuffer* buffer = new BodyStreamBuffer(scope.getScriptState(), src);
+  BodyStreamBuffer* buffer =
+      BodyStreamBuffer::create(scope.getScriptState(), src);
 
   BodyStreamBuffer* new1;
   BodyStreamBuffer* new2;
   buffer->tee(&new1, &new2);
 
   EXPECT_TRUE(buffer->isStreamLocked());
   EXPECT_TRUE(buffer->isStreamDisturbed());
   EXPECT_FALSE(buffer->hasPendingActivity());
 
   checkpoint.Call(0);
@@ skipping 23 matching lines @@
 
   InSequence s;
   EXPECT_CALL(checkpoint, Call(1));
   EXPECT_CALL(*client1, didFetchDataLoadedString(String("ABUX")));
   EXPECT_CALL(checkpoint, Call(2));
   EXPECT_CALL(checkpoint, Call(3));
   EXPECT_CALL(*client2, didFetchDataLoadedString(String("ABUX")));
   EXPECT_CALL(checkpoint, Call(4));
 
   BodyStreamBuffer* buffer =
-      new BodyStreamBuffer(scope.getScriptState(), stream);
+      BodyStreamBuffer::create(scope.getScriptState(), stream);
 
   BodyStreamBuffer* new1;
   BodyStreamBuffer* new2;
   buffer->tee(&new1, &new2);
 
   EXPECT_TRUE(buffer->isStreamLocked());
   // Note that this behavior is slightly different from for the behavior of
   // a BodyStreamBuffer made from a BytesConsumer. See the above test. In this
   // test, the stream will get disturbed when the microtask is performed.
   // TODO(yhirano): A uniformed behavior is preferred.
@@ skipping 17 matching lines @@
   checkpoint.Call(4);
 }
 
 TEST_F(BodyStreamBufferTest, DrainAsBlobDataHandle) {
   V8TestingScope scope;
   std::unique_ptr<BlobData> data = BlobData::create();
   data->appendText("hello", false);
   auto size = data->length();
   RefPtr<BlobDataHandle> blobDataHandle =
       BlobDataHandle::create(std::move(data), size);
-  BodyStreamBuffer* buffer = new BodyStreamBuffer(
+  BodyStreamBuffer* buffer = BodyStreamBuffer::create(
       scope.getScriptState(),
       new BlobBytesConsumer(scope.getExecutionContext(), blobDataHandle));
 
   EXPECT_FALSE(buffer->isStreamLocked());
   EXPECT_FALSE(buffer->isStreamDisturbed());
   EXPECT_FALSE(buffer->hasPendingActivity());
   RefPtr<BlobDataHandle> outputBlobDataHandle = buffer->drainAsBlobDataHandle(
       BytesConsumer::BlobSizePolicy::AllowBlobWithInvalidSize);
 
   EXPECT_TRUE(buffer->isStreamLocked());
   EXPECT_TRUE(buffer->isStreamDisturbed());
   EXPECT_FALSE(buffer->hasPendingActivity());
   EXPECT_EQ(blobDataHandle, outputBlobDataHandle);
 }
 
 TEST_F(BodyStreamBufferTest, DrainAsBlobDataHandleReturnsNull) {
   V8TestingScope scope;
   // This BytesConsumer is not drainable.
   BytesConsumer* src = new ReplayingBytesConsumer(&scope.document());
-  BodyStreamBuffer* buffer = new BodyStreamBuffer(scope.getScriptState(), src);
+  BodyStreamBuffer* buffer =
+      BodyStreamBuffer::create(scope.getScriptState(), src);
 
   EXPECT_FALSE(buffer->isStreamLocked());
   EXPECT_FALSE(buffer->isStreamDisturbed());
   EXPECT_FALSE(buffer->hasPendingActivity());
 
   EXPECT_FALSE(buffer->drainAsBlobDataHandle(
       BytesConsumer::BlobSizePolicy::AllowBlobWithInvalidSize));
 
   EXPECT_FALSE(buffer->isStreamLocked());
   EXPECT_FALSE(buffer->isStreamDisturbed());
   EXPECT_FALSE(buffer->hasPendingActivity());
 }
 
 TEST_F(BodyStreamBufferTest,
        DrainAsBlobFromBufferMadeFromBufferMadeFromStream) {
   V8TestingScope scope;
   ScriptValue stream =
       evalWithPrintingError(scope.getScriptState(), "new ReadableStream()");
   BodyStreamBuffer* buffer =
-      new BodyStreamBuffer(scope.getScriptState(), stream);
+      BodyStreamBuffer::create(scope.getScriptState(), stream);
 
   EXPECT_FALSE(buffer->hasPendingActivity());
   EXPECT_FALSE(buffer->isStreamLocked());
   EXPECT_FALSE(buffer->isStreamDisturbed());
   EXPECT_TRUE(buffer->isStreamReadable());
 
   EXPECT_FALSE(buffer->drainAsBlobDataHandle(
       BytesConsumer::BlobSizePolicy::AllowBlobWithInvalidSize));
 
   EXPECT_FALSE(buffer->hasPendingActivity());
   EXPECT_FALSE(buffer->isStreamLocked());
   EXPECT_FALSE(buffer->isStreamDisturbed());
   EXPECT_TRUE(buffer->isStreamReadable());
 }
 
 TEST_F(BodyStreamBufferTest, DrainAsFormData) {
   V8TestingScope scope;
   FormData* data = FormData::create(UTF8Encoding());
   data->append("name1", "value1");
   data->append("name2", "value2");
   RefPtr<EncodedFormData> inputFormData = data->encodeMultiPartFormData();
 
-  BodyStreamBuffer* buffer = new BodyStreamBuffer(
+  BodyStreamBuffer* buffer = BodyStreamBuffer::create(
       scope.getScriptState(),
       new FormDataBytesConsumer(scope.getExecutionContext(), inputFormData));
 
   EXPECT_FALSE(buffer->isStreamLocked());
   EXPECT_FALSE(buffer->isStreamDisturbed());
   EXPECT_FALSE(buffer->hasPendingActivity());
   RefPtr<EncodedFormData> outputFormData = buffer->drainAsFormData();
 
   EXPECT_TRUE(buffer->isStreamLocked());
   EXPECT_TRUE(buffer->isStreamDisturbed());
   EXPECT_FALSE(buffer->hasPendingActivity());
   EXPECT_EQ(outputFormData->flattenToString(),
             inputFormData->flattenToString());
 }
 
 TEST_F(BodyStreamBufferTest, DrainAsFormDataReturnsNull) {
   V8TestingScope scope;
   // This BytesConsumer is not drainable.
   BytesConsumer* src = new ReplayingBytesConsumer(&scope.document());
-  BodyStreamBuffer* buffer = new BodyStreamBuffer(scope.getScriptState(), src);
+  BodyStreamBuffer* buffer =
+      BodyStreamBuffer::create(scope.getScriptState(), src);
 
   EXPECT_FALSE(buffer->isStreamLocked());
   EXPECT_FALSE(buffer->isStreamDisturbed());
   EXPECT_FALSE(buffer->hasPendingActivity());
 
   EXPECT_FALSE(buffer->drainAsFormData());
 
   EXPECT_FALSE(buffer->isStreamLocked());
   EXPECT_FALSE(buffer->isStreamDisturbed());
   EXPECT_FALSE(buffer->hasPendingActivity());
 }
 
 TEST_F(BodyStreamBufferTest,
        DrainAsFormDataFromBufferMadeFromBufferMadeFromStream) {
   V8TestingScope scope;
   ScriptValue stream =
       evalWithPrintingError(scope.getScriptState(), "new ReadableStream()");
   BodyStreamBuffer* buffer =
-      new BodyStreamBuffer(scope.getScriptState(), stream);
+      BodyStreamBuffer::create(scope.getScriptState(), stream);
 
   EXPECT_FALSE(buffer->hasPendingActivity());
   EXPECT_FALSE(buffer->isStreamLocked());
   EXPECT_FALSE(buffer->isStreamDisturbed());
   EXPECT_TRUE(buffer->isStreamReadable());
 
   EXPECT_FALSE(buffer->drainAsFormData());
 
   EXPECT_FALSE(buffer->hasPendingActivity());
   EXPECT_FALSE(buffer->isStreamLocked());
@@ skipping 10 matching lines @@
   InSequence s;
   EXPECT_CALL(checkpoint, Call(1));
   EXPECT_CALL(*client, didFetchDataLoadedArrayBufferMock(_))
       .WillOnce(SaveArg<0>(&arrayBuffer));
   EXPECT_CALL(checkpoint, Call(2));
 
   ReplayingBytesConsumer* src = new ReplayingBytesConsumer(&scope.document());
   src->add(Command(Command::Wait));
   src->add(Command(Command::Data, "hello"));
   src->add(Command(Command::Done));
-  BodyStreamBuffer* buffer = new BodyStreamBuffer(scope.getScriptState(), src);
+  BodyStreamBuffer* buffer =
+      BodyStreamBuffer::create(scope.getScriptState(), src);
   buffer->startLoading(FetchDataLoader::createLoaderAsArrayBuffer(), client);
 
   EXPECT_TRUE(buffer->isStreamLocked());
   EXPECT_TRUE(buffer->isStreamDisturbed());
   EXPECT_TRUE(buffer->hasPendingActivity());
 
   checkpoint.Call(1);
   testing::runPendingTasks();
   checkpoint.Call(2);
 
@@ skipping 14 matching lines @@
   InSequence s;
   EXPECT_CALL(checkpoint, Call(1));
   EXPECT_CALL(*client, didFetchDataLoadedBlobHandleMock(_))
       .WillOnce(SaveArg<0>(&blobDataHandle));
   EXPECT_CALL(checkpoint, Call(2));
 
   ReplayingBytesConsumer* src = new ReplayingBytesConsumer(&scope.document());
   src->add(Command(Command::Wait));
   src->add(Command(Command::Data, "hello"));
   src->add(Command(Command::Done));
-  BodyStreamBuffer* buffer = new BodyStreamBuffer(scope.getScriptState(), src);
+  BodyStreamBuffer* buffer =
+      BodyStreamBuffer::create(scope.getScriptState(), src);
   buffer->startLoading(FetchDataLoader::createLoaderAsBlobHandle("text/plain"),
                        client);
 
   EXPECT_TRUE(buffer->isStreamLocked());
   EXPECT_TRUE(buffer->isStreamDisturbed());
   EXPECT_TRUE(buffer->hasPendingActivity());
 
   checkpoint.Call(1);
   testing::runPendingTasks();
   checkpoint.Call(2);
@@ skipping 11 matching lines @@
 
   InSequence s;
   EXPECT_CALL(checkpoint, Call(1));
   EXPECT_CALL(*client, didFetchDataLoadedString(String("hello")));
   EXPECT_CALL(checkpoint, Call(2));
 
   ReplayingBytesConsumer* src = new ReplayingBytesConsumer(&scope.document());
   src->add(Command(Command::Wait));
   src->add(Command(Command::Data, "hello"));
   src->add(Command(Command::Done));
-  BodyStreamBuffer* buffer = new BodyStreamBuffer(scope.getScriptState(), src);
+  BodyStreamBuffer* buffer =
+      BodyStreamBuffer::create(scope.getScriptState(), src);
   buffer->startLoading(FetchDataLoader::createLoaderAsString(), client);
 
   EXPECT_TRUE(buffer->isStreamLocked());
   EXPECT_TRUE(buffer->isStreamDisturbed());
   EXPECT_TRUE(buffer->hasPendingActivity());
 
   checkpoint.Call(1);
   testing::runPendingTasks();
   checkpoint.Call(2);
 
   EXPECT_TRUE(buffer->isStreamLocked());
   EXPECT_TRUE(buffer->isStreamDisturbed());
   EXPECT_FALSE(buffer->hasPendingActivity());
 }
 
 TEST_F(BodyStreamBufferTest, LoadClosedHandle) {
   V8TestingScope scope;
   Checkpoint checkpoint;
   MockFetchDataLoaderClient* client = MockFetchDataLoaderClient::create();
 
   InSequence s;
   EXPECT_CALL(checkpoint, Call(1));
   EXPECT_CALL(*client, didFetchDataLoadedString(String("")));
   EXPECT_CALL(checkpoint, Call(2));
 
-  BodyStreamBuffer* buffer = new BodyStreamBuffer(
+  BodyStreamBuffer* buffer = BodyStreamBuffer::create(
       scope.getScriptState(), BytesConsumer::createClosed());
 
   EXPECT_TRUE(buffer->isStreamClosed());
 
   EXPECT_FALSE(buffer->isStreamLocked());
   EXPECT_FALSE(buffer->isStreamDisturbed());
   EXPECT_FALSE(buffer->hasPendingActivity());
 
   checkpoint.Call(1);
   buffer->startLoading(FetchDataLoader::createLoaderAsString(), client);
   checkpoint.Call(2);
 
   EXPECT_TRUE(buffer->isStreamLocked());
   EXPECT_TRUE(buffer->isStreamDisturbed());
   EXPECT_FALSE(buffer->hasPendingActivity());
 }
 
 TEST_F(BodyStreamBufferTest, LoadErroredHandle) {
   V8TestingScope scope;
   Checkpoint checkpoint;
   MockFetchDataLoaderClient* client = MockFetchDataLoaderClient::create();
 
   InSequence s;
   EXPECT_CALL(checkpoint, Call(1));
   EXPECT_CALL(*client, didFetchDataLoadFailed());
   EXPECT_CALL(checkpoint, Call(2));
 
-  BodyStreamBuffer* buffer = new BodyStreamBuffer(
+  BodyStreamBuffer* buffer = BodyStreamBuffer::create(
       scope.getScriptState(),
       BytesConsumer::createErrored(BytesConsumer::Error()));
 
   EXPECT_TRUE(buffer->isStreamErrored());
 
   EXPECT_FALSE(buffer->isStreamLocked());
   EXPECT_FALSE(buffer->isStreamDisturbed());
   EXPECT_FALSE(buffer->hasPendingActivity());
 
   checkpoint.Call(1);
@@ skipping 13 matching lines @@
   InSequence s;
   EXPECT_CALL(checkpoint, Call(1));
   EXPECT_CALL(*client, didFetchDataLoadedString(String("hello")));
   EXPECT_CALL(checkpoint, Call(2));
 
   ReplayingBytesConsumer* src = new ReplayingBytesConsumer(&scope.document());
   src->add(Command(Command::Wait));
   src->add(Command(Command::Data, "hello"));
   src->add(Command(Command::Done));
   Persistent<BodyStreamBuffer> buffer =
-      new BodyStreamBuffer(scope.getScriptState(), src);
+      BodyStreamBuffer::create(scope.getScriptState(), src);
   buffer->startLoading(FetchDataLoader::createLoaderAsString(), client);
 
   ThreadState::current()->collectAllGarbage();
   checkpoint.Call(1);
   testing::runPendingTasks();
   checkpoint.Call(2);
 }
 
 TEST_F(BodyStreamBufferTest, SourceShouldBeCanceledWhenCanceled) {
   V8TestingScope scope;
   ReplayingBytesConsumer* consumer =
       new BytesConsumerTestUtil::ReplayingBytesConsumer(
           scope.getExecutionContext());
 
   BodyStreamBuffer* buffer =
-      new BodyStreamBuffer(scope.getScriptState(), consumer);
+      BodyStreamBuffer::create(scope.getScriptState(), consumer);
   ScriptValue reason(scope.getScriptState(),
                      v8String(scope.getScriptState()->isolate(), "reason"));
   EXPECT_FALSE(consumer->isCancelled());
   buffer->cancel(scope.getScriptState(), reason);
   EXPECT_TRUE(consumer->isCancelled());
 }
 
 }  // namespace
 
 }  // namespace blink