Changeset 13653 in vbox

Timestamp:

Oct 29, 2008 2:28:27 PM (16 years ago)

Author:

vboxsync

svn:sync-xref-src-repo-rev:

38595

Message:

IPRT: RTThreadPoke for posix.

Location:

trunk

Files:

• include/iprt/thread.h (modified) (1 diff)
• src/VBox/Runtime/r3/posix/thread-posix.cpp (modified) (4 diffs)

trunk/include/iprt/thread.h

@@ -371 +371 @@
  */
 RTDECL(int) RTThreadUserReset(RTTHREAD Thread);
+
+/**
+ * Pokes the thread.
+ *
+ * This will signal the thread, attempting to interrupt whatever it's currently
+ * doing.  This is *NOT* implemented on all platforms and may cause unresolved
+ * symbols during or VERR_NOT_IMPLEMENTED at runtime.
+ *
+ * @returns IPRT status code.
+ *
+ * @param   hThread             The thread to poke.  This must not be the
+ *                              calling thread.
+ */
+RTDECL(int) RTThreadPoke(RTTHREAD hThread);
 
 #ifdef IN_RING0

trunk/src/VBox/Runtime/r3/posix/thread-posix.cpp

@@ -61 +61 @@
 static void *rtThreadNativeMain(void *pvArgs);
 static void rtThreadKeyDestruct(void *pvValue);
-
+static void rtThreadPosixPokeSignal(int iSignal);
 
 int rtThreadNativeInit(void)
@@ -69 +69 @@
      * a threads RTTHREADINT structure.
      */
-
     int rc = pthread_key_create(&g_SelfKey, rtThreadKeyDestruct);
-    if (!rc)
-        return VINF_SUCCESS;
-    return VERR_NO_TLS_FOR_SELF;
+    if (rc)
+        return VERR_NO_TLS_FOR_SELF;
+
+    /*
+     * Register the dummy signal handler for RTThreadPoke.
+     */
+    void (*pfnOld)(int);
+    pfnOld = signal(SIGUSR2, rtThreadPosixPokeSignal);
+    Assert(pfnOld == SIG_DFL);
+    return rc;
 }
 
@@ -93 +99 @@
         pthread_setspecific(g_SelfKey, NULL);
     }
+}
+
+
+/**
+ * Dummy signal handler for the poke signal.
+ *
+ * @param   iSignal     The signal number.
+ */
+static void rtThreadPosixPokeSignal(int iSignal)
+{
+    Assert(iSignal == SIGUSR2);
+    NOREF(iSignal);
 }
 
@@ -277 +295 @@
 }
 
+
+RTDECL(int) RTThreadPoke(RTTHREAD hThread)
+{
+    AssertReturn(hThread != RTThreadSelf(), VERR_INVALID_PARAMETER);
+    PRTTHREADINT pThread = rtThreadGet(hThread);
+    AssertReturn(pThread, VERR_INVALID_HANDLE);
+
+    int rc = pthread_kill((pthread_t)(uintptr_t)pThread->Core.Key, SIGUSR2);
+
+    rtThreadRelease(pThread);
+    return RTErrConvertFromErrno(rc);
+}