diff options
author | Yang Gao <yangg@google.com> | 2015-02-11 13:44:11 -0800 |
---|---|---|
committer | Yang Gao <yangg@google.com> | 2015-02-11 13:44:11 -0800 |
commit | f1258c4951f9880e6943558c310da9c5629ea6de (patch) | |
tree | 88f3facbb5cf841356bbdc9c6685d0817f708e97 /include/grpc++ | |
parent | 06ed31e976369cdd0e9698786d10e8b2152e6af3 (diff) |
save before the change
Diffstat (limited to 'include/grpc++')
-rw-r--r-- | include/grpc++/impl/call.h | 19 |
1 files changed, 17 insertions, 2 deletions
diff --git a/include/grpc++/impl/call.h b/include/grpc++/impl/call.h index 141b16ab5b..40939e458f 100644 --- a/include/grpc++/impl/call.h +++ b/include/grpc++/impl/call.h @@ -63,11 +63,15 @@ class CallOpBuffer final : public CompletionQueueTag { // Does not take ownership. void AddSendInitialMetadata( std::multimap<grpc::string, grpc::string> *metadata); + void AddRecvInitialMetadata( + std::multimap<grpc::string, grpc::string> *metadata); void AddSendMessage(const google::protobuf::Message &message); void AddRecvMessage(google::protobuf::Message *message); void AddClientSendClose(); - void AddClientRecvStatus(Status *status); - void AddServerSendStatus(std::multimap<grpc::string, grpc::string> *metadata, const Status& status); + void AddClientRecvStatus(std::multimap<grpc::string, grpc::string> *metadata, + Status *status); + void AddServerSendStatus(std::multimap<grpc::string, grpc::string> *metadata, + const Status& status); // INTERNAL API: @@ -79,17 +83,28 @@ class CallOpBuffer final : public CompletionQueueTag { private: void *return_tag_ = nullptr; + // Send initial metadata size_t initial_metadata_count_ = 0; grpc_metadata* initial_metadata_ = nullptr; + // Recv initial metadta + std::multimap<grpc::string, grpc::string>* recv_initial_metadata_ = nullptr; + grpc_metadata_array recv_initial_metadata_arr_ = {0, 0, nullptr}; + // Send message const google::protobuf::Message* send_message_ = nullptr; grpc_byte_buffer* send_message_buf_ = nullptr; + // Recv message google::protobuf::Message* recv_message_ = nullptr; grpc_byte_buffer* recv_message_buf_ = nullptr; + // Client send close bool client_send_close_ = false; + // Client recv status + std::multimap<grpc::string, grpc::string>* recv_trailing_metadata_ = nullptr; Status* recv_status_ = nullptr; + grpc_metadata_array recv_trailing_metadata_arr_ = {0, 0, nullptr}; grpc_status_code status_code_ = GRPC_STATUS_OK; char* status_details_ = nullptr; size_t status_details_capacity_ = 0; + // Server send status Status* send_status_ = nullptr; size_t trailing_metadata_count_ = 0; grpc_metadata* trailing_metadata_ = nullptr; |