wassname/ray
1
0
Fork 0
mirror of https://github.com/wassname/ray.git synced 2026-07-11 21:43:06 +08:00
Code Issues Packages Projects Releases Wiki Activity

Remove objstore_stub_ (#176)

Browse Source
This commit is contained in:
mehrdadn
2016-06-27 23:16:35 +03:00
committed by Philipp Moritz
parent 23c0b1828f
commit 27bd859925
2 changed files with 1 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/worker.cc
+1 -2
View File
@@ -21,8 +21,7 @@ Status WorkerServiceImpl::ExecuteTask(ServerContext* context, const ExecuteTaskR
Worker::Worker(const std::string& worker_address, std::shared_ptr<Channel> scheduler_channel, std::shared_ptr<Channel> 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;
}
src/worker.h
-1
View File
@@ -92,7 +92,6 @@ class Worker {
bool connected_;
const size_t CHUNK_SIZE = 8 * 1024;
std::unique_ptr<Scheduler::Stub> scheduler_stub_;
std::unique_ptr<ObjStore::Stub> objstore_stub_;
std::thread worker_server_thread_;
MessageQueue<Task*> receive_queue_;
managed_shared_memory segment_;