OLD | NEW |
---|---|
1 /* | 1 /* |
2 * Copyright (C) 2013 Google Inc. All rights reserved. | 2 * Copyright (C) 2013 Google Inc. All rights reserved. |
3 * | 3 * |
4 * Redistribution and use in source and binary forms, with or without | 4 * Redistribution and use in source and binary forms, with or without |
5 * modification, are permitted provided that the following conditions are | 5 * modification, are permitted provided that the following conditions are |
6 * met: | 6 * met: |
7 * | 7 * |
8 * * Redistributions of source code must retain the above copyright | 8 * * Redistributions of source code must retain the above copyright |
9 * notice, this list of conditions and the following disclaimer. | 9 * notice, this list of conditions and the following disclaimer. |
10 * * Redistributions in binary form must reproduce the above | 10 * * Redistributions in binary form must reproduce the above |
(...skipping 15 matching lines...) Expand all Loading... | |
26 * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT | 26 * THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT |
27 * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE | 27 * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE |
28 * OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. | 28 * OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. |
29 */ | 29 */ |
30 | 30 |
31 #ifndef CallbackPromiseAdapter_h | 31 #ifndef CallbackPromiseAdapter_h |
32 #define CallbackPromiseAdapter_h | 32 #define CallbackPromiseAdapter_h |
33 | 33 |
34 #include "bindings/core/v8/ScriptPromiseResolver.h" | 34 #include "bindings/core/v8/ScriptPromiseResolver.h" |
35 #include "public/platform/WebCallbacks.h" | 35 #include "public/platform/WebCallbacks.h" |
36 #include "public/platform/WebPrivateOwnPtr.h" | |
37 #include "wtf/OwnPtr.h" | |
38 #include "wtf/PassOwnPtr.h" | |
36 | 39 |
37 namespace blink { | 40 namespace blink { |
38 | 41 |
39 // This class provides an easy way to convert from a Script-exposed | 42 class CallbackPromiseAdapterBase { |
kinuko
2015/07/15 06:19:23
nit: This could probably be done without inheritan
yhirano
2015/07/15 08:49:45
Yes. Do you like PS2?
By the way, I'm not very int
kinuko
2015/07/21 11:27:06
Ok, understood.
| |
40 // class (i.e. a class that has a toV8() overload) that uses Promises | 43 public: |
41 // to a WebKit API class that uses WebCallbacks. You can define | 44 template <typename T> |
42 // separate Success and Error classes, but this example just uses one | 45 struct PassTypeImpl { |
43 // object for both. | 46 using Type = T; |
44 // | 47 }; |
45 // To use: | 48 template <typename T> |
46 // | 49 struct PassTypeImpl<OwnPtr<T>> { |
47 // class MyClass ... { | 50 using Type = PassOwnPtr<T>; |
48 // typedef blink::WebMyClass WebType; | 51 }; |
49 // | 52 |
50 // // Takes ownership of |webInstance|. | 53 template <typename T> |
51 // static PassRefPtr<MyClass> take(ScriptPromiseResolver* resolver, | 54 struct WebPassTypeImpl { |
52 // PassOwnPtr<blink::WebMyClass> webInstance) { | 55 using Type = T; |
53 // // convert/create as appropriate, but often it's just: | 56 }; |
54 // return MyClass::create(webInstance); | 57 template <typename T> |
55 // | 58 struct WebPassTypeImpl<OwnPtr<T>> { |
56 // // Since promise resolving is done as an async task, it's not | 59 using Type = WebPrivateOwnPtr<T>&&; |
kinuko
2015/07/15 06:19:24
Rvalue reference is currently not allowed. We coul
yhirano
2015/07/15 08:49:45
I see. I uploaded a separate CL https://codereview
| |
57 // // guaranteed that the script context has seen the promise resolve | 60 }; |
58 // // immediately after calling onSuccess/onError. You can use the | 61 |
59 // // ScriptPromise from the resolver to schedule a task that executes | 62 template <typename T> |
60 // // after resolving: | 63 using PassType = typename PassTypeImpl<T>::Type; |
61 // ScriptState::Scope scope(resolver->scriptState()); | 64 template <typename T> |
62 // resolver->promise().then(...); | 65 using WebPassType = typename WebPassTypeImpl<T>::Type; |
63 // } | 66 |
64 // | 67 // TODO(yhirano): Use universal reference and std::forward. |
kinuko
2015/07/15 06:19:23
nit: do you mean this TODO to be resolved after we
yhirano
2015/07/15 08:49:45
Done.
| |
65 // Now when calling into a WebKit API that requires a WebCallbacks<blink::WebMyC lass, blink::WebMyClass>*: | 68 template <typename T> |
66 // | 69 static T& adopt(T& x) { return x; } |
67 // // call signature: callSomeMethod(WebCallbacks<MyClass, MyClass>* callback s) | 70 template <typename T> |
68 // webObject->callSomeMethod(new CallbackPromiseAdapter<MyClass, MyClass>(res olver, scriptExecutionContext)); | 71 static PassOwnPtr<T> adopt(WebPrivateOwnPtr<T>& x) { return x.release(); } |
69 // | 72 |
70 // Note: | 73 // TODO(yhirano): Use rvalue reference and std::move. |
71 // - This class does not manage its own lifetime. In this example that ownership | 74 template <typename T> |
72 // of the WebCallbacks instance is being passed in and it is up to the callee | 75 static PassType<T> pass(T& x) { return x; } |
73 // to free the WebCallbacks instance. | 76 template <typename T> |
74 // - onSuccess and onError take ownership of the given WebType instance. | 77 static PassOwnPtr<T> pass(OwnPtr<T>& x) { return x.release(); } |
78 }; | |
79 | |
80 | |
81 // TODO(yhirano): Add comments. | |
75 template<typename S, typename T> | 82 template<typename S, typename T> |
76 class CallbackPromiseAdapter final : public WebCallbacks<typename S::WebType*, t ypename T::WebType*> { | 83 class CallbackPromiseAdapter final |
84 : public WebCallbacks<typename CallbackPromiseAdapterBase::WebPassType<typen ame S::WebType>, typename CallbackPromiseAdapterBase::WebPassType<typename T::We bType>>, public CallbackPromiseAdapterBase { | |
77 WTF_MAKE_NONCOPYABLE(CallbackPromiseAdapter); | 85 WTF_MAKE_NONCOPYABLE(CallbackPromiseAdapter); |
78 public: | 86 public: |
79 explicit CallbackPromiseAdapter(PassRefPtrWillBeRawPtr<ScriptPromiseResolver > resolver) | 87 explicit CallbackPromiseAdapter(PassRefPtrWillBeRawPtr<ScriptPromiseResolver > resolver) |
80 : m_resolver(resolver) | 88 : m_resolver(resolver) |
81 { | 89 { |
82 ASSERT(m_resolver); | 90 ASSERT(m_resolver); |
83 } | 91 } |
84 ~CallbackPromiseAdapter() override { } | 92 ~CallbackPromiseAdapter() override { } |
85 | 93 |
86 // Takes ownership of |result|. | 94 void onSuccess(WebPassType<typename S::WebType> r) override |
87 void onSuccess(typename S::WebType* result) override | |
88 { | 95 { |
89 OwnPtr<typename S::WebType> ownPtr = adoptPtr(result); | 96 typename S::WebType result(adopt(r)); |
90 if (!m_resolver->executionContext() || m_resolver->executionContext()->a ctiveDOMObjectsAreStopped()) | 97 if (!m_resolver->executionContext() || m_resolver->executionContext()->a ctiveDOMObjectsAreStopped()) |
91 return; | 98 return; |
92 m_resolver->resolve(S::take(m_resolver.get(), ownPtr.release())); | 99 m_resolver->resolve(S::take(m_resolver.get(), pass(result))); |
93 } | 100 } |
94 | 101 |
95 // Takes ownership of |error|. | 102 void onError(WebPassType<typename T::WebType> e) override |
96 void onError(typename T::WebType* error) override | |
97 { | 103 { |
98 OwnPtr<typename T::WebType> ownPtr = adoptPtr(error); | 104 typename T::WebType error(adopt(e)); |
99 if (!m_resolver->executionContext() || m_resolver->executionContext()->a ctiveDOMObjectsAreStopped()) | 105 if (!m_resolver->executionContext() || m_resolver->executionContext()->a ctiveDOMObjectsAreStopped()) |
100 return; | 106 return; |
101 m_resolver->reject(T::take(m_resolver.get(), ownPtr.release())); | 107 m_resolver->reject(T::take(m_resolver.get(), pass(error))); |
102 } | 108 } |
103 | 109 |
104 private: | 110 private: |
105 RefPtrWillBePersistent<ScriptPromiseResolver> m_resolver; | 111 RefPtrWillBePersistent<ScriptPromiseResolver> m_resolver; |
106 }; | 112 }; |
107 | 113 |
108 template<typename T> | 114 template<typename T> |
109 class CallbackPromiseAdapter<void, T> final : public WebCallbacks<void, typename T::WebType*> { | 115 class CallbackPromiseAdapter<void, T> final : public WebCallbacks<void, typename CallbackPromiseAdapterBase::WebPassType<typename T::WebType>>, public CallbackP romiseAdapterBase { |
110 WTF_MAKE_NONCOPYABLE(CallbackPromiseAdapter); | 116 WTF_MAKE_NONCOPYABLE(CallbackPromiseAdapter); |
111 public: | 117 public: |
112 explicit CallbackPromiseAdapter(PassRefPtrWillBeRawPtr<ScriptPromiseResolver > resolver) | 118 explicit CallbackPromiseAdapter(PassRefPtrWillBeRawPtr<ScriptPromiseResolver > resolver) |
113 : m_resolver(resolver) | 119 : m_resolver(resolver) |
114 { | 120 { |
115 ASSERT(m_resolver); | 121 ASSERT(m_resolver); |
116 } | 122 } |
117 ~CallbackPromiseAdapter() override { } | 123 ~CallbackPromiseAdapter() override { } |
118 | 124 |
119 void onSuccess() override | 125 void onSuccess() override |
120 { | 126 { |
121 if (!m_resolver->executionContext() || m_resolver->executionContext()->a ctiveDOMObjectsAreStopped()) | 127 if (!m_resolver->executionContext() || m_resolver->executionContext()->a ctiveDOMObjectsAreStopped()) |
122 return; | 128 return; |
123 m_resolver->resolve(); | 129 m_resolver->resolve(); |
124 } | 130 } |
125 | 131 |
126 // Takes ownership of |error|. | 132 void onError(WebPassType<typename T::WebType> e) override |
127 void onError(typename T::WebType* error) override | |
128 { | 133 { |
129 OwnPtr<typename T::WebType> ownPtr = adoptPtr(error); | 134 typename T::WebType error(adopt(e)); |
130 if (!m_resolver->executionContext() || m_resolver->executionContext()->a ctiveDOMObjectsAreStopped()) | 135 if (!m_resolver->executionContext() || m_resolver->executionContext()->a ctiveDOMObjectsAreStopped()) |
131 return; | 136 return; |
132 m_resolver->reject(T::take(m_resolver.get(), ownPtr.release())); | 137 m_resolver->reject(T::take(m_resolver.get(), pass(error))); |
133 } | 138 } |
134 | 139 |
135 private: | 140 private: |
136 RefPtrWillBePersistent<ScriptPromiseResolver> m_resolver; | 141 RefPtrWillBePersistent<ScriptPromiseResolver> m_resolver; |
137 }; | 142 }; |
138 | 143 |
139 template<typename S> | 144 template<typename S> |
140 class CallbackPromiseAdapter<S, void> final : public WebCallbacks<typename S::We bType*, void> { | 145 class CallbackPromiseAdapter<S, void> final : public WebCallbacks<typename Callb ackPromiseAdapterBase::WebPassType<typename S::WebType>, void>, public CallbackP romiseAdapterBase { |
141 WTF_MAKE_NONCOPYABLE(CallbackPromiseAdapter); | 146 WTF_MAKE_NONCOPYABLE(CallbackPromiseAdapter); |
142 public: | 147 public: |
143 explicit CallbackPromiseAdapter(PassRefPtrWillBeRawPtr<ScriptPromiseResolver > resolver) | 148 explicit CallbackPromiseAdapter(PassRefPtrWillBeRawPtr<ScriptPromiseResolver > resolver) |
144 : m_resolver(resolver) | 149 : m_resolver(resolver) |
145 { | 150 { |
146 ASSERT(m_resolver); | 151 ASSERT(m_resolver); |
147 } | 152 } |
148 ~CallbackPromiseAdapter() override { } | 153 ~CallbackPromiseAdapter() override { } |
149 | 154 |
150 // Takes ownership of |result|. | 155 void onSuccess(WebPassType<typename S::WebType> r) override |
151 void onSuccess(typename S::WebType* result) override | |
152 { | 156 { |
153 OwnPtr<typename S::WebType> ownPtr = adoptPtr(result); | 157 typename S::WebType result(adopt(r)); |
154 if (!m_resolver->executionContext() || m_resolver->executionContext()->a ctiveDOMObjectsAreStopped()) | 158 if (!m_resolver->executionContext() || m_resolver->executionContext()->a ctiveDOMObjectsAreStopped()) |
155 return; | 159 return; |
156 m_resolver->resolve(S::take(m_resolver.get(), ownPtr.release())); | 160 m_resolver->resolve(S::take(m_resolver.get(), pass(result))); |
157 } | 161 } |
158 | 162 |
159 void onError() override | 163 void onError() override |
160 { | 164 { |
161 if (!m_resolver->executionContext() || m_resolver->executionContext()->a ctiveDOMObjectsAreStopped()) | 165 if (!m_resolver->executionContext() || m_resolver->executionContext()->a ctiveDOMObjectsAreStopped()) |
162 return; | 166 return; |
163 m_resolver->reject(); | 167 m_resolver->reject(); |
164 } | 168 } |
165 | 169 |
166 private: | 170 private: |
167 RefPtrWillBePersistent<ScriptPromiseResolver> m_resolver; | 171 RefPtrWillBePersistent<ScriptPromiseResolver> m_resolver; |
168 }; | 172 }; |
169 | 173 |
170 template<typename T> | 174 template<typename T> |
171 class CallbackPromiseAdapter<bool, T> final : public WebCallbacks<bool*, typenam e T::WebType*> { | 175 class CallbackPromiseAdapter<bool, T> final : public WebCallbacks<bool*, typenam e CallbackPromiseAdapterBase::WebPassType<typename T::WebType>>, public Callback PromiseAdapterBase { |
172 WTF_MAKE_NONCOPYABLE(CallbackPromiseAdapter); | 176 WTF_MAKE_NONCOPYABLE(CallbackPromiseAdapter); |
173 public: | 177 public: |
174 explicit CallbackPromiseAdapter(PassRefPtrWillBeRawPtr<ScriptPromiseResolver > resolver) | 178 explicit CallbackPromiseAdapter(PassRefPtrWillBeRawPtr<ScriptPromiseResolver > resolver) |
175 : m_resolver(resolver) | 179 : m_resolver(resolver) |
176 { | 180 { |
177 ASSERT(m_resolver); | 181 ASSERT(m_resolver); |
178 } | 182 } |
179 ~CallbackPromiseAdapter() override { } | 183 ~CallbackPromiseAdapter() override { } |
180 | 184 |
181 // TODO(nhiroki): onSuccess should take ownership of a bool object for | 185 // TODO(nhiroki): onSuccess should take ownership of a bool object for |
182 // consistency. (http://crbug.com/493531) | 186 // consistency. (http://crbug.com/493531) |
183 void onSuccess(bool* result) override | 187 void onSuccess(bool* result) override |
184 { | 188 { |
185 if (!m_resolver->executionContext() || m_resolver->executionContext()->a ctiveDOMObjectsAreStopped()) | 189 if (!m_resolver->executionContext() || m_resolver->executionContext()->a ctiveDOMObjectsAreStopped()) |
186 return; | 190 return; |
187 m_resolver->resolve(*result); | 191 m_resolver->resolve(*result); |
188 } | 192 } |
189 | 193 |
190 // Takes ownership of |error|. | 194 void onError(WebPassType<typename T::WebType> e) override |
191 void onError(typename T::WebType* error) override | |
192 { | 195 { |
193 OwnPtr<typename T::WebType> ownPtr = adoptPtr(error); | 196 typename T::WebType error(adopt(e)); |
194 if (!m_resolver->executionContext() || m_resolver->executionContext()->a ctiveDOMObjectsAreStopped()) | 197 if (!m_resolver->executionContext() || m_resolver->executionContext()->a ctiveDOMObjectsAreStopped()) |
195 return; | 198 return; |
196 m_resolver->reject(T::take(m_resolver.get(), ownPtr.release())); | 199 m_resolver->reject(T::take(m_resolver.get(), pass(error))); |
197 } | 200 } |
198 | 201 |
199 private: | 202 private: |
200 RefPtrWillBePersistent<ScriptPromiseResolver> m_resolver; | 203 RefPtrWillBePersistent<ScriptPromiseResolver> m_resolver; |
201 }; | 204 }; |
202 | 205 |
203 template<> | 206 template<> |
204 class CallbackPromiseAdapter<void, void> final : public WebCallbacks<void, void> { | 207 class CallbackPromiseAdapter<void, void> final : public WebCallbacks<void, void> , public CallbackPromiseAdapterBase { |
205 WTF_MAKE_NONCOPYABLE(CallbackPromiseAdapter); | 208 WTF_MAKE_NONCOPYABLE(CallbackPromiseAdapter); |
206 public: | 209 public: |
207 explicit CallbackPromiseAdapter(PassRefPtrWillBeRawPtr<ScriptPromiseResolver > resolver) | 210 explicit CallbackPromiseAdapter(PassRefPtrWillBeRawPtr<ScriptPromiseResolver > resolver) |
208 : m_resolver(resolver) | 211 : m_resolver(resolver) |
209 { | 212 { |
210 ASSERT(m_resolver); | 213 ASSERT(m_resolver); |
211 } | 214 } |
212 ~CallbackPromiseAdapter() override { } | 215 ~CallbackPromiseAdapter() override { } |
213 | 216 |
214 void onSuccess() override | 217 void onSuccess() override |
215 { | 218 { |
216 if (!m_resolver->executionContext() || m_resolver->executionContext()->a ctiveDOMObjectsAreStopped()) | 219 if (!m_resolver->executionContext() || m_resolver->executionContext()->a ctiveDOMObjectsAreStopped()) |
217 return; | 220 return; |
218 m_resolver->resolve(); | 221 m_resolver->resolve(); |
219 } | 222 } |
220 | 223 |
221 void onError() override | 224 void onError() override |
222 { | 225 { |
223 if (!m_resolver->executionContext() || m_resolver->executionContext()->a ctiveDOMObjectsAreStopped()) | 226 if (!m_resolver->executionContext() || m_resolver->executionContext()->a ctiveDOMObjectsAreStopped()) |
224 return; | 227 return; |
225 m_resolver->reject(); | 228 m_resolver->reject(); |
226 } | 229 } |
227 | 230 |
228 private: | 231 private: |
229 RefPtrWillBePersistent<ScriptPromiseResolver> m_resolver; | 232 RefPtrWillBePersistent<ScriptPromiseResolver> m_resolver; |
230 }; | 233 }; |
231 | 234 |
232 template<> | 235 template<> |
233 class CallbackPromiseAdapter<bool, void> final : public WebCallbacks<bool*, void > { | 236 class CallbackPromiseAdapter<bool, void> final : public WebCallbacks<bool*, void >, public CallbackPromiseAdapterBase { |
234 WTF_MAKE_NONCOPYABLE(CallbackPromiseAdapter); | 237 WTF_MAKE_NONCOPYABLE(CallbackPromiseAdapter); |
235 public: | 238 public: |
236 explicit CallbackPromiseAdapter(PassRefPtrWillBeRawPtr<ScriptPromiseResolver > resolver) | 239 explicit CallbackPromiseAdapter(PassRefPtrWillBeRawPtr<ScriptPromiseResolver > resolver) |
237 : m_resolver(resolver) | 240 : m_resolver(resolver) |
238 { | 241 { |
239 ASSERT(m_resolver); | 242 ASSERT(m_resolver); |
240 } | 243 } |
241 ~CallbackPromiseAdapter() override { } | 244 ~CallbackPromiseAdapter() override { } |
242 | 245 |
243 // TODO(nhiroki): onSuccess should take ownership of a bool object for | 246 // TODO(nhiroki): onSuccess should take ownership of a bool object for |
(...skipping 12 matching lines...) Expand all Loading... | |
256 m_resolver->reject(); | 259 m_resolver->reject(); |
257 } | 260 } |
258 | 261 |
259 private: | 262 private: |
260 RefPtrWillBePersistent<ScriptPromiseResolver> m_resolver; | 263 RefPtrWillBePersistent<ScriptPromiseResolver> m_resolver; |
261 }; | 264 }; |
262 | 265 |
263 } // namespace blink | 266 } // namespace blink |
264 | 267 |
265 #endif | 268 #endif |
OLD | NEW |