| /third_party/grpc/src/python/grpcio/grpc/_cython/_cygrpc/ |
| D | event.pyx.pxi | 19 self, grpc_completion_type completion_type, bint success, object tag): argument
20 self.completion_type = completion_type
28 self, grpc_completion_type completion_type, bint success, object tag, argument
30 self.completion_type = completion_type
41 self, grpc_completion_type completion_type, bint success, object tag, argument
43 self.completion_type = completion_type
52 self, grpc_completion_type completion_type, bint success, object tag): argument
53 self.completion_type = completion_type
|
| D | event.pxd.pxi | 18 cdef readonly grpc_completion_type completion_type
25 cdef readonly grpc_completion_type completion_type
35 cdef readonly grpc_completion_type completion_type
43 cdef readonly grpc_completion_type completion_type
|
| D | completion_queue.pyx.pxi | 85 if event.completion_type == GRPC_QUEUE_SHUTDOWN:
|
| D | channel.pyx.pxi | 415 if event.completion_type == CompletionType.queue_timeout:
|
| /third_party/grpc/src/python/grpcio_tests/tests/unit/_cython/ |
| D | _no_messages_server_completion_queue_per_call_test.py | 106 server_request_call_event.completion_type,
110 client_receive_initial_metadata_event.completion_type,
113 client_complete_rpc_event.completion_type,
117 server_send_initial_metadata_event.completion_type,
120 server_complete_rpc_event.completion_type,
|
| D | _no_messages_single_server_completion_queue_test.py | 100 server_request_call_event.completion_type,
104 client_receive_initial_metadata_event.completion_type,
107 client_complete_rpc_event.completion_type,
111 server_send_initial_metadata_event.completion_type,
114 server_complete_rpc_event.completion_type,
|
| D | cygrpc_test.py | 86 event.completion_type)
150 event.completion_type)
216 request_event.completion_type)
|
| D | _read_some_but_not_all_responses_test.py | 235 server_rpc_event.completion_type)
|
| /third_party/grpc/src/core/lib/surface/ |
| D | completion_queue.h | 94 grpc_cq_completion_type completion_type, grpc_cq_polling_type polling_type,
|
| D | completion_queue.cc | 515 grpc_cq_completion_type completion_type, grpc_cq_polling_type polling_type, in grpc_completion_queue_create_internal() argument
524 2, (completion_type, polling_type)); in grpc_completion_queue_create_internal()
526 const cq_vtable* vtable = &g_cq_vtable[completion_type]; in grpc_completion_queue_create_internal()
|
| /third_party/grpc/include/grpcpp/impl/codegen/ |
| D | completion_queue_impl.h | 439 ServerCompletionQueue(grpc_cq_completion_type completion_type, in ServerCompletionQueue() argument
443 GRPC_CQ_CURRENT_VERSION, completion_type, polling_type, in ServerCompletionQueue()
|
| D | completion_queue.h | 441 ServerCompletionQueue(grpc_cq_completion_type completion_type, in ServerCompletionQueue() argument
445 GRPC_CQ_CURRENT_VERSION, completion_type, polling_type, in ServerCompletionQueue()
|
| /third_party/grpc/src/python/grpcio/grpc/ |
| D | _server.py | 874 if event.completion_type != cygrpc.CompletionType.queue_timeout:
|
| D | _channel.py | 1236 if event.completion_type == cygrpc.CompletionType.queue_timeout:
|
| /third_party/quickjs/ |
| D | quickjs.c | 19353 int completion_type; /* GEN_MAGIC_x */ member
19573 if (next->completion_type == GEN_MAGIC_NEXT) { in js_async_generator_resume_next()
19580 if (next->completion_type == GEN_MAGIC_NEXT) { in js_async_generator_resume_next()
19582 } else if (next->completion_type == GEN_MAGIC_RETURN) { in js_async_generator_resume_next()
19593 if (next->completion_type == GEN_MAGIC_THROW && in js_async_generator_resume_next()
19602 JS_NewInt32(ctx, next->completion_type); in js_async_generator_resume_next()
19717 req->completion_type = magic; in js_async_generator_next()
|