| /external/rust/crates/grpcio-sys/grpc/src/core/lib/surface/ |
| D | call.h | 33 typedef void (*grpc_ioreq_completion_func)(grpc_call* call, int success,
40 grpc_call* parent;
59 grpc_call** call);
61 void grpc_call_set_completion_queue(grpc_call* call, grpc_completion_queue* cq);
64 void grpc_call_internal_ref(grpc_call* call, const char* reason);
65 void grpc_call_internal_unref(grpc_call* call, const char* reason);
71 void grpc_call_internal_ref(grpc_call* call);
72 void grpc_call_internal_unref(grpc_call* call);
77 grpc_core::Arena* grpc_call_get_arena(grpc_call* call);
79 grpc_call_stack* grpc_call_get_call_stack(grpc_call* call);
[all …]
|
| D | call.cc | 85 grpc_call* call = nullptr;
123 grpc_call* first_child = nullptr;
127 explicit child_call(grpc_call* parent) : parent(parent) {} in child_call()
128 grpc_call* parent;
132 grpc_call* sibling_next = nullptr;
133 grpc_call* sibling_prev = nullptr;
139 struct grpc_call { struct
140 grpc_call(grpc_core::Arena* arena, const grpc_call_create_args& args) in grpc_call() argument
153 ~grpc_call() { in ~grpc_call() argument
277 GPR_ROUND_UP_TO_ALIGNMENT_SIZE(sizeof(grpc_call))) argument
[all …]
|
| D | call_test_only.h | 30 grpc_call* call);
35 uint32_t grpc_call_test_only_get_message_flags(grpc_call* call);
41 uint32_t grpc_call_test_only_get_encodings_accepted_by_peer(grpc_call* call);
|
| D | channel.cc | 345 static grpc_call* grpc_channel_create_call_internal( in grpc_channel_create_call_internal()
346 grpc_channel* channel, grpc_call* parent_call, uint32_t propagation_mask, in grpc_channel_create_call_internal()
373 grpc_call* call; in grpc_channel_create_call_internal()
378 grpc_call* grpc_channel_create_call(grpc_channel* channel, in grpc_channel_create_call()
379 grpc_call* parent_call, in grpc_channel_create_call()
387 grpc_call* call = grpc_channel_create_call_internal( in grpc_channel_create_call()
397 grpc_call* grpc_channel_create_pollset_set_call( in grpc_channel_create_pollset_set_call()
398 grpc_channel* channel, grpc_call* parent_call, uint32_t propagation_mask, in grpc_channel_create_pollset_set_call()
472 grpc_call* grpc_channel_create_registered_call( in grpc_channel_create_registered_call()
473 grpc_channel* channel, grpc_call* parent_call, uint32_t propagation_mask, in grpc_channel_create_registered_call()
[all …]
|
| /external/grpc-grpc/src/core/lib/surface/ |
| D | call.h | 31 typedef void (*grpc_ioreq_completion_func)(grpc_call* call, int success,
38 grpc_call* parent;
57 grpc_call** call);
59 void grpc_call_set_completion_queue(grpc_call* call, grpc_completion_queue* cq);
62 void grpc_call_internal_ref(grpc_call* call, const char* reason);
63 void grpc_call_internal_unref(grpc_call* call, const char* reason);
69 void grpc_call_internal_ref(grpc_call* call);
70 void grpc_call_internal_unref(grpc_call* call);
75 gpr_arena* grpc_call_get_arena(grpc_call* call);
77 grpc_call_stack* grpc_call_get_call_stack(grpc_call* call);
[all …]
|
| D | call.cc | 76 grpc_call* call;
105 grpc_call* first_child;
109 grpc_call* parent;
113 grpc_call* sibling_next;
114 grpc_call* sibling_prev;
120 struct grpc_call { struct
236 GPR_ROUND_UP_TO_ALIGNMENT_SIZE(sizeof(grpc_call))) argument
238 (grpc_call*)(((char*)(call_stack)) - \
239 GPR_ROUND_UP_TO_ALIGNMENT_SIZE(sizeof(grpc_call)))
246 static void execute_batch(grpc_call* call, grpc_transport_stream_op_batch* op,
[all …]
|
| D | call_test_only.h | 30 grpc_call* call);
35 uint32_t grpc_call_test_only_get_message_flags(grpc_call* call);
41 uint32_t grpc_call_test_only_get_encodings_accepted_by_peer(grpc_call* call);
|
| D | channel.cc | 295 static grpc_call* grpc_channel_create_call_internal( in grpc_channel_create_call_internal()
296 grpc_channel* channel, grpc_call* parent_call, uint32_t propagation_mask, in grpc_channel_create_call_internal()
323 grpc_call* call; in grpc_channel_create_call_internal()
328 grpc_call* grpc_channel_create_call(grpc_channel* channel, in grpc_channel_create_call()
329 grpc_call* parent_call, in grpc_channel_create_call()
336 grpc_call* call = grpc_channel_create_call_internal( in grpc_channel_create_call()
347 grpc_call* grpc_channel_create_pollset_set_call( in grpc_channel_create_pollset_set_call()
348 grpc_channel* channel, grpc_call* parent_call, uint32_t propagation_mask, in grpc_channel_create_pollset_set_call()
387 grpc_call* grpc_channel_create_registered_call( in grpc_channel_create_registered_call()
388 grpc_channel* channel, grpc_call* parent_call, uint32_t propagation_mask, in grpc_channel_create_registered_call()
[all …]
|
| /external/grpc-grpc/include/grpc/ |
| D | grpc.h | 212 GRPCAPI grpc_call* grpc_channel_create_call(
213 grpc_channel* channel, grpc_call* parent_call, uint32_t propagation_mask,
229 GRPCAPI grpc_call* grpc_channel_create_registered_call(
230 grpc_channel* channel, grpc_call* parent_call, uint32_t propagation_mask,
236 GRPCAPI void* grpc_call_arena_alloc(grpc_call* call, size_t size);
255 GRPCAPI grpc_call_error grpc_call_start_batch(grpc_call* call,
267 GRPCAPI char* grpc_call_get_peer(grpc_call* call);
273 GRPCAPI void grpc_census_call_set_context(grpc_call* call,
277 GRPCAPI struct census_context* grpc_census_call_get_context(grpc_call* call);
323 GRPCAPI grpc_call_error grpc_call_cancel(grpc_call* call, void* reserved);
[all …]
|
| /external/rust/crates/grpcio-sys/grpc/include/grpc/ |
| D | grpc.h | 216 GRPCAPI grpc_call* grpc_channel_create_call(
217 grpc_channel* channel, grpc_call* parent_call, uint32_t propagation_mask,
230 GRPCAPI grpc_call* grpc_channel_create_registered_call(
231 grpc_channel* channel, grpc_call* parent_call, uint32_t propagation_mask,
237 GRPCAPI void* grpc_call_arena_alloc(grpc_call* call, size_t size);
259 GRPCAPI grpc_call_error grpc_call_start_batch(grpc_call* call,
271 GRPCAPI char* grpc_call_get_peer(grpc_call* call);
277 GRPCAPI void grpc_census_call_set_context(grpc_call* call,
281 GRPCAPI struct census_context* grpc_census_call_get_context(grpc_call* call);
327 GRPCAPI grpc_call_error grpc_call_cancel(grpc_call* call, void* reserved);
[all …]
|
| /external/rust/crates/grpcio-sys/grpc/spm-core-include/grpc/ |
| D | grpc.h | 216 GRPCAPI grpc_call* grpc_channel_create_call(
217 grpc_channel* channel, grpc_call* parent_call, uint32_t propagation_mask,
230 GRPCAPI grpc_call* grpc_channel_create_registered_call(
231 grpc_channel* channel, grpc_call* parent_call, uint32_t propagation_mask,
237 GRPCAPI void* grpc_call_arena_alloc(grpc_call* call, size_t size);
259 GRPCAPI grpc_call_error grpc_call_start_batch(grpc_call* call,
271 GRPCAPI char* grpc_call_get_peer(grpc_call* call);
277 GRPCAPI void grpc_census_call_set_context(grpc_call* call,
281 GRPCAPI struct census_context* grpc_census_call_get_context(grpc_call* call);
327 GRPCAPI grpc_call_error grpc_call_cancel(grpc_call* call, void* reserved);
[all …]
|
| /external/rust/crates/grpcio-sys/grpc/spm-cpp-include/grpcpp/impl/codegen/ |
| D | call.h | 43 Call(grpc_call* call, CallHook* call_hook, ::grpc::CompletionQueue* cq) in Call()
49 Call(grpc_call* call, CallHook* call_hook, ::grpc::CompletionQueue* cq, in Call()
57 Call(grpc_call* call, CallHook* call_hook, ::grpc::CompletionQueue* cq, in Call()
69 grpc_call* call() const { return call_; } in call()
85 grpc_call* call_;
|
| D | callback_common.h | 84 CallbackWithStatusTag(grpc_call* call, std::function<void(Status)> f, in CallbackWithStatusTag()
106 grpc_call* call_;
165 void Set(grpc_call* call, std::function<void(bool)> f, in Set()
178 grpc_call* call = call_; in Clear()
197 grpc_call* call_;
|
| D | core_codegen_interface.h | 107 virtual grpc_call_error grpc_call_start_batch(grpc_call* call,
110 virtual grpc_call_error grpc_call_cancel_with_status(grpc_call* call,
114 virtual void grpc_call_ref(grpc_call* call) = 0;
115 virtual void grpc_call_unref(grpc_call* call) = 0;
116 virtual void* grpc_call_arena_alloc(grpc_call* call, size_t length) = 0;
|
| D | core_codegen.h | 66 grpc_call_error grpc_call_start_batch(grpc_call* call, const grpc_op* ops,
69 grpc_call_error grpc_call_cancel_with_status(grpc_call* call,
73 void grpc_call_ref(grpc_call* call) override;
74 void grpc_call_unref(grpc_call* call) override;
75 void* grpc_call_arena_alloc(grpc_call* call, size_t length) override;
|
| /external/rust/crates/grpcio-sys/grpc/include/grpcpp/impl/codegen/ |
| D | call.h | 43 Call(grpc_call* call, CallHook* call_hook, ::grpc::CompletionQueue* cq) in Call()
49 Call(grpc_call* call, CallHook* call_hook, ::grpc::CompletionQueue* cq, in Call()
57 Call(grpc_call* call, CallHook* call_hook, ::grpc::CompletionQueue* cq, in Call()
69 grpc_call* call() const { return call_; } in call()
85 grpc_call* call_;
|
| D | callback_common.h | 84 CallbackWithStatusTag(grpc_call* call, std::function<void(Status)> f, in CallbackWithStatusTag()
106 grpc_call* call_;
165 void Set(grpc_call* call, std::function<void(bool)> f, in Set()
178 grpc_call* call = call_; in Clear()
197 grpc_call* call_;
|
| D | core_codegen.h | 66 grpc_call_error grpc_call_start_batch(grpc_call* call, const grpc_op* ops,
69 grpc_call_error grpc_call_cancel_with_status(grpc_call* call,
73 void grpc_call_ref(grpc_call* call) override;
74 void grpc_call_unref(grpc_call* call) override;
75 void* grpc_call_arena_alloc(grpc_call* call, size_t length) override;
|
| D | core_codegen_interface.h | 107 virtual grpc_call_error grpc_call_start_batch(grpc_call* call,
110 virtual grpc_call_error grpc_call_cancel_with_status(grpc_call* call,
114 virtual void grpc_call_ref(grpc_call* call) = 0;
115 virtual void grpc_call_unref(grpc_call* call) = 0;
116 virtual void* grpc_call_arena_alloc(grpc_call* call, size_t length) = 0;
|
| /external/grpc-grpc/src/csharp/ext/ |
| D | grpc_csharp_ext.c | 78 grpc_call* call;
310 GPR_EXPORT grpc_call* GPR_CALLTYPE
397 GPR_EXPORT grpc_call* GPR_CALLTYPE grpcsharp_channel_create_call( in grpcsharp_channel_create_call()
398 grpc_channel* channel, grpc_call* parent_call, uint32_t propagation_mask, in grpcsharp_channel_create_call()
408 grpc_call* ret = in grpcsharp_channel_create_call()
511 GPR_EXPORT grpc_call_error GPR_CALLTYPE grpcsharp_call_cancel(grpc_call* call) { in grpcsharp_call_cancel()
516 grpc_call* call, grpc_status_code status, const char* description) { in grpcsharp_call_cancel_with_status()
520 GPR_EXPORT char* GPR_CALLTYPE grpcsharp_call_get_peer(grpc_call* call) { in grpcsharp_call_get_peer()
526 GPR_EXPORT void GPR_CALLTYPE grpcsharp_call_destroy(grpc_call* call) { in grpcsharp_call_destroy()
530 typedef grpc_call_error (*grpcsharp_call_start_batch_func)(grpc_call* call,
[all …]
|
| /external/rust/crates/grpcio-sys/ |
| D | grpc_wrap.cc | 103 grpc_call* call;
340 GPR_EXPORT grpc_call* GPR_CALLTYPE
342 grpc_call* call = ctx->call; in grpcwrap_request_call_context_ref_call()
347 GPR_EXPORT grpc_call* GPR_CALLTYPE
383 GPR_EXPORT grpc_call* GPR_CALLTYPE grpcwrap_channel_create_call( in grpcwrap_channel_create_call()
384 grpc_channel* channel, grpc_call* parent_call, uint32_t propagation_mask, in grpcwrap_channel_create_call()
397 grpc_call* ret = in grpcwrap_channel_create_call()
471 grpc_call* call, grpcwrap_batch_context* ctx, grpc_slice* send_buffer, in grpcwrap_call_start_unary()
521 grpc_call* call, grpcwrap_batch_context* ctx, in grpcwrap_call_start_client_streaming()
561 grpc_call* call, grpcwrap_batch_context* ctx, grpc_slice* send_buffer, in grpcwrap_call_start_server_streaming()
[all …]
|
| /external/grpc-grpc/include/grpcpp/impl/codegen/ |
| D | callback_common.h | 67 CallbackWithStatusTag(grpc_call* call, std::function<void(Status)> f, in CallbackWithStatusTag()
85 grpc_call* call_;
124 CallbackWithSuccessTag(grpc_call* call, std::function<void(bool)> f, in CallbackWithSuccessTag()
139 grpc_call* call_;
|
| D | client_context.h | 55 struct grpc_call;
360 grpc_call* c_call() { return call_; } in c_call()
402 grpc_call* call() const { return call_; } in call()
403 void set_call(grpc_call* call, const std::shared_ptr<Channel>& channel);
424 grpc_call* call_;
435 grpc_call* propagate_from_call_;
|
| D | core_codegen_interface.h | 103 virtual grpc_call_error grpc_call_cancel_with_status(grpc_call* call,
107 virtual void grpc_call_ref(grpc_call* call) = 0;
108 virtual void grpc_call_unref(grpc_call* call) = 0;
109 virtual void* grpc_call_arena_alloc(grpc_call* call, size_t length) = 0;
|
| D | core_codegen.h | 66 grpc_call_error grpc_call_cancel_with_status(grpc_call* call,
70 void grpc_call_ref(grpc_call* call) override;
71 void grpc_call_unref(grpc_call* call) override;
72 virtual void* grpc_call_arena_alloc(grpc_call* call, size_t length) override;
|