diff options
author | 2015-02-17 07:38:26 -0800 | |
---|---|---|
committer | 2015-02-17 07:38:26 -0800 | |
commit | 573523f1278a8c797c10ebb2a8b571d6891a22cc (patch) | |
tree | 1d250d9a1747e9fa3949776ecf9d9789ff0c633d /src/cpp/common | |
parent | 73b7018ebdf546684fc916dcf87d21dd82d0b4c5 (diff) |
clang-format
Diffstat (limited to 'src/cpp/common')
-rw-r--r-- | src/cpp/common/call.cc | 35 | ||||
-rw-r--r-- | src/cpp/common/completion_queue.cc | 4 |
2 files changed, 19 insertions, 20 deletions
diff --git a/src/cpp/common/call.cc b/src/cpp/common/call.cc index fe8859de94..df800d940d 100644 --- a/src/cpp/common/call.cc +++ b/src/cpp/common/call.cc @@ -95,13 +95,13 @@ namespace { // mess. Make sure it does not happen. grpc_metadata* FillMetadataArray( std::multimap<grpc::string, grpc::string>* metadata) { - if (metadata->empty()) { return nullptr; } - grpc_metadata* metadata_array = (grpc_metadata*)gpr_malloc( - metadata->size()* sizeof(grpc_metadata)); + if (metadata->empty()) { + return nullptr; + } + grpc_metadata* metadata_array = + (grpc_metadata*)gpr_malloc(metadata->size() * sizeof(grpc_metadata)); size_t i = 0; - for (auto iter = metadata->cbegin(); - iter != metadata->cend(); - ++iter, ++i) { + for (auto iter = metadata->cbegin(); iter != metadata->cend(); ++iter, ++i) { metadata_array[i].key = iter->first.c_str(); metadata_array[i].value = iter->second.c_str(); metadata_array[i].value_length = iter->second.size(); @@ -114,7 +114,8 @@ void FillMetadataMap(grpc_metadata_array* arr, for (size_t i = 0; i < arr->count; i++) { // TODO(yangg) handle duplicates? metadata->insert(std::pair<grpc::string, grpc::string>( - arr->metadata[i].key, {arr->metadata[i].value, arr->metadata[i].value_length})); + arr->metadata[i].key, + {arr->metadata[i].value, arr->metadata[i].value_length})); } grpc_metadata_array_destroy(arr); grpc_metadata_array_init(arr); @@ -133,8 +134,7 @@ void CallOpBuffer::AddRecvInitialMetadata( recv_initial_metadata_ = metadata; } - -void CallOpBuffer::AddSendInitialMetadata(ClientContext *ctx) { +void CallOpBuffer::AddSendInitialMetadata(ClientContext* ctx) { AddSendInitialMetadata(&ctx->send_initial_metadata_); } @@ -142,20 +142,18 @@ void CallOpBuffer::AddSendMessage(const google::protobuf::Message& message) { send_message_ = &message; } -void CallOpBuffer::AddRecvMessage(google::protobuf::Message *message) { +void CallOpBuffer::AddRecvMessage(google::protobuf::Message* message) { recv_message_ = message; } -void CallOpBuffer::AddClientSendClose() { - client_send_close_ = true; -} +void CallOpBuffer::AddClientSendClose() { client_send_close_ = true; } void CallOpBuffer::AddServerRecvClose(bool* cancelled) { recv_closed_ = cancelled; } void CallOpBuffer::AddClientRecvStatus( - std::multimap<grpc::string, grpc::string>* metadata, Status *status) { + std::multimap<grpc::string, grpc::string>* metadata, Status* status) { recv_trailing_metadata_ = metadata; recv_status_ = status; } @@ -171,7 +169,7 @@ void CallOpBuffer::AddServerSendStatus( send_status_ = &status; } -void CallOpBuffer::FillOps(grpc_op *ops, size_t *nops) { +void CallOpBuffer::FillOps(grpc_op* ops, size_t* nops) { *nops = 0; if (send_initial_metadata_) { ops[*nops].op = GRPC_OP_SEND_INITIAL_METADATA; @@ -232,7 +230,7 @@ void CallOpBuffer::FillOps(grpc_op *ops, size_t *nops) { } } -void CallOpBuffer::FinalizeResult(void **tag, bool *status) { +void CallOpBuffer::FinalizeResult(void** tag, bool* status) { // Release send buffers. if (send_message_buf_) { grpc_byte_buffer_destroy(send_message_buf_); @@ -270,15 +268,14 @@ void CallOpBuffer::FinalizeResult(void **tag, bool *status) { FillMetadataMap(&recv_trailing_metadata_arr_, recv_trailing_metadata_); *recv_status_ = Status( static_cast<StatusCode>(status_code_), - status_details_ ? grpc::string(status_details_) - : grpc::string()); + status_details_ ? grpc::string(status_details_) : grpc::string()); } if (recv_closed_) { *recv_closed_ = cancelled_buf_ != 0; } } -Call::Call(grpc_call* call, CallHook *call_hook, CompletionQueue* cq) +Call::Call(grpc_call* call, CallHook* call_hook, CompletionQueue* cq) : call_hook_(call_hook), cq_(cq), call_(call) {} void Call::PerformOps(CallOpBuffer* buffer) { diff --git a/src/cpp/common/completion_queue.cc b/src/cpp/common/completion_queue.cc index f69ddc3b7e..4419b4b2f1 100644 --- a/src/cpp/common/completion_queue.cc +++ b/src/cpp/common/completion_queue.cc @@ -52,7 +52,9 @@ void CompletionQueue::Shutdown() { grpc_completion_queue_shutdown(cq_); } // Helper class so we can declare a unique_ptr with grpc_event class EventDeleter { public: - void operator()(grpc_event *ev) { if (ev) grpc_event_finish(ev); } + void operator()(grpc_event *ev) { + if (ev) grpc_event_finish(ev); + } }; bool CompletionQueue::Next(void **tag, bool *ok) { |