aboutsummaryrefslogtreecommitdiffhomepage
path: root/src/cpp/common
diff options
context:
space:
mode:
authorGravatar Craig Tiller <craig.tiller@gmail.com>2015-02-17 07:38:26 -0800
committerGravatar Craig Tiller <craig.tiller@gmail.com>2015-02-17 07:38:26 -0800
commit573523f1278a8c797c10ebb2a8b571d6891a22cc (patch)
tree1d250d9a1747e9fa3949776ecf9d9789ff0c633d /src/cpp/common
parent73b7018ebdf546684fc916dcf87d21dd82d0b4c5 (diff)
clang-format
Diffstat (limited to 'src/cpp/common')
-rw-r--r--src/cpp/common/call.cc35
-rw-r--r--src/cpp/common/completion_queue.cc4
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) {