diff options
author | Craig Tiller <ctiller@google.com> | 2015-06-22 11:41:14 -0700 |
---|---|---|
committer | Craig Tiller <ctiller@google.com> | 2015-06-22 11:41:14 -0700 |
commit | 026e600b5bb61743cf6ac86623b622520ae2d353 (patch) | |
tree | a873f52a8b5fa0a2e3adbb284d047738caf7b7db /include/grpc++ | |
parent | 3de4b47e2b4f0b4b93602e2d066eec43215bdc5b (diff) |
Update to set flags=0 on all ops
Diffstat (limited to 'include/grpc++')
-rw-r--r-- | include/grpc++/impl/call.h | 11 |
1 files changed, 10 insertions, 1 deletions
diff --git a/include/grpc++/impl/call.h b/include/grpc++/impl/call.h index 2584caec71..33e66816f5 100644 --- a/include/grpc++/impl/call.h +++ b/include/grpc++/impl/call.h @@ -84,6 +84,7 @@ class CallOpSendInitialMetadata { if (!send_) return; grpc_op* op = &ops[(*nops)++]; op->op = GRPC_OP_SEND_INITIAL_METADATA; + op->flags = 0; op->data.send_initial_metadata.count = initial_metadata_count_; op->data.send_initial_metadata.metadata = initial_metadata_; } @@ -110,6 +111,7 @@ class CallOpSendMessage { if (send_buf_ == nullptr) return; grpc_op* op = &ops[(*nops)++]; op->op = GRPC_OP_SEND_MESSAGE; + op->flags = 0; op->data.send_message = send_buf_; } void FinishOp(bool* status, int max_message_size) { @@ -141,6 +143,7 @@ class CallOpRecvMessage { if (message_ == nullptr) return; grpc_op* op = &ops[(*nops)++]; op->op = GRPC_OP_RECV_MESSAGE; + op->flags = 0; op->data.recv_message = &recv_buf_; } @@ -188,6 +191,7 @@ class CallOpGenericRecvMessage { if (!deserialize_) return; grpc_op* op = &ops[(*nops)++]; op->op = GRPC_OP_RECV_MESSAGE; + op->flags = 0; op->data.recv_message = &recv_buf_; } @@ -223,7 +227,9 @@ class CallOpClientSendClose { protected: void AddOp(grpc_op* ops, size_t* nops) { if (!send_) return; - ops[(*nops)++].op = GRPC_OP_SEND_CLOSE_FROM_CLIENT; + grpc_op* op = &ops[(*nops)++]; + op->op = GRPC_OP_SEND_CLOSE_FROM_CLIENT; + op->flags = 0; } void FinishOp(bool* status, int max_message_size) { send_ = false; } @@ -256,6 +262,7 @@ class CallOpServerSendStatus { op->data.send_status_from_server.status = send_status_code_; op->data.send_status_from_server.status_details = send_status_details_.empty() ? nullptr : send_status_details_.c_str(); + op->flags = 0; } void FinishOp(bool* status, int max_message_size) { @@ -288,6 +295,7 @@ class CallOpRecvInitialMetadata { grpc_op* op = &ops[(*nops)++]; op->op = GRPC_OP_RECV_INITIAL_METADATA; op->data.recv_initial_metadata = &recv_initial_metadata_arr_; + op->flags = 0; } void FinishOp(bool* status, int max_message_size) { if (recv_initial_metadata_ == nullptr) return; @@ -324,6 +332,7 @@ class CallOpClientRecvStatus { op->data.recv_status_on_client.status_details = &status_details_; op->data.recv_status_on_client.status_details_capacity = &status_details_capacity_; + op->flags = 0; } void FinishOp(bool* status, int max_message_size) { |