|
|
@ -34,7 +34,10 @@ void SendOpHandle::RunImpl() {
|
|
|
|
}
|
|
|
|
}
|
|
|
|
in->generated_op_->Wait(dev_ctxes_[p]);
|
|
|
|
in->generated_op_->Wait(dev_ctxes_[p]);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
this->RunAndRecordEvent([&] { op_->Run(*local_scope_, place_); });
|
|
|
|
auto &tmp_scope = local_scope_->FindVar(kLocalExecScopeName)->Get<Scope *>();
|
|
|
|
|
|
|
|
// FIXME(wuyi): can not use RunAndRecordEvent here, for it will cause dead
|
|
|
|
|
|
|
|
// lock.
|
|
|
|
|
|
|
|
op_->Run(*tmp_scope, place_);
|
|
|
|
}
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
std::string SendOpHandle::Name() const { return "send"; }
|
|
|
|
std::string SendOpHandle::Name() const { return "send"; }
|
|
|
|