| /external/grpc-grpc-java/netty/src/main/java/io/grpc/netty/ |
| D | WriteQueue.java | 81 ChannelPromise promise = channel.newPromise(); in enqueue() local
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() argument
168 public final ChannelPromise promise() { in promise() method in WriteQueue.AbstractQueuedCommand
185 ChannelPromise promise(); in promise() method
190 void promise(ChannelPromise promise); in promise() argument
|
| D | SendGrpcFrameCommand.java | 32 private ChannelPromise promise; field in SendGrpcFrameCommand
110 public ChannelPromise promise() { in promise() method in SendGrpcFrameCommand
115 public void promise(ChannelPromise promise) { in promise() method in SendGrpcFrameCommand
|
| D | NettyClientHandler.java | 297 public void write(ChannelHandlerContext ctx, Object msg, ChannelPromise promise) in write()
300 createStream((CreateStreamCommand) msg, promise); in write() local
383 public void close(ChannelHandlerContext ctx, ChannelPromise promise) throws Exception { in close()
485 private void createStream(CreateStreamCommand command, final ChannelPromise promise) in createStream()
562 ChannelPromise promise) { in cancelStream()
575 ChannelPromise promise) { in sendGrpcFrame()
586 ChannelPromise promise) { in sendPingFrame()
640 ChannelPromise promise) throws Exception { in gracefulClose()
649 ChannelPromise promise) throws Exception { in forcefulClose()
|
| D | NettyServerHandler.java | 570 public void write(ChannelHandlerContext ctx, Object msg, ChannelPromise promise) in write()
600 private void closeStreamWhenDone(ChannelPromise promise, int streamId) throws Http2Exception { in closeStreamWhenDone()
614 ChannelPromise promise) throws Http2Exception { in sendGrpcFrame()
626 ChannelPromise promise) throws Http2Exception { in sendResponseHeaders()
642 ChannelPromise promise) { in cancelStream()
650 ChannelPromise promise) throws Exception { in forcefulClose()
931 int padding, boolean endStream, ChannelPromise promise) { in writeData()
938 int padding, boolean endStream, ChannelPromise promise) { in writeHeaders()
946 ChannelPromise promise) { in writeHeaders()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/js/test/ |
| D | PromiseTest.kt | 13 val promise = Promise<String> { resolve, _ -> in <lambda>() constant
23 val promise = Promise<String> { _, reject -> in <lambda>() constant
44 val promise = deferred.asPromise() in <lambda>() constant
54 val promise = deferred.asPromise() in <lambda>() constant
72 val promise = deferred.asPromise() in <lambda>() constant
|
| /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()
112 public void bind(ChannelHandlerContext ctx, SocketAddress localAddress, ChannelPromise promise) { in bind()
121 ChannelPromise promise) { in connect()
126 public void disconnect(ChannelHandlerContext ctx, ChannelPromise promise) { in disconnect()
131 public void close(ChannelHandlerContext ctx, ChannelPromise promise) { in close()
136 public void deregister(ChannelHandlerContext ctx, ChannelPromise promise) { in deregister()
|
| D | ProtectedPromise.java | 53 void addUnprotectedPromise(ChannelPromise promise) { in addUnprotectedPromise()
|
| /external/kotlinx.coroutines/kotlinx-coroutines-core/js/src/ |
| D | Promise.kt | 25 public fun <T> CoroutineScope.promise( in <lambda>() method
36 val promise = Promise<T> { resolve, reject -> in <lambda>() constant
|
| /external/v8/src/builtins/ |
| D | builtins-async-function-gen.cc | 47 TNode<JSPromise> promise = LoadObjectField<JSPromise>( in AsyncFunctionAwaitResumeClosure() local
117 TNode<JSPromise> promise = UncheckedCast<JSPromise>( in TF_BUILTIN() local
183 TNode<JSPromise> promise = LoadObjectField<JSPromise>( in TF_BUILTIN() local
208 TNode<JSPromise> promise = LoadObjectField<JSPromise>( in TF_BUILTIN() local
227 auto promise = Parameter<JSPromise>(Descriptor::kPromise); in TF_BUILTIN() local
|
| D | builtins-promise-gen.cc | 24 TNode<JSPromise> promise) { in ZeroOutEmbedderOffsets()
|
| D | builtins-async-iterator-gen.cc | 111 const TNode<JSPromise> promise = NewJSPromise(context); in Generate_AsyncFromSyncIteratorMethod() local
308 Label* if_exception) { in TF_BUILTIN()
340 Label* if_exception) { Goto(if_exception); }; in TF_BUILTIN()
|
| D | builtins-async-generator-gen.cc | 151 TNode<JSPromise> promise = NewJSPromise(context); in AsyncGeneratorEnqueue() local
196 TNode<JSPromise> promise) { in AllocateAsyncGeneratorRequest()
494 const TNode<JSPromise> promise = LoadPromiseFromAsyncGeneratorRequest(next); in TF_BUILTIN() local
556 TNode<JSPromise> promise = LoadPromiseFromAsyncGeneratorRequest(next); in TF_BUILTIN() local
|
| D | builtins-async-gen.cc | 76 TNode<JSPromise> promise; in AwaitOld() local
124 TNode<JSPromise> promise, TNode<JSPromise> outer_promise, in AwaitOptimized()
|
| /external/v8/src/runtime/ |
| D | runtime-promise.cc | 137 Handle<JSPromise> promise, in AwaitPromisesInitCommon()
218 Handle<JSPromise> promise = Handle<JSPromise>::cast(maybe_promise); in RUNTIME_FUNCTION() local
231 Handle<JSPromise> promise = Handle<JSPromise>::cast(maybe_promise); in RUNTIME_FUNCTION() local
|
| /external/v8/src/d8/ |
| D | async-hooks-wrapper.cc | 123 void AsyncHooks::ShellPromiseHook(PromiseHookType type, Local<Promise> promise, in ShellPromiseHook()
217 Local<Promise> promise, in PromiseHookDispatch()
|
| /external/grpc-grpc-java/netty/src/test/java/io/grpc/netty/ |
| D | WriteQueueTest.java | 59 public ChannelPromise promise; field in WriteQueueTest
|
| D | NettyStreamTestBase.java | 76 protected ChannelPromise promise; field in NettyStreamTestBase
|
| /external/libcxx/src/ |
| D | future.cpp | 200 promise<void>::promise() in promise() function in promise
|
| /external/swiftshader/src/Reactor/ |
| D | LLVMReactor.hpp | 109 llvm::Value *promise = nullptr; member
|
| /external/v8/src/execution/ |
| D | isolate.cc | 899 void CaptureAsyncStackTrace(Isolate* isolate, Handle<JSPromise> promise, in CaptureAsyncStackTrace()
1123 Handle<JSPromise> promise(async_function_object->promise(), in CaptureStackTrace() local
1133 Handle<JSPromise> promise( in CaptureStackTrace() local
1147 Handle<JSPromise> promise = in CaptureStackTrace() local
2426 void Isolate::PushPromise(Handle<JSObject> promise) { in ThrowInternal()
2458 Handle<JSPromise> promise) { in ThrowInternal()
2470 Handle<JSPromise> promise = in ThrowInternal() local
2486 bool Isolate::PromiseHasUserDefinedRejectHandler(Handle<JSPromise> promise) { in ThrowInternal()
4135 v8::Local<v8::Promise> promise = resolver->GetPromise(); in ThrowInternal() local
4162 v8::Local<v8::Promise> promise; in ThrowInternal() local
[all …]
|
| D | futex-emulation.cc | 501 Handle<JSObject> promise, Isolate* isolate) in FutexWaitListNode()
716 Handle<JSPromise> promise = Handle<JSPromise>::cast( in CleanupAsyncWaiterPromise() local
760 Handle<JSPromise> promise = Handle<JSPromise>::cast( in ResolveAsyncWaiterPromise() local
|
| /external/v8/src/heap/ |
| D | memory-measurement.cc | 116 Handle<JSPromise> promise, in MeasureMemoryDelegate()
334 Isolate* isolate, Handle<NativeContext> context, Handle<JSPromise> promise, in DefaultDelegate()
|
| D | heap-write-barrier-inl.h | 174 HeapObject object, const DisallowHeapAllocation* promise) { in GetWriteBarrierModeForObject()
|
| /external/okhttp/mockwebserver/src/main/java/com/squareup/okhttp/mockwebserver/ |
| D | MockResponse.java | 236 public MockResponse withPush(PushPromise promise) { in withPush()
|
| /external/v8/src/wasm/ |
| D | wasm-js.cc | 249 AsyncCompilationResolver(i::Isolate* isolate, i::Handle<i::JSPromise> promise) in AsyncCompilationResolver()
292 i::Handle<i::JSPromise> promise) in InstantiateModuleResultResolver()
332 i::Handle<i::JSPromise> promise, in InstantiateBytesResultResolver()
396 i::Isolate* isolate, i::Handle<i::JSPromise> promise, in AsyncInstantiateCompileResultResolver()
506 Local<Promise> promise = promise_resolver->GetPromise(); in WebAssemblyCompile() local
569 Local<Promise> promise = result_resolver->GetPromise(); in WebAssemblyCompileStreaming() local
831 Local<Promise> promise = result_resolver->GetPromise(); in WebAssemblyInstantiateStreaming() local
916 Local<Promise> promise = promise_resolver->GetPromise(); in WebAssemblyInstantiate() local
|