aboutsummaryrefslogtreecommitdiffhomepage
path: root/src/main/cpp
diff options
context:
space:
mode:
authorGravatar Googler <noreply@google.com>2018-06-20 11:51:52 -0700
committerGravatar Copybara-Service <copybara-piper@google.com>2018-06-20 11:53:12 -0700
commitc325124b5161361629e217e1cd51c02e30a55307 (patch)
treeaec14d0963ca3770a68833f938328f11208d668a /src/main/cpp
parentf140cf38242666cb75977d5161ab457e287de02d (diff)
PiperOrigin-RevId: 201390253
Diffstat (limited to 'src/main/cpp')
-rw-r--r--src/main/cpp/blaze.cc12
1 files changed, 7 insertions, 5 deletions
diff --git a/src/main/cpp/blaze.cc b/src/main/cpp/blaze.cc
index 055e3fd792..a8987eb2b2 100644
--- a/src/main/cpp/blaze.cc
+++ b/src/main/cpp/blaze.cc
@@ -81,6 +81,7 @@ using std::map;
using std::set;
using std::string;
using std::vector;
+using command_server::CommandServer;
// The following is a treatise on how the interaction between the client and the
// server works.
@@ -227,7 +228,7 @@ class GrpcBlazeServer : public BlazeServer {
private:
enum CancelThreadAction { NOTHING, JOIN, CANCEL, COMMAND_ID_RECEIVED };
- std::unique_ptr<command_server::CommandServer::Stub> client_;
+ std::unique_ptr<CommandServer::Stub> client_;
std::string request_cookie_;
std::string response_cookie_;
std::string command_id_;
@@ -243,7 +244,7 @@ class GrpcBlazeServer : public BlazeServer {
// actions from.
blaze_util::IPipe *pipe_;
- bool TryConnect(command_server::CommandServer::Stub *client);
+ bool TryConnect(CommandServer::Stub *client);
void CancelThread();
void SendAction(CancelThreadAction action);
void SendCancelMessage();
@@ -1563,7 +1564,8 @@ GrpcBlazeServer::~GrpcBlazeServer() {
pipe_ = NULL;
}
-bool GrpcBlazeServer::TryConnect(command_server::CommandServer::Stub *client) {
+bool GrpcBlazeServer::TryConnect(
+ CommandServer::Stub *client) {
grpc::ClientContext context;
context.set_deadline(std::chrono::system_clock::now() +
std::chrono::seconds(connect_timeout_secs_));
@@ -1628,8 +1630,8 @@ bool GrpcBlazeServer::Connect() {
std::shared_ptr<grpc::Channel> channel(
grpc::CreateChannel(port, grpc::InsecureChannelCredentials()));
- std::unique_ptr<command_server::CommandServer::Stub> client(
- command_server::CommandServer::NewStub(channel));
+ std::unique_ptr<CommandServer::Stub> client(
+ CommandServer::NewStub(channel));
if (!TryConnect(client.get())) {
return false;