| /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 …]
|
| D | channel.h | 46 grpc_call* grpc_channel_create_pollset_set_call(
47 grpc_channel* channel, grpc_call* parent_call, uint32_t propagation_mask,
|
| /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/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/grpc-grpc/include/grpcpp/impl/codegen/ |
| 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 | 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 | 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;
|
| D | server_context.h | 38 struct grpc_call;
239 grpc_call* c_call() { return call_; } in c_call()
284 void set_call(grpc_call* call) { call_ = call; } in set_call()
293 grpc_call* call_;
|
| D | call.h | 601 virtual void FillOps(grpc_call* call, grpc_op* ops, size_t* nops) = 0;
627 void FillOps(grpc_call* call, grpc_op* ops, size_t* nops) override { in FillOps()
664 grpc_call* call_;
671 Call(grpc_call* call, CallHook* call_hook, CompletionQueue* cq) in Call()
677 Call(grpc_call* call, CallHook* call_hook, CompletionQueue* cq, in Call()
688 grpc_call* call() const { return call_; } in call()
696 grpc_call* call_;
|
| /external/grpc-grpc/src/ruby/ext/grpc/ |
| D | rb_grpc_imports.generated.h | 146 typedef grpc_call*(*grpc_channel_create_call_type)(grpc_channel* channel, grpc_call* parent_call, u…
155 typedef grpc_call*(*grpc_channel_create_registered_call_type)(grpc_channel* channel, grpc_call* par…
158 typedef void*(*grpc_call_arena_alloc_type)(grpc_call* call, size_t size);
161 typedef grpc_call_error(*grpc_call_start_batch_type)(grpc_call* call, const grpc_op* ops, size_t no…
164 typedef char*(*grpc_call_get_peer_type)(grpc_call* call);
167 typedef void(*grpc_census_call_set_context_type)(grpc_call* call, struct census_context* context);
170 typedef struct census_context*(*grpc_census_call_get_context_type)(grpc_call* call);
191 typedef grpc_call_error(*grpc_call_cancel_type)(grpc_call* call, void* reserved);
194 typedef grpc_call_error(*grpc_call_cancel_with_status_type)(grpc_call* call, grpc_status_code statu…
197 typedef void(*grpc_call_ref_type)(grpc_call* call);
[all …]
|
| D | rb_call.h | 27 grpc_call* grpc_rb_get_wrapped_call(VALUE v);
30 VALUE grpc_rb_wrap_call(grpc_call* c, grpc_completion_queue* q);
|
| /external/grpc-grpc/src/core/ext/filters/census/ |
| D | grpc_context.cc | 26 void grpc_census_call_set_context(grpc_call* call, census_context* context) { in grpc_census_call_set_context()
34 census_context* grpc_census_call_get_context(grpc_call* call) { in grpc_census_call_get_context()
|
| /external/grpc-grpc/test/core/end2end/tests/ |
| D | cancel_test_helpers.h | 24 grpc_call_error (*initiate_cancel)(grpc_call* call, void* reserved);
29 static grpc_call_error wait_for_deadline(grpc_call* call, void* reserved) { in wait_for_deadline()
|
| D | resource_quota_server.cc | 134 grpc_call** client_calls = in resource_quota_server()
135 static_cast<grpc_call**>(malloc(sizeof(grpc_call*) * NUM_CALLS)); in resource_quota_server()
136 grpc_call** server_calls = in resource_quota_server()
137 static_cast<grpc_call**>(malloc(sizeof(grpc_call*) * NUM_CALLS)); in resource_quota_server()
|
| D | max_concurrent_streams.cc | 88 grpc_call* c; in simple_request_body()
89 grpc_call* s; in simple_request_body()
196 grpc_call* c1; in test_max_concurrent_streams()
197 grpc_call* c2; in test_max_concurrent_streams()
198 grpc_call* s1; in test_max_concurrent_streams()
199 grpc_call* s2; in test_max_concurrent_streams()
443 grpc_call* c1; in test_max_concurrent_streams_with_timeout_on_first()
444 grpc_call* c2; in test_max_concurrent_streams_with_timeout_on_first()
445 grpc_call* s1; in test_max_concurrent_streams_with_timeout_on_first()
446 grpc_call* s2; in test_max_concurrent_streams_with_timeout_on_first()
[all …]
|
| /external/grpc-grpc/src/php/ext/grpc/ |
| D | call.h | 32 grpc_call *wrapped;
47 zval *grpc_php_wrap_call(grpc_call *wrapped, bool owned TSRMLS_DC);
|
| /external/grpc-grpc/src/cpp/common/ |
| D | core_codegen.cc | 106 grpc_call* call, grpc_status_code status, const char* description, in grpc_call_cancel_with_status()
110 void CoreCodegen::grpc_call_ref(grpc_call* call) { ::grpc_call_ref(call); } in grpc_call_ref()
111 void CoreCodegen::grpc_call_unref(grpc_call* call) { ::grpc_call_unref(call); } in grpc_call_unref()
112 void* CoreCodegen::grpc_call_arena_alloc(grpc_call* call, size_t length) { in grpc_call_arena_alloc()
|
| /external/grpc-grpc/test/core/util/ |
| D | debugger_macros.cc | 34 grpc_stream* grpc_transport_stream_from_call(grpc_call* call) { in grpc_transport_stream_from_call()
56 grpc_chttp2_stream* grpc_chttp2_stream_from_call(grpc_call* call) { in grpc_chttp2_stream_from_call()
|
| /external/grpc-grpc/src/python/grpcio/grpc/_cython/_cygrpc/ |
| D | grpc.pxi | 157 ctypedef struct grpc_call:
347 grpc_call *call, const grpc_op *ops, size_t nops, void *tag,
349 grpc_call_error grpc_call_cancel(grpc_call *call, void *reserved) nogil
350 grpc_call_error grpc_call_cancel_with_status(grpc_call *call,
354 char *grpc_call_get_peer(grpc_call *call) nogil
355 void grpc_call_unref(grpc_call *call) nogil
360 grpc_call *grpc_channel_create_call(
361 grpc_channel *channel, grpc_call *parent_call, uint32_t propagation_mask,
375 grpc_server *server, grpc_call **call, grpc_call_details *details,
510 grpc_call_error grpc_call_set_credentials(grpc_call *call,
[all …]
|
| /external/grpc-grpc/test/core/tsi/alts/handshaker/ |
| D | alts_handshaker_client_test.cc | 153 static grpc_call_error check_must_not_be_called(grpc_call* call, in check_must_not_be_called()
165 static grpc_call_error check_client_start_success(grpc_call* call, in check_client_start_success()
208 static grpc_call_error check_server_start_success(grpc_call* call, in check_server_start_success()
244 static grpc_call_error check_next_success(grpc_call* call, const grpc_op* op, in check_next_success()
263 static grpc_call_error check_grpc_call_failure(grpc_call* call, in check_grpc_call_failure()
|
| /external/grpc-grpc/src/objective-c/GRPCClient/private/ |
| D | GRPCHost.h | 26 struct grpc_call;
66 - (nullable struct grpc_call *)unmanagedCallWithPath:(NSString *)path
|