From f7e481380417ce78252be03ff8f8072e20a6b9e7 Mon Sep 17 00:00:00 2001 From: dongdaxiang Date: Wed, 27 Mar 2019 22:44:25 +0800 Subject: [PATCH] add WIN32 for rand_r and usleep test=develop --- paddle/fluid/framework/data_feed.cc | 2 ++ paddle/fluid/framework/pull_dense_worker.cc | 2 ++ 2 files changed, 4 insertions(+) diff --git a/paddle/fluid/framework/data_feed.cc b/paddle/fluid/framework/data_feed.cc index 7f882ecc9cf..50766074458 100644 --- a/paddle/fluid/framework/data_feed.cc +++ b/paddle/fluid/framework/data_feed.cc @@ -341,6 +341,7 @@ void InMemoryDataFeed::LocalShuffle() { template void InMemoryDataFeed::GlobalShuffle() { +#ifdef _LINUX VLOG(3) << "GlobalShuffle() begin, thread_id=" << thread_id_; auto fleet_ptr = FleetWrapper::GetInstance(); std::vector> send_vec(trainer_num_); @@ -387,6 +388,7 @@ void InMemoryDataFeed::GlobalShuffle() { t.wait(); } VLOG(3) << "GlobalShuffle() end, thread_id=" << thread_id_; +#endif } template diff --git a/paddle/fluid/framework/pull_dense_worker.cc b/paddle/fluid/framework/pull_dense_worker.cc index 3ebf0d8fb5b..c48c7872ec2 100644 --- a/paddle/fluid/framework/pull_dense_worker.cc +++ b/paddle/fluid/framework/pull_dense_worker.cc @@ -105,7 +105,9 @@ void PullDenseWorker::Run() { if (pull_dense_status_.size() != 0) { Wait(&pull_dense_status_); } +#ifndef _WIN32 usleep(sleep_time_ms_ * 1000); +#endif } } -- GitLab