Skip to content

Commit

Permalink
Merge pull request #36 from chao9527/paddlebox
Browse files Browse the repository at this point in the history
format
  • Loading branch information
qingshui authored Apr 1, 2022
2 parents 3860903 + 1cb68eb commit 920c89f
Show file tree
Hide file tree
Showing 3 changed files with 157 additions and 144 deletions.
8 changes: 4 additions & 4 deletions paddle/fluid/framework/boxps_trainer.cc
Original file line number Diff line number Diff line change
Expand Up @@ -141,16 +141,16 @@ void BoxPSTrainer::InitTrainerEnv(const ProgramDesc& main_program,

std::set<std::string> async_param_name;
if (async_mode_) {
async_param_name = dense_table_->Init(*root_scope_, *param_need_sync_.get(),
persistable_vars_);
async_param_name = dense_table_->Init(*root_scope_, *param_need_sync_.get(),
persistable_vars_);
}
for (int i = 0; i < thread_num_; ++i) {
auto this_worker =
std::dynamic_pointer_cast<paddle::framework::BoxPSWorker>(workers_[i]);
this_worker->SetRootScope(root_scope_);
if (async_mode_) {
this_worker->SetDenseTable(dense_table_.get());
this_worker->SetAsyncParamName(async_param_name);
this_worker->SetDenseTable(dense_table_.get());
this_worker->SetAsyncParamName(async_param_name);
}
this_worker->CreateDeviceResource(main_program);
// CopyParameters(*root_scope_, i);
Expand Down
Loading

0 comments on commit 920c89f

Please sign in to comment.