19 #ifndef GRPC_CORE_LIB_SURFACE_CALL_H 20 #define GRPC_CORE_LIB_SURFACE_CALL_H 65 #define GRPC_CALL_INTERNAL_REF(call, reason) \ 66 grpc_call_internal_ref(call, reason) 67 #define GRPC_CALL_INTERNAL_UNREF(call, reason) \ 68 grpc_call_internal_unref(call, reason) 72 #define GRPC_CALL_INTERNAL_REF(call, reason) grpc_call_internal_ref(call) 73 #define GRPC_CALL_INTERNAL_UNREF(call, reason) grpc_call_internal_unref(call) 93 const grpc_op* ops,
size_t nops);
99 void* value,
void (*destroy)(
void* value));
103 #define GRPC_CALL_LOG_BATCH(sev, ops, nops) \ 105 if (GRPC_TRACE_FLAG_ENABLED(grpc_api_trace)) { \ 106 grpc_call_log_batch(sev, ops, nops); \ uint8_t grpc_call_is_client(grpc_call *call)
Definition: call.cc:2000
int64_t grpc_millis
Definition: exec_ctx.h:35
grpc_server * server
Definition: call.h:37
grpc_millis send_deadline
Definition: call.h:51
Definition: error_internal.h:39
void grpc_call_log_batch(const char *file, int line, gpr_log_severity severity, const grpc_op *ops, size_t nops)
Definition: call_log_batch.cc:110
grpc_completion_queue * cq
Definition: call.h:42
void * grpc_call_context_get(grpc_call *call, grpc_context_index elem)
Definition: call.cc:1996
grpc_core::TraceFlag grpc_call_error_trace
grpc_channel * channel
Definition: call.h:36
grpc_compression_level
Compression levels allow a party with knowledge of its peer's accepted encodings to request compressi...
Definition: compression_types.h:71
grpc_call_error
Result of a grpc call.
Definition: grpc_types.h:407
grpc_core::Arena * grpc_call_get_arena(grpc_call *call)
Definition: call.cc:1087
size_t grpc_call_get_initial_size_estimate()
Definition: call.cc:320
grpc_call_stack * grpc_call_get_call_stack(grpc_call *call)
Definition: call.cc:1089
grpc_compression_algorithm
The various compression algorithms supported by gRPC (not sorted by compression level) ...
Definition: compression_types.h:57
grpc_mdelem * add_initial_metadata
Definition: call.h:48
Definition: metadata.h:98
Operation data: one field for each op type (except SEND_CLOSE_FROM_CLIENT which has no arguments) ...
Definition: grpc_types.h:590
grpc_core::TraceFlag grpc_compression_trace
grpc_compression_algorithm grpc_call_compression_for_level(grpc_call *call, grpc_compression_level level)
Definition: call.cc:2002
uint32_t propagation_mask
Definition: call.h:40
Definition: completion_queue.cc:321
void grpc_call_set_completion_queue(grpc_call *call, grpc_completion_queue *cq)
Definition: call.cc:485
struct grpc_pollset_set grpc_pollset_set
Definition: pollset_set.h:31
void(* grpc_ioreq_completion_func)(grpc_call *call, int success, void *user_data)
Definition: call.h:32
grpc_context_index
Call object context pointers.
Definition: context.h:27
grpc_call * parent
Definition: call.h:39
grpc_error * grpc_call_create(const grpc_call_create_args *args, grpc_call **call)
Definition: call.cc:325
void grpc_call_context_set(grpc_call *call, grpc_context_index elem, void *value, void(*destroy)(void *value))
Definition: call.cc:1987
gpr_log_severity
GPR log API.
Definition: log.h:43
A closure over a grpc_iomgr_cb_func.
Definition: closure.h:56
Definition: channel_stack.h:185
const void * server_transport_data
Definition: call.h:46
void grpc_call_internal_unref(grpc_call *call, const char *reason)
Definition: call.cc:510
grpc_call * grpc_call_from_top_element(grpc_call_element *surface_element)
Definition: call.cc:650
Definition: channel_stack.h:167
grpc_call_error grpc_call_start_batch_and_execute(grpc_call *call, const grpc_op *ops, size_t nops, grpc_closure *closure)
Definition: call.cc:1980
void grpc_call_cancel_internal(grpc_call *call)
Definition: call.cc:711
void grpc_call_internal_ref(grpc_call *call, const char *reason)
Definition: call.cc:507
grpc_pollset_set * pollset_set_alternative
Definition: call.h:44
struct grpc_call_create_args grpc_call_create_args
size_t add_initial_metadata_count
Definition: call.h:49
grpc_call_element * elem
Definition: client_channel.cc:112
Definition: server.cc:222