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 "config.h" | 5 #include "config.h" |
6 #include "core/streams/ReadableStreamReader.h" | 6 #include "core/streams/ReadableStreamReader.h" |
7 | 7 |
8 #include "bindings/core/v8/ExceptionState.h" | 8 #include "bindings/core/v8/ExceptionState.h" |
9 #include "bindings/core/v8/ScriptFunction.h" | |
10 #include "bindings/core/v8/ScriptPromiseResolver.h" | 9 #include "bindings/core/v8/ScriptPromiseResolver.h" |
| 10 #include "bindings/core/v8/V8IteratorResultValue.h" |
11 #include "core/dom/DOMException.h" | 11 #include "core/dom/DOMException.h" |
12 #include "core/streams/ReadableStream.h" | 12 #include "core/streams/ReadableStream.h" |
13 | 13 |
14 namespace blink { | 14 namespace blink { |
15 | 15 |
16 namespace { | |
17 | |
18 class PromiseRaceFulfillHandler : public ScriptFunction { | |
19 public: | |
20 static v8::Handle<v8::Function> create(PassRefPtrWillBeRawPtr<ScriptPromiseR
esolver> resolver) | |
21 { | |
22 return (new PromiseRaceFulfillHandler(resolver))->bindToV8Function(); | |
23 } | |
24 | |
25 DEFINE_INLINE_TRACE() | |
26 { | |
27 visitor->trace(m_resolver); | |
28 ScriptFunction::trace(visitor); | |
29 } | |
30 | |
31 private: | |
32 explicit PromiseRaceFulfillHandler(PassRefPtrWillBeRawPtr<ScriptPromiseResol
ver> resolver) | |
33 : ScriptFunction(resolver->scriptState()) | |
34 , m_resolver(resolver) { } | |
35 ScriptValue call(ScriptValue value) override | |
36 { | |
37 m_resolver->resolve(value); | |
38 return ScriptValue(scriptState(), v8::Undefined(scriptState()->isolate()
)); | |
39 } | |
40 | |
41 RefPtrWillBeMember<ScriptPromiseResolver> m_resolver; | |
42 }; | |
43 | |
44 class PromiseRaceRejectHandler : public ScriptFunction { | |
45 public: | |
46 static v8::Handle<v8::Function> create(PassRefPtrWillBeRawPtr<ScriptPromiseR
esolver> resolver) | |
47 { | |
48 return (new PromiseRaceRejectHandler(resolver))->bindToV8Function(); | |
49 } | |
50 | |
51 DEFINE_INLINE_TRACE() | |
52 { | |
53 visitor->trace(m_resolver); | |
54 ScriptFunction::trace(visitor); | |
55 } | |
56 | |
57 private: | |
58 explicit PromiseRaceRejectHandler(PassRefPtrWillBeRawPtr<ScriptPromiseResolv
er> resolver) | |
59 : ScriptFunction(resolver->scriptState()) | |
60 , m_resolver(resolver) { } | |
61 ScriptValue call(ScriptValue value) override | |
62 { | |
63 m_resolver->reject(value); | |
64 return ScriptValue(scriptState(), v8::Undefined(scriptState()->isolate()
)); | |
65 } | |
66 | |
67 RefPtrWillBeMember<ScriptPromiseResolver> m_resolver; | |
68 }; | |
69 | |
70 ScriptPromise race(ScriptState* scriptState, const Vector<ScriptPromise>& promis
es) | |
71 { | |
72 RefPtrWillBeRawPtr<ScriptPromiseResolver> resolver = ScriptPromiseResolver::
create(scriptState); | |
73 for (ScriptPromise promise : promises) { | |
74 promise.then(PromiseRaceFulfillHandler::create(resolver), PromiseRaceRej
ectHandler::create(resolver)); | |
75 } | |
76 return resolver->promise(); | |
77 } | |
78 | |
79 } // namespace | |
80 | |
81 ReadableStreamReader::ReadableStreamReader(ReadableStream* stream) | 16 ReadableStreamReader::ReadableStreamReader(ReadableStream* stream) |
82 : ActiveDOMObject(stream->executionContext()) | 17 : ActiveDOMObject(stream->executionContext()) |
83 , m_stream(stream) | 18 , m_stream(stream) |
84 , m_released(new ReleasedPromise(stream->executionContext(), this, ReleasedP
romise::Released)) | |
85 , m_stateAfterRelease(ReadableStream::Closed) | 19 , m_stateAfterRelease(ReadableStream::Closed) |
| 20 , m_closed(new ClosedPromise(stream->executionContext(), this, ClosedPromise
::Closed)) |
86 { | 21 { |
87 suspendIfNeeded(); | 22 suspendIfNeeded(); |
88 ASSERT(m_stream->isLockedTo(nullptr)); | 23 ASSERT(m_stream->isLockedTo(nullptr)); |
89 m_stream->setReader(this); | 24 m_stream->setReader(this); |
| 25 |
| 26 if (m_stream->stateInternal() == ReadableStream::Closed || m_stream->stateIn
ternal() == ReadableStream::Errored) { |
| 27 // If the stream is already closed or errored the created reader |
| 28 // should be closed or errored respectively. |
| 29 releaseLock(); |
| 30 } |
90 } | 31 } |
91 | 32 |
92 ScriptPromise ReadableStreamReader::closed(ScriptState* scriptState) | 33 ScriptPromise ReadableStreamReader::closed(ScriptState* scriptState) |
93 { | 34 { |
94 if (isActive()) { | 35 return m_closed->promise(scriptState->world()); |
95 Vector<ScriptPromise> promises; | |
96 promises.append(m_stream->closed(scriptState)); | |
97 promises.append(m_released->promise(scriptState->world())); | |
98 return race(scriptState, promises); | |
99 } | |
100 ASSERT(m_released); | |
101 return m_closedAfterRelease->promise(scriptState->world()); | |
102 } | 36 } |
103 | 37 |
104 bool ReadableStreamReader::isActive() const | 38 bool ReadableStreamReader::isActive() const |
105 { | 39 { |
106 return m_stream->isLockedTo(this); | 40 return m_stream->isLockedTo(this); |
107 } | 41 } |
108 | 42 |
109 ScriptPromise ReadableStreamReader::ready(ScriptState* scriptState) | |
110 { | |
111 if (isActive()) { | |
112 Vector<ScriptPromise> promises; | |
113 promises.append(m_stream->readyInternal(scriptState)); | |
114 promises.append(m_released->promise(scriptState->world())); | |
115 return race(scriptState, promises); | |
116 } | |
117 ASSERT(m_readyAfterRelease); | |
118 return m_readyAfterRelease->promise(scriptState->world()); | |
119 } | |
120 | |
121 String ReadableStreamReader::state() const | |
122 { | |
123 if (isActive()) | |
124 return ReadableStream::stateToString(m_stream->stateInternal()); | |
125 return ReadableStream::stateToString(m_stateAfterRelease); | |
126 } | |
127 | |
128 ScriptPromise ReadableStreamReader::cancel(ScriptState* scriptState, ScriptValue
reason) | 43 ScriptPromise ReadableStreamReader::cancel(ScriptState* scriptState, ScriptValue
reason) |
129 { | 44 { |
130 if (isActive()) { | 45 if (isActive()) |
131 releaseLock(); | 46 return m_stream->cancelInternal(scriptState, reason); |
132 return m_stream->cancel(scriptState, reason); | 47 |
133 } | 48 // A method should return a different promise on each call. |
134 return m_closedAfterRelease->promise(scriptState->world()); | 49 RefPtrWillBeRawPtr<ScriptPromiseResolver> resolver = ScriptPromiseResolver::
create(scriptState); |
| 50 ScriptPromise promise = resolver->promise(); |
| 51 resolver->resolve(closed(scriptState).v8Value()); |
| 52 return promise; |
135 } | 53 } |
136 | 54 |
137 ScriptValue ReadableStreamReader::read(ScriptState* scriptState, ExceptionState&
es) | 55 ScriptPromise ReadableStreamReader::read(ScriptState* scriptState) |
138 { | 56 { |
139 if (!isActive()) { | 57 if (!isActive()) { |
140 es.throwTypeError("The stream is not locked to this reader"); | 58 ASSERT(m_stateAfterRelease == ReadableStream::Closed || m_stateAfterRele
ase == ReadableStream::Errored); |
141 return ScriptValue(); | 59 if (m_stateAfterRelease == ReadableStream::Closed) { |
| 60 // {value: undefined, done: true} |
| 61 return ScriptPromise::cast(scriptState, v8IteratorResultDone(scriptS
tate)); |
| 62 } |
| 63 // A method should return a different promise on each call. |
| 64 RefPtrWillBeRawPtr<ScriptPromiseResolver> resolver = ScriptPromiseResolv
er::create(scriptState); |
| 65 ScriptPromise promise = resolver->promise(); |
| 66 resolver->resolve(closed(scriptState).v8Value()); |
| 67 return promise; |
142 } | 68 } |
143 return m_stream->readInternal(scriptState, es); | 69 |
| 70 return m_stream->read(scriptState); |
| 71 } |
| 72 |
| 73 void ReadableStreamReader::releaseLock(ExceptionState& es) |
| 74 { |
| 75 if (!isActive()) |
| 76 return; |
| 77 if (m_stream->hasPendingReads()) { |
| 78 es.throwTypeError("The stream has pending read operations."); |
| 79 return; |
| 80 } |
| 81 |
| 82 releaseLock(); |
144 } | 83 } |
145 | 84 |
146 void ReadableStreamReader::releaseLock() | 85 void ReadableStreamReader::releaseLock() |
147 { | 86 { |
148 if (!isActive()) | 87 if (!isActive()) |
149 return; | 88 return; |
150 | 89 |
151 m_stream->setReader(nullptr); | 90 ASSERT(!m_stream->hasPendingReads()); |
152 | |
153 m_readyAfterRelease = new ReadyPromise(executionContext(), this, ReadyPromis
e::Ready); | |
154 m_readyAfterRelease->resolve(ToV8UndefinedGenerator()); | |
155 m_closedAfterRelease = new ClosedPromise(executionContext(), this, ReadyProm
ise::Closed); | |
156 | |
157 if (m_stream->stateInternal() == ReadableStream::Closed) { | 91 if (m_stream->stateInternal() == ReadableStream::Closed) { |
158 m_stateAfterRelease = ReadableStream::Closed; | 92 m_stateAfterRelease = ReadableStream::Closed; |
159 m_closedAfterRelease->resolve(ToV8UndefinedGenerator()); | 93 m_closed->resolve(ToV8UndefinedGenerator()); |
160 } else if (m_stream->stateInternal() == ReadableStream::Errored) { | 94 } else if (m_stream->stateInternal() == ReadableStream::Errored) { |
161 m_stateAfterRelease = ReadableStream::Errored; | 95 m_stateAfterRelease = ReadableStream::Errored; |
162 m_closedAfterRelease->reject(m_stream->storedException()); | 96 m_closed->reject(m_stream->storedException()); |
163 } else { | 97 } else { |
164 m_stateAfterRelease = ReadableStream::Closed; | 98 m_stateAfterRelease = ReadableStream::Closed; |
165 m_closedAfterRelease->resolve(ToV8UndefinedGenerator()); | 99 m_closed->resolve(ToV8UndefinedGenerator()); |
166 } | 100 } |
167 m_released->resolve(ToV8UndefinedGenerator()); | 101 |
| 102 // We call setReader(nullptr) after resolving / rejecting |m_closed| |
| 103 // because it affects hasPendingActivity. |
| 104 m_stream->setReader(nullptr); |
168 ASSERT(!isActive()); | 105 ASSERT(!isActive()); |
169 } | 106 } |
170 | 107 |
171 ScriptPromise ReadableStreamReader::released(ScriptState* scriptState) | |
172 { | |
173 return m_released->promise(scriptState->world()); | |
174 } | |
175 | |
176 bool ReadableStreamReader::hasPendingActivity() const | 108 bool ReadableStreamReader::hasPendingActivity() const |
177 { | 109 { |
178 // We need to extend ReadableStreamReader's wrapper's life while it is | 110 // We need to extend ReadableStreamReader's wrapper's life while it is |
179 // active in order to call resolve / reject on ScriptPromiseProperties. | 111 // active in order to call resolve / reject on ScriptPromiseProperties. |
180 return isActive(); | 112 return isActive(); |
181 } | 113 } |
182 | 114 |
183 void ReadableStreamReader::stop() | 115 void ReadableStreamReader::stop() |
184 { | 116 { |
185 releaseLock(); | 117 releaseLock(); |
186 ActiveDOMObject::stop(); | 118 ActiveDOMObject::stop(); |
187 } | 119 } |
188 | 120 |
189 DEFINE_TRACE(ReadableStreamReader) | 121 DEFINE_TRACE(ReadableStreamReader) |
190 { | 122 { |
191 visitor->trace(m_stream); | 123 visitor->trace(m_stream); |
192 visitor->trace(m_released); | 124 visitor->trace(m_closed); |
193 visitor->trace(m_closedAfterRelease); | |
194 visitor->trace(m_readyAfterRelease); | |
195 ActiveDOMObject::trace(visitor); | 125 ActiveDOMObject::trace(visitor); |
196 } | 126 } |
197 | 127 |
198 } // namespace blink | 128 } // namespace blink |
OLD | NEW |