aboutsummaryrefslogtreecommitdiffhomepage
path: root/src/core/surface/call.h
diff options
context:
space:
mode:
authorGravatar Craig Tiller <ctiller@google.com>2015-09-22 10:42:19 -0700
committerGravatar Craig Tiller <ctiller@google.com>2015-09-22 10:42:19 -0700
commit45724b35e411fef7c5da66a74c78428c11d56843 (patch)
tree9264034aca675c89444e02f72ef58e67d7043604 /src/core/surface/call.h
parent298751c1195523ef6228595043b583c3a6270e08 (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.h171
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 */