Changeset 3989

Timestamp:

04/08/05 11:03:21

Author:

bbralo

Message:

usleep implementation

Files:

• OpenThreads/branches/Usleep/include/OpenThreads/Thread (modified) (1 diff)
• OpenThreads/branches/Usleep/pthread_src/PThread.c++ (modified) (1 diff)
• OpenThreads/branches/Usleep/sproc_src/SprocThread.c++ (modified) (1 diff)
• OpenThreads/branches/Usleep/win32_src/Win32Thread.cpp (modified) (2 diffs)

OpenThreads/branches/Usleep/include/OpenThreads/Thread

@@ -329 +329 @@
-    int setProcessorAffinity( unsigned int cpunum );
-
+    /** usleep method.  This is not strictly thread API but is used 
+      * so often with threads. It's basically UNIX usleep. Parameter is 
+      * number of microseconds we current thread to sleep. Returns 0 on 
+      * succes, non-zero on failure (UNIX errno or GetLastError() will give
+      * detailed description.
+      */
+    static int usleep( unsigned int microsec);
+
-private:
-

OpenThreads/branches/Usleep/pthread_src/PThread.c++

@@ -833 +833 @@
-
-}
+
+// Description:  sleep 
+//
+// Use: public
+//
+int Thread::usleep(unsigned int microsec)
+{
+    return ::usleep(microsec);
+}

OpenThreads/branches/Usleep/sproc_src/SprocThread.c++

@@ -753 +753 @@
-}
-
+//-----------------------------------------------------------------------------
+// Description:  sleep 
+//
+// Use: public
+//
+int Thread::usleep(unsigned int microsec)
+{
+    return ::usleep(microsec);
+}
+
-static void sproc_dead_child_sig_handler(int sigid) {
-

OpenThreads/branches/Usleep/win32_src/Win32Thread.cpp

@@ -602 +602 @@
-int SwitchToThread (void)
-{
-
+::
-    return 0;
-};
@@ -612 +612 @@
-}
-
+int Thread::usleep(unsigned int microsec)
+{
+#if _WIN32_WINNT < 0x0400 // simulate
+    ::Sleep(microsec/1000);
+    return 0;
+#else
+    HandleHolder sleepTimer(CreateWaitableTimer(NULL, TRUE, NULL));
+
+    if( !sleepTimer )
+      return -1;
+    
+    LARGE_INTEGER t;
+
+    t.QuadPart= -(LONGLONG)microsec*10; // in 100ns units
+                 // negative sign means relative,
+
+    if (!SetWaitableTimer(sleepTimer.get(), &t, 0, NULL, NULL, 0))
+    {
+        return -1;
+    }
+
+    // Wait for the timer.
+    if (WaitForSingleObject(sleepTimer.get(), INFINITE) != WAIT_OBJECT_0)
+    {
+        return -1;
+    } 
+    return 0;
+#endif
+}