Changeset 92507 in vbox

Timestamp:

Nov 19, 2021 1:57:29 AM (3 years ago)

Author:

vboxsync

Message:

IPRT/thread: Added RTThreadControlPokeSignal to help deal with RTTHREADFLAGS_NO_SIGNALS in NEM/linux mode. bugref:9044

Location:

trunk

Files:

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

trunk/include/iprt/mangling.h

@@ -2512 +2512 @@
 # define RTThreadIsSelfKnown                            RT_MANGLER(RTThreadIsSelfKnown)
 # define RTThreadNativeSelf                             RT_MANGLER(RTThreadNativeSelf)
+# define RTThreadControlPokeSignal                      RT_MANGLER(RTThreadControlPokeSignal) /* not-win not-os2 */
 # define RTThreadPoke                                   RT_MANGLER(RTThreadPoke) /* not-win not-os2 */
 # define RTThreadPreemptDisable                         RT_MANGLER(RTThreadPreemptDisable)     /* r0drv */

trunk/include/iprt/thread.h

@@ -530 +530 @@
  */
 RTDECL(int) RTThreadPoke(RTTHREAD hThread);
+
+/**
+ * Controls the masking of the signal used by RTThreadPoke on posix systems.
+ *
+ * This function is not available on non-posix systems.
+ *
+ * @returns IPRT status code.
+ *
+ * @param   hThread     The current thread.
+ * @param   fEnable     Whether to enable poking (unblock) or to disable it
+ *                      (block the signal).
+ */
+RTDECL(int) RTThreadControlPokeSignal(RTTHREAD hThread, bool fEnable);
+
 
 # ifdef IN_RING0

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

@@ -641 +641 @@
 
 #ifdef RTTHREAD_POSIX_WITH_POKE
+
 RTDECL(int) RTThreadPoke(RTTHREAD hThread)
 {
@@ -659 +660 @@
     return rc;
 }
+
+
+RTDECL(int) RTThreadControlPokeSignal(RTTHREAD hThread, bool fEnable)
+{
+    AssertReturn(hThread == RTThreadSelf() && hThread != NIL_RTTHREAD, VERR_INVALID_PARAMETER);
+    int rc;
+    if (g_iSigPokeThread != -1)
+    {
+        sigset_t SigSet;
+        sigemptyset(&SigSet);
+        sigaddset(&SigSet, g_iSigPokeThread);
+
+        int rc2 = sigprocmask(fEnable ? SIG_UNBLOCK : SIG_BLOCK, &SigSet, NULL);
+        if (rc2 == 0)
+            rc = VINF_SUCCESS;
+        else
+        {
+            rc = RTErrConvertFromErrno(errno);
+            AssertMsgFailed(("rc=%Rrc errno=%d (rc2=%d)\n", rc, errno, rc2));
+        }
+    }
+    else
+        rc = VERR_NOT_SUPPORTED;
+    return rc;
+}
+
+
 #endif