From 329f1e0f79001f32aadc4e6344be06e5ba00ef63 Mon Sep 17 00:00:00 2001 From: Yancey1989 Date: Mon, 15 Jan 2018 20:18:34 +0800 Subject: [PATCH] add some comment --- paddle/operators/recv_op.cc | 1 + paddle/operators/send_op.cc | 2 -- 2 files changed, 1 insertion(+), 2 deletions(-) diff --git a/paddle/operators/recv_op.cc b/paddle/operators/recv_op.cc index dad5cf372e..978ce92d24 100644 --- a/paddle/operators/recv_op.cc +++ b/paddle/operators/recv_op.cc @@ -90,6 +90,7 @@ class RecvOp : public framework::OperatorBase { platform::DeviceContextPool &pool = platform::DeviceContextPool::Instance(); auto &dev_ctx = *pool.Get(dev_place); + // FIXME(Yancey1989): initialize rpc server with laze mode. rpc_service_->SetScope(&recv_scope); rpc_service_->SetDevCtx(&dev_ctx); auto param_list = Attr>("ParamList"); diff --git a/paddle/operators/send_op.cc b/paddle/operators/send_op.cc index a82c3430e9..1e6d659180 100644 --- a/paddle/operators/send_op.cc +++ b/paddle/operators/send_op.cc @@ -38,8 +38,6 @@ class SendOp : public framework::OperatorBase { auto outs = Outputs("Out"); std::vector epmap = Attr>("epmap"); - // FIXME(gongwb): DeviceContext? - // auto ctx = platform::CPUDeviceContext(); platform::DeviceContextPool& pool = platform::DeviceContextPool::Instance(); auto& ctx = *pool.Get(place); for (size_t i = 0; i < ins.size(); i++) { -- GitLab