forked from mindspore-Ecosystem/mindspore
!25628 Fix get data timeout
Merge pull request !25628 from luoyang/issues2
This commit is contained in:
commit
9bb04d41ae
|
@ -612,7 +612,7 @@ Status DeviceQueueOp::SendDataToGPU() {
|
|||
if (current_row.eoe()) {
|
||||
MS_LOG(INFO) << "EOE Detected";
|
||||
TensorRow eoe_flag(TensorRow::kFlagEOE);
|
||||
RETURN_IF_NOT_OK(receive_queues_[num_buf % num_workers_]->Add(std::move(eoe_flag)));
|
||||
RETURN_IF_NOT_OK(receive_queues_[num_buf++ % num_workers_]->Add(std::move(eoe_flag)));
|
||||
}
|
||||
|
||||
if (!TaskManager::FindMe()->Interrupted() && !GpuBufferMgr::GetInstance().IsClosed()) {
|
||||
|
|
Loading…
Reference in New Issue