aboutsummaryrefslogtreecommitdiffstats
path: root/contrib/libs/grpc/include/grpcpp/impl/codegen/call_op_set.h
diff options
context:
space:
mode:
authorthegeorg <thegeorg@yandex-team.com>2023-03-28 10:11:46 +0300
committerthegeorg <thegeorg@yandex-team.com>2023-03-28 10:11:46 +0300
commit14a9357e8d2d937e22b789d5aea09219a3e92c31 (patch)
tree9e899edffa271e32ae6272be3034a371b3742c2a /contrib/libs/grpc/include/grpcpp/impl/codegen/call_op_set.h
parent1911ec1bf2da9ae39eb5f31511a92b06b9631da1 (diff)
downloadydb-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.h23
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_;