diff options
Diffstat (limited to 'src/csharp')
| -rw-r--r-- | src/csharp/ext/grpc_csharp_ext.c | 42 |
1 files changed, 21 insertions, 21 deletions
diff --git a/src/csharp/ext/grpc_csharp_ext.c b/src/csharp/ext/grpc_csharp_ext.c index 3cdeaef715..8f5a414187 100644 --- a/src/csharp/ext/grpc_csharp_ext.c +++ b/src/csharp/ext/grpc_csharp_ext.c @@ -346,14 +346,19 @@ grpcsharp_call_start_unary(grpc_call *call, callback_funcptr callback, /* Synchronous unary call */ GPR_EXPORT void GPR_CALLTYPE -grpcsharp_call_blocking_unary(grpc_call *call, grpc_completion_queue *dedicated_cq, callback_funcptr callback, - const char *send_buffer, size_t send_buffer_len) { - GPR_ASSERT(grpcsharp_call_start_unary(call, callback, send_buffer, send_buffer_len) == GRPC_CALL_OK); +grpcsharp_call_blocking_unary(grpc_call *call, + grpc_completion_queue *dedicated_cq, + callback_funcptr callback, + const char *send_buffer, size_t send_buffer_len) { + GPR_ASSERT(grpcsharp_call_start_unary(call, callback, send_buffer, + send_buffer_len) == GRPC_CALL_OK); /* TODO: we would like to use pluck, but we don't know the tag */ - GPR_ASSERT(grpcsharp_completion_queue_next_with_callback(dedicated_cq) == GRPC_OP_COMPLETE); + GPR_ASSERT(grpcsharp_completion_queue_next_with_callback(dedicated_cq) == + GRPC_OP_COMPLETE); grpc_completion_queue_shutdown(dedicated_cq); - GPR_ASSERT(grpcsharp_completion_queue_next_with_callback(dedicated_cq) == GRPC_QUEUE_SHUTDOWN); + GPR_ASSERT(grpcsharp_completion_queue_next_with_callback(dedicated_cq) == + GRPC_QUEUE_SHUTDOWN); } GPR_EXPORT grpc_call_error GPR_CALLTYPE @@ -582,24 +587,22 @@ grpcsharp_server_request_call(grpc_server *server, grpc_completion_queue *cq, /* Logging */ -typedef void(GPR_CALLTYPE *grpcsharp_log_func)(const char *file, - gpr_int32 line, - gpr_uint64 thd_id, - const char *severity_string, - const char *msg); +typedef void(GPR_CALLTYPE *grpcsharp_log_func)(const char *file, gpr_int32 line, + gpr_uint64 thd_id, + const char *severity_string, + const char *msg); static grpcsharp_log_func log_func = NULL; /* Redirects gpr_log to log_func callback */ static void grpcsharp_log_handler(gpr_log_func_args *args) { - log_func(args->file, args->line, gpr_thd_currentid(), - gpr_log_severity_string(args->severity), args->message); + log_func(args->file, args->line, gpr_thd_currentid(), + gpr_log_severity_string(args->severity), args->message); } -GPR_EXPORT void GPR_CALLTYPE -grpcsharp_redirect_log(grpcsharp_log_func func) { - GPR_ASSERT(func); - log_func = func; - gpr_set_log_function(grpcsharp_log_handler); +GPR_EXPORT void GPR_CALLTYPE grpcsharp_redirect_log(grpcsharp_log_func func) { + GPR_ASSERT(func); + log_func = func; + gpr_set_log_function(grpcsharp_log_handler); } /* For testing */ @@ -609,7 +612,4 @@ grpcsharp_test_callback(callback_funcptr callback) { } /* For testing */ -GPR_EXPORT void *GPR_CALLTYPE -grpcsharp_test_nop(void *ptr) { - return ptr; -} +GPR_EXPORT void *GPR_CALLTYPE grpcsharp_test_nop(void *ptr) { return ptr; } |