From 020a71a06d520c0fb9948af3fde7042601fd0c1c Mon Sep 17 00:00:00 2001
From: vng <viktor.govako@gmail.com>
Date: Fri, 1 Jul 2011 22:18:40 +0300
Subject: [PATCH] Add cross-platform Sleep(milliseconds) function.

---
 base/base_tests/object_pool_test.cpp | 19 +++++--------------
 base/thread.cpp                      | 12 ++++++++++++
 base/thread.hpp                      |  5 +++++
 3 files changed, 22 insertions(+), 14 deletions(-)

diff --git a/base/base_tests/object_pool_test.cpp b/base/base_tests/object_pool_test.cpp
index 39eebd480b..ff559f999f 100644
--- a/base/base_tests/object_pool_test.cpp
+++ b/base/base_tests/object_pool_test.cpp
@@ -3,18 +3,9 @@
 
 #include "../object_pool.hpp"
 #include "../thread.hpp"
+
 #include "../../base/logging.hpp"
 
-namespace my
-{
-  void sleep(int ms)
-  {
-    timespec t;
-    t.tv_nsec =(ms * 1000000) % 1000000000;
-    t.tv_sec = (ms * 1000000) / 1000000000;
-    nanosleep(&t, 0);
-  }
-}
 
 struct ProcessorThread : public threads::IRoutine
 {
@@ -33,7 +24,7 @@ struct ProcessorThread : public threads::IRoutine
       int res = m_p->Reserve();
       m_res->push_back(res);
       LOG(LINFO, (m_id, " thread got ", res));
-      my::sleep(10);
+      threads::Sleep(10);
     }
     LOG(LINFO, (m_id, " thread is cancelled"));
   }
@@ -57,13 +48,13 @@ UNIT_TEST(ObjectPool)
   t2.Create(new ProcessorThread(&p, &res, 2));
 
   p.Free(0);
-  my::sleep(200);
+  threads::Sleep(200);
 
   p.Free(1);
-  my::sleep(200);
+  threads::Sleep(200);
 
   p.Free(2);
-  my::sleep(200);
+  threads::Sleep(200);
 
   TEST_EQUAL(res.front(), 0, ());
   res.pop_front();
diff --git a/base/thread.cpp b/base/thread.cpp
index 4974de7d9d..d1a983f942 100644
--- a/base/thread.cpp
+++ b/base/thread.cpp
@@ -166,4 +166,16 @@ namespace threads
       }
     }
   }
+
+  void Sleep(size_t ms)
+  {
+#ifdef OMIM_OS_WINDOWS
+    ::Sleep(ms);
+#else
+    timespec t;
+    t.tv_nsec =(ms * 1000000) % 1000000000;
+    t.tv_sec = (ms * 1000000) / 1000000000;
+    nanosleep(&t, 0);
+#endif
+  }
 }
diff --git a/base/thread.hpp b/base/thread.hpp
index 68801e2fd9..ecab55dbf1 100644
--- a/base/thread.hpp
+++ b/base/thread.hpp
@@ -40,4 +40,9 @@ namespace threads
     /// wait for thread ending
     void Join();
   };
+
+  /// Suspends the execution of the current thread until the time-out interval elapses.
+  /// @param[in] ms time-out interval in milliseconds
+  void Sleep(size_t ms);
+
 } // namespace threads