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); \ struct grpc_call grpc_call
A Call represents an RPC.
Definition: grpc_types.h:70
int64_t grpc_millis
Definition: exec_ctx.h:35
void(* grpc_ioreq_completion_func)(grpc_call *call, int success, void *user_data)
Definition: call.h:32
grpc_call_stack * grpc_call_get_call_stack(grpc_call *call)
grpc_server * server
Definition: call.h:37
void * grpc_call_context_get(grpc_call *call, grpc_context_index elem)
grpc_millis send_deadline
Definition: call.h:51
Definition: error_internal.h:39
struct grpc_server grpc_server
A server listens to some port and responds to request calls.
Definition: grpc_types.h:65
grpc_completion_queue * cq
Definition: call.h:42
void grpc_call_internal_unref(grpc_call *call, const char *reason)
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_core::Arena * grpc_call_get_arena(grpc_call *call)
grpc_call_error
Result of a grpc call.
Definition: grpc_types.h:407
struct grpc_call_create_args grpc_call_create_args
grpc_core::TraceFlag grpc_call_error_trace
grpc_compression_algorithm grpc_call_compression_for_level(grpc_call *call, grpc_compression_level level)
size_t grpc_call_get_initial_size_estimate()
void grpc_call_internal_ref(grpc_call *call, const char *reason)
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
uint32_t propagation_mask
Definition: call.h:40
void grpc_call_log_batch(const char *file, int line, gpr_log_severity severity, const grpc_op *ops, size_t nops)
grpc_call * grpc_call_from_top_element(grpc_call_element *surface_element)
struct grpc_pollset_set grpc_pollset_set
Definition: pollset_set.h:31
grpc_context_index
Call object context pointers.
Definition: context.h:27
grpc_call * parent
Definition: call.h:39
grpc_core::TraceFlag grpc_compression_trace
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
grpc_error * grpc_call_create(const grpc_call_create_args *args, grpc_call **call)
void grpc_call_set_completion_queue(grpc_call *call, grpc_completion_queue *cq)
Definition: channel_stack.h:167
grpc_pollset_set * pollset_set_alternative
Definition: call.h:44
grpc_call_error grpc_call_start_batch_and_execute(grpc_call *call, const grpc_op *ops, size_t nops, grpc_closure *closure)
struct grpc_completion_queue grpc_completion_queue
Completion Queues enable notification of the completion of asynchronous actions.
Definition: grpc_types.h:56
void grpc_call_context_set(grpc_call *call, grpc_context_index elem, void *value, void(*destroy)(void *value))
void grpc_call_cancel_internal(grpc_call *call)
size_t add_initial_metadata_count
Definition: call.h:49
uint8_t grpc_call_is_client(grpc_call *call)