From 27bd85992596646d4bb82e7c84596073d25c35ba Mon Sep 17 00:00:00 2001 From: mehrdadn Date: Mon, 27 Jun 2016 23:16:35 +0300 Subject: [PATCH] Remove objstore_stub_ (#176) --- src/worker.cc | 3 +-- src/worker.h | 1 - 2 files changed, 1 insertion(+), 3 deletions(-) diff --git a/src/worker.cc b/src/worker.cc index 2d6b3964f..950e7d3e1 100644 --- a/src/worker.cc +++ b/src/worker.cc @@ -21,8 +21,7 @@ Status WorkerServiceImpl::ExecuteTask(ServerContext* context, const ExecuteTaskR Worker::Worker(const std::string& worker_address, std::shared_ptr scheduler_channel, std::shared_ptr objstore_channel) : worker_address_(worker_address), - scheduler_stub_(Scheduler::NewStub(scheduler_channel)), - objstore_stub_(ObjStore::NewStub(objstore_channel)) { + scheduler_stub_(Scheduler::NewStub(scheduler_channel)) { receive_queue_.connect(worker_address_, true); connected_ = true; } diff --git a/src/worker.h b/src/worker.h index 6c303691e..d52332e6a 100644 --- a/src/worker.h +++ b/src/worker.h @@ -92,7 +92,6 @@ class Worker { bool connected_; const size_t CHUNK_SIZE = 8 * 1024; std::unique_ptr scheduler_stub_; - std::unique_ptr objstore_stub_; std::thread worker_server_thread_; MessageQueue receive_queue_; managed_shared_memory segment_;