diff options
author | Yuxuan Li <yuxuanli@google.com> | 2017-03-03 13:59:30 -0800 |
---|---|---|
committer | Yuxuan Li <yuxuanli@google.com> | 2017-03-08 10:59:31 -0800 |
commit | bdc76ab37b4d61a849f2f9f9742a5004864ce984 (patch) | |
tree | 2d3ebf49880c0e92abd3c093d31774a0176e0e61 /include/grpc++ | |
parent | 34894e4b1c46697a5b484d5f6b7734ea8795d149 (diff) |
bug fix
Diffstat (limited to 'include/grpc++')
-rw-r--r-- | include/grpc++/impl/codegen/async_stream.h | 4 | ||||
-rw-r--r-- | include/grpc++/impl/codegen/client_context.h | 4 | ||||
-rw-r--r-- | include/grpc++/impl/codegen/sync_stream.h | 4 |
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; |