aboutsummaryrefslogtreecommitdiffhomepage
path: root/include/grpc++
diff options
context:
space:
mode:
authorGravatar Yuxuan Li <yuxuanli@google.com>2017-03-03 13:59:30 -0800
committerGravatar Yuxuan Li <yuxuanli@google.com>2017-03-08 10:59:31 -0800
commitbdc76ab37b4d61a849f2f9f9742a5004864ce984 (patch)
tree2d3ebf49880c0e92abd3c093d31774a0176e0e61 /include/grpc++
parent34894e4b1c46697a5b484d5f6b7734ea8795d149 (diff)
bug fix
Diffstat (limited to 'include/grpc++')
-rw-r--r--include/grpc++/impl/codegen/async_stream.h4
-rw-r--r--include/grpc++/impl/codegen/client_context.h4
-rw-r--r--include/grpc++/impl/codegen/sync_stream.h4
3 files changed, 7 insertions, 5 deletions
diff --git a/include/grpc++/impl/codegen/async_stream.h b/include/grpc++/impl/codegen/async_stream.h
index f21139618f..a201341590 100644
--- a/include/grpc++/impl/codegen/async_stream.h
+++ b/include/grpc++/impl/codegen/async_stream.h
@@ -244,7 +244,7 @@ class ClientAsyncWriter final : public ClientAsyncWriterInterface<W> {
call_.PerformOps(&write_ops_);
}
- void Write(const W& msg, WriteOptions options, void* tag) {
+ void Write(const W& msg, WriteOptions options, void* tag) override {
write_ops_.set_output_tag(tag);
if (options.is_last_message()) {
options.set_buffer_hint();
@@ -341,7 +341,7 @@ class ClientAsyncReaderWriter final
call_.PerformOps(&write_ops_);
}
- void Write(const W& msg, WriteOptions options, void* tag) {
+ void Write(const W& msg, WriteOptions options, void* tag) override {
write_ops_.set_output_tag(tag);
if (options.is_last_message()) {
options.set_buffer_hint();
diff --git a/include/grpc++/impl/codegen/client_context.h b/include/grpc++/impl/codegen/client_context.h
index cc48b9c3f5..3c50e6ba9d 100644
--- a/include/grpc++/impl/codegen/client_context.h
+++ b/include/grpc++/impl/codegen/client_context.h
@@ -288,7 +288,9 @@ class ClientContext {
///
/// \param corked The flag indicating whether the initial metadata is to be
/// corked or not.
- void sent_initial_metadata_corked(bool corked);
+ void set_initial_metadata_corked(bool corked) {
+ initial_metadata_corked_ = corked;
+ }
/// Return the peer uri in a string.
///
diff --git a/include/grpc++/impl/codegen/sync_stream.h b/include/grpc++/impl/codegen/sync_stream.h
index 859c3d0b90..ae3b8e441d 100644
--- a/include/grpc++/impl/codegen/sync_stream.h
+++ b/include/grpc++/impl/codegen/sync_stream.h
@@ -262,7 +262,7 @@ class ClientWriter : public ClientWriterInterface<W> {
if (context_->initial_metadata_corked_) {
ops.SendInitialMetadata(context_->send_initial_metadata_,
context_->initial_metadata_flags());
- context_->sent_initial_metadata_corked(false);
+ context_->set_initial_metadata_corked(false);
}
if (!ops.SendMessage(msg, options).ok()) {
return false;
@@ -372,7 +372,7 @@ class ClientReaderWriter final : public ClientReaderWriterInterface<W, R> {
if (context_->initial_metadata_corked_) {
ops.SendInitialMetadata(context_->send_initial_metadata_,
context_->initial_metadata_flags());
- context_->sent_initial_metadata_corked(false);
+ context_->set_initial_metadata_corked(false);
}
if (!ops.SendMessage(msg, options).ok()) {
return false;