| /third_party/gstreamer/gstreamer/gst/ |
| D | gstpromise.c | 104 GstPromise promise; member
129 gst_promise_wait (GstPromise * promise) in gst_promise_wait() argument
133 g_return_val_if_fail (promise != NULL, GST_PROMISE_RESULT_EXPIRED); in gst_promise_wait()
135 g_mutex_lock (GST_PROMISE_LOCK (promise)); in gst_promise_wait()
136 ret = GST_PROMISE_RESULT (promise); in gst_promise_wait()
139 GST_LOG ("%p waiting", promise); in gst_promise_wait()
140 g_cond_wait (GST_PROMISE_COND (promise), GST_PROMISE_LOCK (promise)); in gst_promise_wait()
141 ret = GST_PROMISE_RESULT (promise); in gst_promise_wait()
143 GST_LOG ("%p waited", promise); in gst_promise_wait()
145 g_mutex_unlock (GST_PROMISE_LOCK (promise)); in gst_promise_wait()
[all …]
|
| D | gstpromise.h | 63 typedef void (*GstPromiseChangeFunc) (GstPromise * promise, gpointer user_data);
84 GstPromiseResult gst_promise_wait (GstPromise * promise);
86 void gst_promise_reply (GstPromise * promise,
89 void gst_promise_interrupt (GstPromise * promise);
91 void gst_promise_expire (GstPromise * promise);
94 const GstStructure * gst_promise_get_reply (GstPromise * promise);
98 gst_promise_ref (GstPromise * promise) in gst_promise_ref() argument
100 return (GstPromise *) gst_mini_object_ref (GST_MINI_OBJECT_CAST (promise)); in gst_promise_ref()
104 gst_promise_unref (GstPromise * promise) in gst_promise_unref() argument
106 gst_mini_object_unref (GST_MINI_OBJECT_CAST (promise)); in gst_promise_unref()
[all …]
|
| /third_party/node/deps/npm/node_modules/es6-promise/lib/es6-promise/ |
| D | -internal.js | 37 function handleForeignThenable(promise, thenable, then) { argument
38 asap(promise => {
44 resolve(promise, value);
46 fulfill(promise, value);
52 reject(promise, reason);
53 }, 'Settle: ' + (promise._label || ' unknown promise'));
57 reject(promise, error);
59 }, promise);
62 function handleOwnThenable(promise, thenable) { argument
64 fulfill(promise, thenable._result);
[all …]
|
| D | enumerator.js | 29 this.promise = new Constructor(noop);
31 if (!this.promise[PROMISE_ID]) {
32 makePromise(this.promise);
42 fulfill(this.promise, this._result);
47 fulfill(this.promise, this._result);
51 reject(this.promise, validationError());
82 let promise = new c(noop);
84 reject(promise, error);
86 handleMaybeThenable(promise, entry, then);
88 this._willSettleAt(promise, i);
[all …]
|
| /third_party/node/deps/npm/node_modules/es6-promise/dist/ |
| D | es6-promise.js | 224 var promise = new Constructor(noop);
225 resolve(promise, object);
226 return promise;
253 function handleForeignThenable(promise, thenable, then$$1) { argument
254 asap(function (promise) { argument
262 resolve(promise, value);
264 fulfill(promise, value);
272 reject(promise, reason);
273 }, 'Settle: ' + (promise._label || ' unknown promise'));
277 reject(promise, error);
[all …]
|
| D | es6-promise.auto.js | 224 var promise = new Constructor(noop);
225 resolve(promise, object);
226 return promise;
253 function handleForeignThenable(promise, thenable, then$$1) { argument
254 asap(function (promise) { argument
262 resolve(promise, value);
264 fulfill(promise, value);
272 reject(promise, reason);
273 }, 'Settle: ' + (promise._label || ' unknown promise'));
277 reject(promise, error);
[all …]
|
| /third_party/boost/boost/fiber/future/ |
| D | promise.hpp | 105 class promise : private detail::promise_base< R > { class
110 promise() = default;
113 promise( std::allocator_arg_t, Allocator alloc) : in promise() function in boost::fibers::promise
117 promise( promise const&) = delete;
118 promise & operator=( promise const&) = delete;
120 promise( promise && other) noexcept = default;
121 promise & operator=( promise && other) = default;
137 void swap( promise & other) noexcept { in swap()
146 class promise< R & > : private detail::promise_base< R & > { class
151 promise() = default;
[all …]
|
| /third_party/ejdb/src/bindings/ejdb2_react_native/binding/android/src/main/java/com/softmotions/ejdb2/ |
| D | EJDB2DBModule.java | 35 public void open(String path, ReadableMap opts, Promise promise) { in open() argument
36 executor.execute(() -> openImpl(path, opts, promise)); in open()
39 private synchronized void openImpl(String path_, ReadableMap opts, Promise promise) { in openImpl() argument
51 promise.resolve(dbe.handle); in openImpl()
82 promise.resolve(handle); in openImpl()
84 promise.reject(String.valueOf(e.getCode()), e.toString()); in openImpl()
86 promise.reject(null, e.toString()); in openImpl()
91 public synchronized void close(Integer handle, Promise promise) { in close() argument
96 promise.reject(String.valueOf(e.getCode()), e.toString()); in close()
98 promise.reject(null, e.toString()); in close()
[all …]
|
| /third_party/typescript/tests/baselines/reference/ |
| D | es5-asyncFunctionLongObjectLiteral.symbols | 10 …: Symbol(PromiseConstructor.resolve, Decl(lib.es2015.promise.d.ts, --, --), Decl(lib.es2015.promis…
11 >Promise : Symbol(Promise, Decl(lib.es5.d.ts, --, --), Decl(lib.es2015.promise.d.ts, --, --))
12 …: Symbol(PromiseConstructor.resolve, Decl(lib.es2015.promise.d.ts, --, --), Decl(lib.es2015.promis…
16 …: Symbol(PromiseConstructor.resolve, Decl(lib.es2015.promise.d.ts, --, --), Decl(lib.es2015.promis…
17 >Promise : Symbol(Promise, Decl(lib.es5.d.ts, --, --), Decl(lib.es2015.promise.d.ts, --, --))
18 …: Symbol(PromiseConstructor.resolve, Decl(lib.es2015.promise.d.ts, --, --), Decl(lib.es2015.promis…
22 …: Symbol(PromiseConstructor.resolve, Decl(lib.es2015.promise.d.ts, --, --), Decl(lib.es2015.promis…
23 >Promise : Symbol(Promise, Decl(lib.es5.d.ts, --, --), Decl(lib.es2015.promise.d.ts, --, --))
24 …: Symbol(PromiseConstructor.resolve, Decl(lib.es2015.promise.d.ts, --, --), Decl(lib.es2015.promis…
28 …: Symbol(PromiseConstructor.resolve, Decl(lib.es2015.promise.d.ts, --, --), Decl(lib.es2015.promis…
[all …]
|
| D | types.asyncGenerators.es2018.1.symbols | 19 …: Symbol(PromiseConstructor.resolve, Decl(lib.es2015.promise.d.ts, --, --), Decl(lib.es2015.promis…
20 …ts, --, --), Decl(lib.es2015.promise.d.ts, --, --), Decl(lib.es2015.symbol.wellknown.d.ts, --, --)…
21 …: Symbol(PromiseConstructor.resolve, Decl(lib.es2015.promise.d.ts, --, --), Decl(lib.es2015.promis…
28 …: Symbol(PromiseConstructor.resolve, Decl(lib.es2015.promise.d.ts, --, --), Decl(lib.es2015.promis…
29 …ts, --, --), Decl(lib.es2015.promise.d.ts, --, --), Decl(lib.es2015.symbol.wellknown.d.ts, --, --)…
30 …: Symbol(PromiseConstructor.resolve, Decl(lib.es2015.promise.d.ts, --, --), Decl(lib.es2015.promis…
41 …: Symbol(PromiseConstructor.resolve, Decl(lib.es2015.promise.d.ts, --, --), Decl(lib.es2015.promis…
42 …ts, --, --), Decl(lib.es2015.promise.d.ts, --, --), Decl(lib.es2015.symbol.wellknown.d.ts, --, --)…
43 …: Symbol(PromiseConstructor.resolve, Decl(lib.es2015.promise.d.ts, --, --), Decl(lib.es2015.promis…
61 …: Symbol(PromiseConstructor.resolve, Decl(lib.es2015.promise.d.ts, --, --), Decl(lib.es2015.promis…
[all …]
|
| /third_party/boost/libs/fiber/doc/ |
| D | promise.qbk | 9 [section:promise Template `promise<>`]
12 later be retrieved from the corresponding __future__ object. `promise<>` and
15 #include <boost/fiber/future/promise.hpp>
21 class promise {
23 promise();
26 promise( __allocator_arg_t__, Allocator);
28 promise( promise &&) noexcept;
30 promise & operator=( promise &&) noexcept;
32 promise( promise const&) = delete;
34 promise & operator=( promise const&) = delete;
[all …]
|
| /third_party/node/deps/npm/node_modules/bluebird/js/release/ |
| D | promise.js | 134 var promise =
136 promise._setIsFinal();
167 return new PromiseArray(this).promise();
194 return new PromiseArray(promises).promise();
231 var promise = haveInternalData ? internalData : new Promise(INTERNAL);
236 promise._propagateFrom(this, 3);
237 promise._captureStackTrace();
246 this._fireEvent("promiseChained", this, promise);
270 promise: promise, property
275 target._addCallbacks(didFulfill, didReject, promise, receiver, domain);
[all …]
|
| D | thenables.js | 57 var promise = new Promise(INTERNAL);
58 var ret = promise;
60 promise._captureStackTrace();
66 if (promise && result === errorObj) {
67 promise._rejectCallback(result.e, true, true);
68 promise = null;
72 if (!promise) return;
73 promise._resolveCallback(value);
74 promise = null;
78 if (!promise) return;
[all …]
|
| D | cancel.js | 11 var promise = this;
12 var child = promise;
13 while (promise._isCancellable()) {
14 if (!promise._cancelBy(child)) {
23 var parent = promise._cancellationParent;
25 if (promise._isFollowing()) {
26 promise._followee().cancel();
28 promise._cancelBranched();
32 if (promise._isFollowing()) promise._followee().cancel();
33 promise._setWillBeCancelled();
[all …]
|
| D | using.js | 37 resources.promise);
52 function Disposer(data, promise, context) { argument
54 this._promise = promise;
62 Disposer.prototype.promise = function () { method in Disposer
67 if (this.promise().isFulfilled()) {
68 return this.promise().value();
91 function FunctionDisposer(fn, promise, context) { argument
92 this.constructor$(fn, promise, context);
104 return value.promise();
111 this.promise = null;
[all …]
|
| /third_party/node/deps/npm/node_modules/es6-promise/ |
| D | README.md | 1 …https://travis-ci.org/stefanpenner/es6-promise.svg?branch=master)](https://travis-ci.org/stefanpen…
3 This is a polyfill of the [ES6 Promise](http://www.ecma-international.org/ecma-262/6.0/#sec-promise…
9 * [es6-promise 27.86 KB (7.33 KB gzipped)](https://cdn.jsdelivr.net/npm/es6-promise/dist/es6-promis…
10 * [es6-promise-auto 27.78 KB (7.3 KB gzipped)](https://cdn.jsdelivr.net/npm/es6-promise/dist/es6-pr…
11 * [es6-promise-min 6.17 KB (2.4 KB gzipped)](https://cdn.jsdelivr.net/npm/es6-promise/dist/es6-prom…
12 …6-promise-auto-min 6.19 KB (2.4 KB gzipped)](https://cdn.jsdelivr.net/npm/es6-promise/dist/es6-pro…
20 <script src="https://cdn.jsdelivr.net/npm/es6-promise@4/dist/es6-promise.js"></script>
21 <script src="https://cdn.jsdelivr.net/npm/es6-promise@4/dist/es6-promise.auto.js"></script>
23 <!-- Minified version of `es6-promise-auto` below. -->
24 <script src="https://cdn.jsdelivr.net/npm/es6-promise@4/dist/es6-promise.min.js"></script>
[all …]
|
| /third_party/node/lib/internal/process/ |
| D | promises.js | 93 function promiseRejectHandler(type, promise, reason) { argument
99 unhandledRejection(promise, reason);
102 handledRejection(promise);
105 resolveError('resolve', promise, reason);
108 resolveError('reject', promise, reason);
113 function resolveError(type, promise, reason) { argument
117 process.emit('multipleResolves', type, promise, reason);
121 function unhandledRejection(promise, reason) { argument
122 maybeUnhandledPromises.set(promise, {
128 pendingUnhandledRejections.push(promise);
[all …]
|
| /third_party/boost/libs/fiber/examples/ |
| D | adapt_callbacks.cpp | 149 boost::fibers::promise< AsyncAPI::errorcode > promise; in write_ec() local
150 boost::fibers::future< AsyncAPI::errorcode > future( promise.get_future() ); in write_ec()
161 [promise=std::move( promise)]( AsyncAPI::errorcode ec) mutable { in write_ec()
162 promise.set_value( ec); in write_ec()
168 std::bind([](boost::fibers::promise< AsyncAPI::errorcode > & promise, in write_ec()
170 promise.set_value( ec); in write_ec()
172 std::move( promise), in write_ec()
192 boost::fibers::promise< result_pair > promise; in read_ec() local
193 boost::fibers::future< result_pair > future( promise.get_future() ); in read_ec()
197 …api.init_read([promise=std::move( promise)]( AsyncAPI::errorcode ec, std::string const& data) muta… in read_ec()
[all …]
|
| /third_party/node/test/parallel/ |
| D | test-promises-unhandled-rejections.js | 89 process.on('unhandledRejection', function(reason, promise) { argument
91 predicate(reason, promise);
101 process.on('unhandledRejection', function(reason, promise) { argument
115 onUnhandledSucceed(done, function(reason, promise) { argument
124 onUnhandledSucceed(done, function(reason, promise) { argument
135 onUnhandledSucceed(done, function(reason, promise) { argument
148 onUnhandledSucceed(done, function(reason, promise) { argument
161 onUnhandledSucceed(done, function(reason, promise) { argument
165 const promise = new Promise(function(_, reject) {
170 promise.then(assert.fail, function() {});
[all …]
|
| D | test-child-process-promisified.js | 11 const promise = exec(`${process.execPath} -p 42`); constant
13 assert(promise.child instanceof child_process.ChildProcess);
14 promise.then(common.mustCall((obj) => {
20 const promise = execFile(process.execPath, ['-p', '42']); constant
22 assert(promise.child instanceof child_process.ChildProcess);
23 promise.then(common.mustCall((obj) => {
29 const promise = exec('doesntexist'); constant
31 assert(promise.child instanceof child_process.ChildProcess);
32 promise.catch(common.mustCall((err) => {
38 const promise = execFile('doesntexist', ['-p', '42']); constant
[all …]
|
| /third_party/boost/libs/fiber/test/ |
| D | test_promise_dispatch.cpp | 36 void fn1( boost::fibers::promise< int > * p, int i) { in fn1()
42 boost::fibers::promise< int > p; in fn2()
88 boost::fibers::promise< int > p1; in test_promise_create()
91 std::allocator< boost::fibers::promise< int > > alloc; in test_promise_create()
92 boost::fibers::promise< int > p2( std::allocator_arg, alloc); in test_promise_create()
97 boost::fibers::promise< int& > p1; in test_promise_create_ref()
100 std::allocator< boost::fibers::promise< int& > > alloc; in test_promise_create_ref()
101 boost::fibers::promise< int& > p2( std::allocator_arg, alloc); in test_promise_create_ref()
106 boost::fibers::promise< void > p1; in test_promise_create_void()
109 std::allocator< boost::fibers::promise< void > > alloc; in test_promise_create_void()
[all …]
|
| D | test_promise_post.cpp | 36 void fn1( boost::fibers::promise< int > * p, int i) { in fn1()
42 boost::fibers::promise< int > p; in fn2()
88 boost::fibers::promise< int > p1; in test_promise_create()
91 std::allocator< boost::fibers::promise< int > > alloc; in test_promise_create()
92 boost::fibers::promise< int > p2( std::allocator_arg, alloc); in test_promise_create()
97 boost::fibers::promise< int& > p1; in test_promise_create_ref()
100 std::allocator< boost::fibers::promise< int& > > alloc; in test_promise_create_ref()
101 boost::fibers::promise< int& > p2( std::allocator_arg, alloc); in test_promise_create_ref()
106 boost::fibers::promise< void > p1; in test_promise_create_void()
109 std::allocator< boost::fibers::promise< void > > alloc; in test_promise_create_void()
[all …]
|
| /third_party/mindspore/mindspore/core/mindrt/include/async/ |
| D | async.h | 65 auto promise = std::shared_ptr<Promise<R>>(new (std::nothrow) Promise<R>());
66 MINDRT_OOM_EXIT(promise);
67 Future<R> future = promise->GetFuture();
69 MessageHandler handler = [=](ActorBase *) { promise->Associate(f()); };
82 auto promise = std::shared_ptr<Promise<R>>(new (std::nothrow) Promise<R>());
83 MINDRT_OOM_EXIT(promise);
84 Future<R> future = promise->GetFuture();
86 std::function<void(ActorBase *)> handler = [=](ActorBase *) { promise->SetValue(f()); };
145 auto promise = std::shared_ptr<Promise<R>>(new (std::nothrow) Promise<R>());
146 MINDRT_OOM_EXIT(promise);
[all …]
|
| /third_party/node/lib/internal/ |
| D | async_hooks.js | 305 function trackPromise(promise, parent) { argument
306 if (promise[async_id_symbol]) {
315 promise[async_id_symbol] = newAsyncId();
316 promise[trigger_async_id_symbol] = triggerAsyncId;
319 function promiseInitHook(promise, parent) { argument
320 trackPromise(promise, parent);
321 const asyncId = promise[async_id_symbol];
322 const triggerAsyncId = promise[trigger_async_id_symbol];
323 emitInitScript(asyncId, 'PROMISE', triggerAsyncId, promise);
326 function promiseInitHookWithDestroyTracking(promise, parent) { argument
[all …]
|
| /third_party/gstreamer/gstplugins_bad/tests/examples/webrtc/ |
| D | webrtcbidirectional.c | 81 _on_answer_received (GstPromise * promise, gpointer user_data) in _on_answer_received() argument
87 g_assert (gst_promise_wait (promise) == GST_PROMISE_RESULT_REPLIED); in _on_answer_received()
88 reply = gst_promise_get_reply (promise); in _on_answer_received()
91 gst_promise_unref (promise); in _on_answer_received()
101 promise = gst_promise_new (); in _on_answer_received()
102 g_signal_emit_by_name (webrtc2, "set-local-description", answer, promise); in _on_answer_received()
103 gst_promise_interrupt (promise); in _on_answer_received()
104 gst_promise_unref (promise); in _on_answer_received()
110 _on_offer_received (GstPromise * promise, gpointer user_data) in _on_offer_received() argument
116 g_assert (gst_promise_wait (promise) == GST_PROMISE_RESULT_REPLIED); in _on_offer_received()
[all …]
|