/external/v8/src/runtime/ |
D | runtime-promise.cc | 20 CONVERT_ARG_HANDLE_CHECKED(JSPromise, promise, 0); in RUNTIME_FUNCTION() 23 Handle<Object> rejected_promise = promise; in RUNTIME_FUNCTION() 29 isolate->RunPromiseHook(PromiseHookType::kResolve, promise, in RUNTIME_FUNCTION() 34 if (!promise->has_handler()) { in RUNTIME_FUNCTION() 35 isolate->ReportPromiseReject(promise, value, in RUNTIME_FUNCTION() 44 CONVERT_ARG_HANDLE_CHECKED(JSPromise, promise, 0); in RUNTIME_FUNCTION() 46 isolate->ReportPromiseReject(promise, reason, in RUNTIME_FUNCTION() 54 CONVERT_ARG_HANDLE_CHECKED(JSPromise, promise, 0); in RUNTIME_FUNCTION() 56 isolate->ReportPromiseReject(promise, resolution, in RUNTIME_FUNCTION() 64 CONVERT_ARG_HANDLE_CHECKED(JSPromise, promise, 0); in RUNTIME_FUNCTION() [all …]
|
/external/grpc-grpc-java/netty/src/main/java/io/grpc/netty/ |
D | WriteQueue.java | 79 Preconditions.checkArgument(command.promise() == null, "promise must not be set on command"); in enqueue() 81 ChannelPromise promise = channel.newPromise(); in enqueue() local 82 command.promise(promise); in enqueue() 87 return promise; in enqueue() 143 public final void promise(ChannelPromise promise) { in promise() argument 148 public final ChannelPromise promise() { in promise() method in WriteQueue.RunnableCommand 160 private ChannelPromise promise; field in WriteQueue.AbstractQueuedCommand 163 public final void promise(ChannelPromise promise) { in promise() method in WriteQueue.AbstractQueuedCommand 164 this.promise = promise; in promise() 168 public final ChannelPromise promise() { in promise() method in WriteQueue.AbstractQueuedCommand [all …]
|
D | SendGrpcFrameCommand.java | 32 private ChannelPromise promise; field in SendGrpcFrameCommand 110 public ChannelPromise promise() { in promise() method in SendGrpcFrameCommand 111 return promise; in promise() 115 public void promise(ChannelPromise promise) { in promise() argument 116 this.promise = promise; in promise() 121 channel.write(this, promise); in run()
|
D | NettyClientHandler.java | 297 public void write(ChannelHandlerContext ctx, Object msg, ChannelPromise promise) in write() argument 300 createStream((CreateStreamCommand) msg, promise); in write() local 302 sendGrpcFrame(ctx, (SendGrpcFrameCommand) msg, promise); in write() 304 cancelStream(ctx, (CancelClientStreamCommand) msg, promise); in write() 306 sendPingFrame(ctx, (SendPingCommand) msg, promise); in write() 308 gracefulClose(ctx, (GracefulCloseCommand) msg, promise); in write() 310 forcefulClose(ctx, (ForcefulCloseCommand) msg, promise); in write() 312 ctx.write(Unpooled.EMPTY_BUFFER, promise); in write() 383 public void close(ChannelHandlerContext ctx, ChannelPromise promise) throws Exception { in close() argument 389 super.close(ctx, promise); in close() [all …]
|
/external/libcxx/test/std/thread/futures/futures.promise/ |
D | copy_ctor.fail.cpp | 26 std::promise<int> p0; in main() 27 … std::promise<int> p(p0); // expected-error {{call to deleted constructor of 'std::promise<int>'}} in main() 30 std::promise<int &> p0; in main() 31 …std::promise<int &> p(p0); // expected-error {{call to deleted constructor of 'std::promise<int &>… in main() 34 std::promise<void> p0; in main() 35 …std::promise<void> p(p0); // expected-error {{call to deleted constructor of 'std::promise<void>'}} in main() 39 std::promise<int> p0; in main() 40 …std::promise<int> p(p0); // expected-error {{calling a private constructor of class 'std::__1::pro… in main() 43 std::promise<int &> p0; in main() 44 …std::promise<int &> p(p0); // expected-error {{calling a private constructor of class 'std::__1::p… in main() [all …]
|
D | alloc_ctor.pass.cpp | 30 std::promise<int> p(std::allocator_arg, test_allocator<int>(42)); in main() 38 std::promise<int&> p(std::allocator_arg, test_allocator<int>(42)); in main() 46 std::promise<void> p(std::allocator_arg, test_allocator<void>(42)); in main() 55 std::promise<int> p(std::allocator_arg, bare_allocator<void>()); in main() 60 std::promise<int&> p(std::allocator_arg, bare_allocator<void>()); in main() 65 std::promise<void> p(std::allocator_arg, bare_allocator<void>()); in main() 71 std::promise<int> p(std::allocator_arg, min_allocator<void>()); in main() 76 std::promise<int&> p(std::allocator_arg, min_allocator<void>()); in main() 81 std::promise<void> p(std::allocator_arg, min_allocator<void>()); in main()
|
D | copy_assign.fail.cpp | 26 std::promise<int> p0, p; in main() 30 std::promise<int&> p0, p; in main() 34 std::promise<void> p0, p; in main() 39 std::promise<int> p0, p; in main() 43 std::promise<int&> p0, p; in main() 47 std::promise<void> p0, p; in main()
|
D | swap.pass.cpp | 30 std::promise<int> p0(std::allocator_arg, test_allocator<int>()); in main() 31 std::promise<int> p(std::allocator_arg, test_allocator<int>()); in main() 44 std::promise<int> p0(std::allocator_arg, test_allocator<int>()); in main() 45 std::promise<int> p(std::allocator_arg, test_allocator<int>()); in main() 58 std::promise<int> p0(std::allocator_arg, test_allocator<int>()); in main() 59 std::promise<int> p; in main() 72 std::promise<int> p0(std::allocator_arg, test_allocator<int>()); in main() 73 std::promise<int> p; in main()
|
D | move_ctor.pass.cpp | 29 std::promise<int> p0(std::allocator_arg, test_allocator<int>()); in main() 30 std::promise<int> p(std::move(p0)); in main() 50 std::promise<int&> p0(std::allocator_arg, test_allocator<int>()); in main() 51 std::promise<int&> p(std::move(p0)); in main() 71 std::promise<void> p0(std::allocator_arg, test_allocator<void>()); in main() 72 std::promise<void> p(std::move(p0)); in main()
|
D | dtor.pass.cpp | 30 std::promise<T> p; in main() 41 std::promise<T> p; in main() 62 std::promise<T> p; in main() 73 std::promise<T> p; in main() 93 std::promise<T> p; in main() 105 std::promise<T> p; in main()
|
D | move_assign.pass.cpp | 29 std::promise<int> p0(std::allocator_arg, test_allocator<int>()); in main() 30 std::promise<int> p(std::allocator_arg, test_allocator<int>()); in main() 52 std::promise<int&> p0(std::allocator_arg, test_allocator<int>()); in main() 53 std::promise<int&> p(std::allocator_arg, test_allocator<int>()); in main() 75 std::promise<void> p0(std::allocator_arg, test_allocator<void>()); in main() 76 std::promise<void> p(std::allocator_arg, test_allocator<void>()); in main()
|
/external/libcxx/test/std/thread/futures/futures.shared_future/ |
D | get.pass.cpp | 26 void func1(std::promise<int> p) in func1() 32 void func2(std::promise<int> p) in func2() 40 void func3(std::promise<int&> p) in func3() 47 void func4(std::promise<int&> p) in func4() 53 void func5(std::promise<void> p) in func5() 59 void func6(std::promise<void> p) in func6() 70 std::promise<T> p; in main() 79 std::promise<T> p; in main() 99 std::promise<T> p; in main() 108 std::promise<T> p; in main() [all …]
|
D | wait.pass.cpp | 22 void func1(std::promise<int> p) in func1() 30 void func3(std::promise<int&> p) in func3() 37 void func5(std::promise<void> p) in func5() 49 std::promise<T> p; in main() 63 std::promise<T> p; in main() 77 std::promise<T> p; in main()
|
/external/libcxx/test/std/thread/futures/futures.unique_future/ |
D | get.pass.cpp | 26 void func1(std::promise<int> p) in func1() 32 void func2(std::promise<int> p) in func2() 40 void func3(std::promise<int&> p) in func3() 47 void func4(std::promise<int&> p) in func4() 53 void func5(std::promise<void> p) in func5() 59 void func6(std::promise<void> p) in func6() 70 std::promise<T> p; in main() 79 std::promise<T> p; in main() 99 std::promise<T> p; in main() 108 std::promise<T> p; in main() [all …]
|
D | wait.pass.cpp | 22 void func1(std::promise<int> p) in func1() 30 void func3(std::promise<int&> p) in func3() 37 void func5(std::promise<void> p) in func5() 49 std::promise<T> p; in main() 63 std::promise<T> p; in main() 77 std::promise<T> p; in main()
|
/external/libcxx/include/ |
D | future | 59 class promise 62 promise(); 64 promise(allocator_arg_t, const Allocator& a); 65 promise(promise&& rhs) noexcept; 66 promise(const promise& rhs) = delete; 67 ~promise(); 70 promise& operator=(promise&& rhs) noexcept; 71 promise& operator=(const promise& rhs) = delete; 72 void swap(promise& other) noexcept; 89 class promise<R&> [all …]
|
/external/grpc-grpc-java/alts/src/main/java/io/grpc/alts/internal/ |
D | TsiFrameHandler.java | 82 public void write(ChannelHandlerContext ctx, Object message, ChannelPromise promise) in write() argument 89 Future<?> possiblyIgnoredError = promise.setSuccess(); in write() 94 pendingUnprotectedWrites.add(msg, promise); in write() 112 public void bind(ChannelHandlerContext ctx, SocketAddress localAddress, ChannelPromise promise) { in bind() argument 113 ctx.bind(localAddress, promise); in bind() 121 ChannelPromise promise) { in connect() argument 122 ctx.connect(remoteAddress, localAddress, promise); in connect() 126 public void disconnect(ChannelHandlerContext ctx, ChannelPromise promise) { in disconnect() argument 127 ctx.disconnect(promise); in disconnect() 131 public void close(ChannelHandlerContext ctx, ChannelPromise promise) { in close() argument [all …]
|
/external/v8/src/builtins/ |
D | builtins-promise-gen.cc | 28 Node* const promise = Allocate(JSPromise::kSizeWithEmbedderFields); in AllocateJSPromise() local 29 StoreMapNoWriteBarrier(promise, promise_map); in AllocateJSPromise() 30 StoreObjectFieldRoot(promise, JSPromise::kPropertiesOrHashOffset, in AllocateJSPromise() 32 StoreObjectFieldRoot(promise, JSPromise::kElementsOffset, in AllocateJSPromise() 34 return promise; in AllocateJSPromise() 37 void PromiseBuiltinsAssembler::PromiseInit(Node* promise) { in PromiseInit() argument 39 StoreObjectFieldNoWriteBarrier(promise, JSPromise::kReactionsOrResultOffset, in PromiseInit() 41 StoreObjectFieldNoWriteBarrier(promise, JSPromise::kFlagsOffset, in PromiseInit() 45 StoreObjectFieldNoWriteBarrier(promise, offset, SmiConstant(Smi::kZero)); in PromiseInit() 94 Node* promise, Node* debug_event, Node* native_context) { in CreatePromiseResolvingFunctions() argument [all …]
|
D | builtins-promise-gen.h | 104 Node* promise, Node* native_context, Node* promise_context); 106 Node* PromiseHasHandler(Node* promise); 120 Node* CreatePromiseResolvingFunctionsContext(Node* promise, Node* debug_event, 127 void PromiseInit(Node* promise); 129 void PromiseSetHasHandler(Node* promise); 130 void PromiseSetHandledHint(Node* promise); 132 void PerformPromiseThen(Node* context, Node* promise, Node* on_fulfilled, 138 Node* TriggerPromiseReactions(Node* context, Node* promise, Node* result, 192 void SetPromiseHandledByIfTrue(Node* context, Node* condition, Node* promise, 195 Node* PromiseStatus(Node* promise); [all …]
|
D | builtins-async-iterator-gen.cc | 28 typedef std::function<void(Node* const context, Node* const promise, 123 Node* const promise = AllocateAndInitJSPromise(context); in Generate_AsyncFromSyncIteratorMethod() local 142 if_method_undefined(native_context, promise, &reject_promise); in Generate_AsyncFromSyncIteratorMethod() 169 on_fulfilled, UndefinedConstant(), promise)); in Generate_AsyncFromSyncIteratorMethod() 174 CallBuiltin(Builtins::kRejectPromise, context, promise, exception, in Generate_AsyncFromSyncIteratorMethod() 176 Return(promise); in Generate_AsyncFromSyncIteratorMethod() 188 Node* const promise = AllocateAndInitJSPromise(context); in Generate_AsyncFromSyncIteratorMethodOptimized() local 207 if_method_undefined(native_context, promise, &reject_promise); in Generate_AsyncFromSyncIteratorMethodOptimized() 237 on_fulfilled, UndefinedConstant(), promise)); in Generate_AsyncFromSyncIteratorMethodOptimized() 242 CallBuiltin(Builtins::kRejectPromise, context, promise, exception, in Generate_AsyncFromSyncIteratorMethodOptimized() [all …]
|
/external/swiftshader/third_party/llvm-7.0/llvm/test/Transforms/Coroutines/ |
D | ex4.ll | 1 ; Fourth example from Doc/Coroutines.rst (coroutine promise) 6 %promise = alloca i32 7 %pv = bitcast i32* %promise to i8* 22 store i32 %n.val, i32* %promise 39 %promise.addr.raw = call i8* @llvm.coro.promise(i8* %hdl, i32 4, i1 false) 40 %promise.addr = bitcast i8* %promise.addr.raw to i32* 41 %val0 = load i32, i32* %promise.addr 44 %val1 = load i32, i32* %promise.addr 47 %val2 = load i32, i32* %promise.addr 57 declare i8* @llvm.coro.promise(i8*, i32, i1)
|
/external/libcxx/test/std/experimental/language.support/support.coroutines/coroutine.handle/coroutine.handle.prom/ |
D | promise.pass.cpp | 51 assert(&h.promise() == this); in do_runtime_test() 52 assert(&h2.promise() == this); in do_runtime_test() 53 assert(&h3.promise() == this); in do_runtime_test() 69 ASSERT_SAME_TYPE(decltype(H.promise()), Promise&); in do_test() 70 LIBCPP_ASSERT_NOT_NOEXCEPT(H.promise()); in do_test() 74 ASSERT_SAME_TYPE(decltype(CH.promise()), Promise&); in do_test() 75 LIBCPP_ASSERT_NOT_NOEXCEPT(CH.promise()); in do_test()
|
/external/libcxx/src/ |
D | future.cpp | 200 promise<void>::promise() in promise() function in promise 205 promise<void>::~promise() in ~promise() 220 promise<void>::get_future() in get_future() 228 promise<void>::set_value() in set_value() 236 promise<void>::set_exception(exception_ptr __p) in set_exception() 244 promise<void>::set_value_at_thread_exit() in set_value_at_thread_exit() 252 promise<void>::set_exception_at_thread_exit(exception_ptr __p) in set_exception_at_thread_exit()
|
/external/perfetto/ui/src/common/ |
D | wasm_engine_proxy.ts | 99 const promise = defer<void>(); constant 100 this.pendingCallbacks.set(id, () => promise.resolve()); 102 return promise; 110 const promise = defer<void>(); constant 111 this.pendingCallbacks.set(id, () => promise.resolve()); 113 return promise;
|
/external/v8/src/ |
D | async-hooks-wrapper.cc | 131 void AsyncHooks::ShellPromiseHook(PromiseHookType type, Local<Promise> promise, in ShellPromiseHook() argument 134 PerIsolateData::Get(promise->GetIsolate())->GetAsyncHooks(); in ShellPromiseHook() 145 promise->SetPrivate(currentContext, in ShellPromiseHook() 154 promise->SetPrivate(currentContext, in ShellPromiseHook() 160 promise->SetPrivate(currentContext, in ShellPromiseHook() 167 promise in ShellPromiseHook() 174 promise in ShellPromiseHook() 186 PromiseHookDispatch(type, promise, parent, wrap, hooks); in ShellPromiseHook() 224 Local<Promise> promise, in PromiseHookDispatch() argument 248 promise->GetPrivate(context, hooks->async_id_smb.Get(hooks->isolate_)) in PromiseHookDispatch() [all …]
|