aboutsummaryrefslogtreecommitdiffhomepage
path: root/include
diff options
context:
space:
mode:
authorGravatar Vijay Pai <vpai@google.com>2017-06-22 12:06:44 -0700
committerGravatar Vijay Pai <vpai@google.com>2017-06-22 12:06:44 -0700
commitd35730d18564a00a4b9acccaf8387ccb4bb565b8 (patch)
tree8a241c5bc534ca414ebc4597d5d36444e0f5ef8f /include
parentfc539eb19334bdfde8bc798d94ccb56b686e5193 (diff)
Fix use of terminal underscores in field names.
Diffstat (limited to 'include')
-rw-r--r--include/grpc++/impl/codegen/async_unary_call.h52
1 files changed, 26 insertions, 26 deletions
diff --git a/include/grpc++/impl/codegen/async_unary_call.h b/include/grpc++/impl/codegen/async_unary_call.h
index de0ab2372a..a5a698c640 100644
--- a/include/grpc++/impl/codegen/async_unary_call.h
+++ b/include/grpc++/impl/codegen/async_unary_call.h
@@ -100,13 +100,13 @@ class ClientAsyncResponseReader final
: context_(context),
call_(channel->CreateCall(method, context, cq)),
collection_(std::make_shared<Ops>()) {
- collection_->init_buf_.SetCollection(collection_);
- collection_->init_buf_.SendInitialMetadata(
+ collection_->init_buf.SetCollection(collection_);
+ collection_->init_buf.SendInitialMetadata(
context->send_initial_metadata_, context->initial_metadata_flags());
// TODO(ctiller): don't assert
- GPR_CODEGEN_ASSERT(collection_->init_buf_.SendMessage(request).ok());
- collection_->init_buf_.ClientSendClose();
- call_.PerformOps(&collection_->init_buf_);
+ GPR_CODEGEN_ASSERT(collection_->init_buf.SendMessage(request).ok());
+ collection_->init_buf.ClientSendClose();
+ call_.PerformOps(&collection_->init_buf);
}
// always allocated against a call arena, no memory free required
@@ -123,18 +123,18 @@ class ClientAsyncResponseReader final
void ReadInitialMetadata(void* tag) {
GPR_CODEGEN_ASSERT(!context_->initial_metadata_received_);
- Ops& o = ops;
+ Ops& o = ops_;
// TODO(vjpai): Remove the collection_ specialization as soon
// as the public constructor is deleted
if (collection_) {
o = *collection_;
- collection_->meta_buf_.SetCollection(collection_);
+ collection_->meta_buf.SetCollection(collection_);
}
- o.meta_buf_.set_output_tag(tag);
- o.meta_buf_.RecvInitialMetadata(context_);
- call_.PerformOps(&o.meta_buf_);
+ o.meta_buf.set_output_tag(tag);
+ o.meta_buf.RecvInitialMetadata(context_);
+ call_.PerformOps(&o.meta_buf);
}
/// See \a ClientAysncResponseReaderInterface::Finish for semantics.
@@ -143,23 +143,23 @@ class ClientAsyncResponseReader final
/// - the \a ClientContext associated with this call is updated with
/// possible initial and trailing metadata sent from the server.
void Finish(R* msg, Status* status, void* tag) {
- Ops& o = ops;
+ Ops& o = ops_;
// TODO(vjpai): Remove the collection_ specialization as soon
// as the public constructor is deleted
if (collection_) {
o = *collection_;
- collection_->finish_buf_.SetCollection(collection_);
+ collection_->finish_buf.SetCollection(collection_);
}
- o.finish_buf_.set_output_tag(tag);
+ o.finish_buf.set_output_tag(tag);
if (!context_->initial_metadata_received_) {
- o.finish_buf_.RecvInitialMetadata(context_);
+ o.finish_buf.RecvInitialMetadata(context_);
}
- o.finish_buf_.RecvMessage(msg);
- o.finish_buf_.AllowNoMessage();
- o.finish_buf_.ClientRecvStatus(context_, status);
- call_.PerformOps(&o.finish_buf_);
+ o.finish_buf.RecvMessage(msg);
+ o.finish_buf.AllowNoMessage();
+ o.finish_buf.ClientRecvStatus(context_, status);
+ call_.PerformOps(&o.finish_buf);
}
private:
@@ -169,12 +169,12 @@ class ClientAsyncResponseReader final
template <class W>
ClientAsyncResponseReader(Call call, ClientContext* context, const W& request)
: context_(context), call_(call) {
- ops.init_buf_.SendInitialMetadata(context->send_initial_metadata_,
+ ops_.init_buf.SendInitialMetadata(context->send_initial_metadata_,
context->initial_metadata_flags());
// TODO(ctiller): don't assert
- GPR_CODEGEN_ASSERT(ops.init_buf_.SendMessage(request).ok());
- ops.init_buf_.ClientSendClose();
- call_.PerformOps(&ops.init_buf_);
+ GPR_CODEGEN_ASSERT(ops_.init_buf.SendMessage(request).ok());
+ ops_.init_buf.ClientSendClose();
+ call_.PerformOps(&ops_.init_buf);
}
// disable operator new
@@ -186,12 +186,12 @@ class ClientAsyncResponseReader final
struct Ops : public CallOpSetCollectionInterface {
SneakyCallOpSet<CallOpSendInitialMetadata, CallOpSendMessage,
CallOpClientSendClose>
- init_buf_;
- CallOpSet<CallOpRecvInitialMetadata> meta_buf_;
+ init_buf;
+ CallOpSet<CallOpRecvInitialMetadata> meta_buf;
CallOpSet<CallOpRecvInitialMetadata, CallOpRecvMessage<R>,
CallOpClientRecvStatus>
- finish_buf_;
- } ops;
+ finish_buf;
+ } ops_;
// TODO(vjpai): Remove the collection_ as soon as the related workaround
// (public constructor) is deleted