diff options
author | 2015-09-22 10:42:19 -0700 | |
---|---|---|
committer | 2015-09-22 10:42:19 -0700 | |
commit | 45724b35e411fef7c5da66a74c78428c11d56843 (patch) | |
tree | 9264034aca675c89444e02f72ef58e67d7043604 /src/core/surface/call.h | |
parent | 298751c1195523ef6228595043b583c3a6270e08 (diff) |
indent pass to get logical source lines on one physical line
Diffstat (limited to 'src/core/surface/call.h')
-rw-r--r-- | src/core/surface/call.h | 171 |
1 files changed, 77 insertions, 94 deletions
diff --git a/src/core/surface/call.h b/src/core/surface/call.h index 4476ab915b..a859fbf218 100644 --- a/src/core/surface/call.h +++ b/src/core/surface/call.h @@ -39,120 +39,104 @@ #include <grpc/grpc.h> #ifdef __cplusplus -extern "C" { +extern "C" +{ #endif /* Primitive operation types - grpc_op's get rewritten into these */ -typedef enum { - GRPC_IOREQ_RECV_INITIAL_METADATA, - GRPC_IOREQ_RECV_MESSAGE, - GRPC_IOREQ_RECV_TRAILING_METADATA, - GRPC_IOREQ_RECV_STATUS, - GRPC_IOREQ_RECV_STATUS_DETAILS, - GRPC_IOREQ_RECV_CLOSE, - GRPC_IOREQ_SEND_INITIAL_METADATA, - GRPC_IOREQ_SEND_MESSAGE, - GRPC_IOREQ_SEND_TRAILING_METADATA, - GRPC_IOREQ_SEND_STATUS, - GRPC_IOREQ_SEND_CLOSE, - GRPC_IOREQ_OP_COUNT -} grpc_ioreq_op; - -typedef union { - grpc_metadata_array *recv_metadata; - grpc_byte_buffer **recv_message; - struct { - void (*set_value)(grpc_status_code status, void *user_data); - void *user_data; - } recv_status; - struct { - char **details; - size_t *details_capacity; - } recv_status_details; - struct { - size_t count; - grpc_metadata *metadata; - } send_metadata; - grpc_byte_buffer *send_message; - struct { - grpc_status_code code; - grpc_mdstr *details; - } send_status; -} grpc_ioreq_data; - -typedef struct { - grpc_ioreq_op op; - gpr_uint32 flags; /**< A copy of the write flags from grpc_op */ - grpc_ioreq_data data; -} grpc_ioreq; - -typedef void (*grpc_ioreq_completion_func)(grpc_call *call, int success, - void *user_data, - grpc_closure_list *closure_list); - -grpc_call *grpc_call_create(grpc_channel *channel, grpc_call *parent_call, - gpr_uint32 propagation_mask, - grpc_completion_queue *cq, - const void *server_transport_data, - grpc_mdelem **add_initial_metadata, - size_t add_initial_metadata_count, - gpr_timespec send_deadline); - -void grpc_call_set_completion_queue(grpc_call *call, grpc_completion_queue *cq, - grpc_closure_list *closure_list); -grpc_completion_queue *grpc_call_get_completion_queue(grpc_call *call); + typedef enum + { + GRPC_IOREQ_RECV_INITIAL_METADATA, + GRPC_IOREQ_RECV_MESSAGE, + GRPC_IOREQ_RECV_TRAILING_METADATA, + GRPC_IOREQ_RECV_STATUS, + GRPC_IOREQ_RECV_STATUS_DETAILS, + GRPC_IOREQ_RECV_CLOSE, + GRPC_IOREQ_SEND_INITIAL_METADATA, + GRPC_IOREQ_SEND_MESSAGE, + GRPC_IOREQ_SEND_TRAILING_METADATA, + GRPC_IOREQ_SEND_STATUS, + GRPC_IOREQ_SEND_CLOSE, + GRPC_IOREQ_OP_COUNT + } grpc_ioreq_op; + + typedef union + { + grpc_metadata_array *recv_metadata; + grpc_byte_buffer **recv_message; + struct + { + void (*set_value) (grpc_status_code status, void *user_data); + void *user_data; + } recv_status; + struct + { + char **details; + size_t *details_capacity; + } recv_status_details; + struct + { + size_t count; + grpc_metadata *metadata; + } send_metadata; + grpc_byte_buffer *send_message; + struct + { + grpc_status_code code; + grpc_mdstr *details; + } send_status; + } grpc_ioreq_data; + + typedef struct + { + grpc_ioreq_op op; + gpr_uint32 flags; + /**< A copy of the write flags from grpc_op */ + grpc_ioreq_data data; + } grpc_ioreq; + + typedef void (*grpc_ioreq_completion_func) (grpc_call * call, int success, void *user_data, grpc_closure_list * closure_list); + + grpc_call *grpc_call_create (grpc_channel * channel, grpc_call * parent_call, gpr_uint32 propagation_mask, grpc_completion_queue * cq, const void *server_transport_data, grpc_mdelem ** add_initial_metadata, size_t add_initial_metadata_count, gpr_timespec send_deadline); + + void grpc_call_set_completion_queue (grpc_call * call, grpc_completion_queue * cq, grpc_closure_list * closure_list); + grpc_completion_queue *grpc_call_get_completion_queue (grpc_call * call); #ifdef GRPC_CALL_REF_COUNT_DEBUG -void grpc_call_internal_ref(grpc_call *call, const char *reason); -void grpc_call_internal_unref(grpc_call *call, const char *reason, - grpc_closure_list *closure_list); + void grpc_call_internal_ref (grpc_call * call, const char *reason); + void grpc_call_internal_unref (grpc_call * call, const char *reason, grpc_closure_list * closure_list); #define GRPC_CALL_INTERNAL_REF(call, reason) \ grpc_call_internal_ref(call, reason) #define GRPC_CALL_INTERNAL_UNREF(call, reason, closure_list) \ grpc_call_internal_unref(call, reason, closure_list) #else -void grpc_call_internal_ref(grpc_call *call); -void grpc_call_internal_unref(grpc_call *call, grpc_closure_list *closure_list); + void grpc_call_internal_ref (grpc_call * call); + void grpc_call_internal_unref (grpc_call * call, grpc_closure_list * closure_list); #define GRPC_CALL_INTERNAL_REF(call, reason) grpc_call_internal_ref(call) #define GRPC_CALL_INTERNAL_UNREF(call, reason, closure_list) \ grpc_call_internal_unref(call, closure_list) #endif -grpc_call_error grpc_call_start_ioreq_and_call_back( - grpc_call *call, const grpc_ioreq *reqs, size_t nreqs, - grpc_ioreq_completion_func on_complete, void *user_data, - grpc_closure_list *closure_list); + grpc_call_error grpc_call_start_ioreq_and_call_back (grpc_call * call, const grpc_ioreq * reqs, size_t nreqs, grpc_ioreq_completion_func on_complete, void *user_data, grpc_closure_list * closure_list); -grpc_call_stack *grpc_call_get_call_stack(grpc_call *call); + grpc_call_stack *grpc_call_get_call_stack (grpc_call * call); /* Given the top call_element, get the call object. */ -grpc_call *grpc_call_from_top_element(grpc_call_element *surface_element); + grpc_call *grpc_call_from_top_element (grpc_call_element * surface_element); -extern int grpc_trace_batch; + extern int grpc_trace_batch; -void grpc_call_log_batch(char *file, int line, gpr_log_severity severity, - grpc_call *call, const grpc_op *ops, size_t nops, - void *tag); + void grpc_call_log_batch (char *file, int line, gpr_log_severity severity, grpc_call * call, const grpc_op * ops, size_t nops, void *tag); -void grpc_server_log_request_call(char *file, int line, - gpr_log_severity severity, - grpc_server *server, grpc_call **call, - grpc_call_details *details, - grpc_metadata_array *initial_metadata, - grpc_completion_queue *cq_bound_to_call, - grpc_completion_queue *cq_for_notification, - void *tag); + void grpc_server_log_request_call (char *file, int line, gpr_log_severity severity, grpc_server * server, grpc_call ** call, grpc_call_details * details, grpc_metadata_array * initial_metadata, grpc_completion_queue * cq_bound_to_call, grpc_completion_queue * cq_for_notification, void *tag); -void grpc_server_log_shutdown(char *file, int line, gpr_log_severity severity, - grpc_server *server, grpc_completion_queue *cq, - void *tag); + void grpc_server_log_shutdown (char *file, int line, gpr_log_severity severity, grpc_server * server, grpc_completion_queue * cq, void *tag); /* Set a context pointer. No thread safety guarantees are made wrt this value. */ -void grpc_call_context_set(grpc_call *call, grpc_context_index elem, - void *value, void (*destroy)(void *value)); + void grpc_call_context_set (grpc_call * call, grpc_context_index elem, void *value, void (*destroy) (void *value)); /* Get a context pointer. */ -void *grpc_call_context_get(grpc_call *call, grpc_context_index elem); + void *grpc_call_context_get (grpc_call * call, grpc_context_index elem); #define GRPC_CALL_LOG_BATCH(sev, call, ops, nops, tag) \ if (grpc_trace_batch) grpc_call_log_batch(sev, call, ops, nops, tag) @@ -167,21 +151,20 @@ void *grpc_call_context_get(grpc_call *call, grpc_context_index elem); #define GRPC_SERVER_LOG_SHUTDOWN(sev, server, cq, tag) \ if (grpc_trace_batch) grpc_server_log_shutdown(sev, server, cq, tag) -gpr_uint8 grpc_call_is_client(grpc_call *call); + gpr_uint8 grpc_call_is_client (grpc_call * call); -grpc_compression_algorithm grpc_call_get_compression_algorithm( - const grpc_call *call); + grpc_compression_algorithm grpc_call_get_compression_algorithm (const grpc_call * call); -gpr_uint32 grpc_call_get_message_flags(const grpc_call *call); + gpr_uint32 grpc_call_get_message_flags (const grpc_call * call); /** Returns a bitset for the encodings (compression algorithms) supported by \a * call's peer. * * To be indexed by grpc_compression_algorithm enum values. */ -gpr_uint32 grpc_call_get_encodings_accepted_by_peer(grpc_call *call); + gpr_uint32 grpc_call_get_encodings_accepted_by_peer (grpc_call * call); #ifdef __cplusplus } #endif -#endif /* GRPC_INTERNAL_CORE_SURFACE_CALL_H */ +#endif /* GRPC_INTERNAL_CORE_SURFACE_CALL_H */ |