diff options
author | thegeorg <thegeorg@yandex-team.com> | 2023-03-28 10:11:46 +0300 |
---|---|---|
committer | thegeorg <thegeorg@yandex-team.com> | 2023-03-28 10:11:46 +0300 |
commit | 14a9357e8d2d937e22b789d5aea09219a3e92c31 (patch) | |
tree | 9e899edffa271e32ae6272be3034a371b3742c2a /contrib/libs/grpc/include/grpcpp/impl/codegen/call_op_set.h | |
parent | 1911ec1bf2da9ae39eb5f31511a92b06b9631da1 (diff) | |
download | ydb-14a9357e8d2d937e22b789d5aea09219a3e92c31.tar.gz |
Update contrib/libs/grpc to 1.45.2
Diffstat (limited to 'contrib/libs/grpc/include/grpcpp/impl/codegen/call_op_set.h')
-rw-r--r-- | contrib/libs/grpc/include/grpcpp/impl/codegen/call_op_set.h | 23 |
1 files changed, 14 insertions, 9 deletions
diff --git a/contrib/libs/grpc/include/grpcpp/impl/codegen/call_op_set.h b/contrib/libs/grpc/include/grpcpp/impl/codegen/call_op_set.h index 5ad0a74d83..283f299f95 100644 --- a/contrib/libs/grpc/include/grpcpp/impl/codegen/call_op_set.h +++ b/contrib/libs/grpc/include/grpcpp/impl/codegen/call_op_set.h @@ -171,6 +171,12 @@ class WriteOptions { return *this; } + /// Get value for the flag indicating that this is the last message, and + /// should be coalesced with trailing metadata. + /// + /// \sa GRPC_WRITE_LAST_MESSAGE + bool is_last_message() const { return last_message_; } + /// Guarantee that all bytes have been written to the socket before completing /// this write (usually writes are completed when they pass flow control). inline WriteOptions& set_write_through() { @@ -178,13 +184,12 @@ class WriteOptions { return *this; } - inline bool is_write_through() const { return GetBit(GRPC_WRITE_THROUGH); } + inline WriteOptions& clear_write_through() { + ClearBit(GRPC_WRITE_THROUGH); + return *this; + } - /// Get value for the flag indicating that this is the last message, and - /// should be coalesced with trailing metadata. - /// - /// \sa GRPC_WRITE_LAST_MESSAGE - bool is_last_message() const { return last_message_; } + inline bool is_write_through() const { return GetBit(GRPC_WRITE_THROUGH); } private: void SetBit(const uint32_t mask) { flags_ |= mask; } @@ -728,7 +733,7 @@ class CallOpRecvInitialMetadata { public: CallOpRecvInitialMetadata() : metadata_map_(nullptr) {} - void RecvInitialMetadata(::grpc::ClientContext* context) { + void RecvInitialMetadata(grpc::ClientContext* context) { context->initial_metadata_received_ = true; metadata_map_ = &context->recv_initial_metadata_; } @@ -777,7 +782,7 @@ class CallOpClientRecvStatus { CallOpClientRecvStatus() : recv_status_(nullptr), debug_error_string_(nullptr) {} - void ClientRecvStatus(::grpc::ClientContext* context, Status* status) { + void ClientRecvStatus(grpc::ClientContext* context, Status* status) { client_context_ = context; metadata_map_ = &client_context_->trailing_metadata_; recv_status_ = status; @@ -844,7 +849,7 @@ class CallOpClientRecvStatus { private: bool hijacked_ = false; - ::grpc::ClientContext* client_context_; + grpc::ClientContext* client_context_; MetadataMap* metadata_map_; Status* recv_status_; const char* debug_error_string_; |