[Streams] UnderlyingSourceBase should be kept alive only when locked

third_party/WebKit/Source/core/streams/ReadableStreamOperationsTest.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 "core/streams/ReadableStreamOperations.h"
 
 #include "bindings/core/v8/ExceptionState.h"
 #include "bindings/core/v8/ScriptFunction.h"
 #include "bindings/core/v8/ScriptState.h"
 #include "bindings/core/v8/ScriptValue.h"
@@ skipping 316 matching lines @@
     EXPECT_FALSE(it3->isSet());
 
     underlyingSource->close();
     v8::MicrotasksScope::PerformCheckpoint(isolate());
 
     EXPECT_TRUE(it3->isSet());
     EXPECT_TRUE(it3->isValid());
     EXPECT_TRUE(it3->isDone());
 }
 
+TEST_F(ReadableStreamOperationsTest, UnderlyingSourceShouldHavePendingActivityWhenLockedAndControllerIsActive)
+{
+    auto underlyingSource = new TestUnderlyingSource(getScriptState());
+
+    ScriptValue strategy = ReadableStreamOperations::createCountQueuingStrategy(getScriptState(), 10);
+    ASSERT_FALSE(strategy.isEmpty());
+
+    ScriptValue stream = ReadableStreamOperations::createReadableStream(getScriptState(), underlyingSource, strategy);
+    ASSERT_FALSE(stream.isEmpty());
+
+    v8::Local<v8::Object> global = getScriptState()->context()->Global();
+    ASSERT_TRUE(global->Set(getScriptState()->context(), v8String(getScriptState()->isolate(), "stream"), stream.v8Value()).IsJust());
+
+    EXPECT_FALSE(underlyingSource->hasPendingActivity());
+    evalWithPrintingError("let reader = stream.getReader();");
+    EXPECT_TRUE(underlyingSource->hasPendingActivity());
+    evalWithPrintingError("reader.releaseLock();");
+    EXPECT_FALSE(underlyingSource->hasPendingActivity());
+    evalWithPrintingError("reader = stream.getReader();");
+    EXPECT_TRUE(underlyingSource->hasPendingActivity());
+    underlyingSource->enqueue(ScriptValue(getScriptState(), v8::Undefined(getScriptState()->isolate())));
+    underlyingSource->close();
+    EXPECT_FALSE(underlyingSource->hasPendingActivity());
+}
+
 TEST_F(ReadableStreamOperationsTest, SetDisturbed)
 {
     ScriptValue stream = evalWithPrintingError("new ReadableStream()");
     ASSERT_FALSE(stream.isEmpty());
 
     EXPECT_FALSE(ReadableStreamOperations::isDisturbed(getScriptState(), stream));
     ReadableStreamOperations::setDisturbed(getScriptState(), stream);
     EXPECT_TRUE(ReadableStreamOperations::isDisturbed(getScriptState(), stream));
 }
 
@@ skipping 36 matching lines @@
 
     EXPECT_FALSE(ReadableStreamOperations::isErrored(getScriptState(), readable));
     EXPECT_FALSE(ReadableStreamOperations::isErrored(getScriptState(), closed));
     EXPECT_TRUE(ReadableStreamOperations::isErrored(getScriptState(), errored));
 }
 
 } // namespace
 
 } // namespace blink