Changeset 36233 in vbox for trunk/src/VBox/Runtime/r0drv/linux

Timestamp:

Mar 9, 2011 5:05:12 PM (14 years ago)

Author:

vboxsync

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

70454

Message:

IPRT: linux R0 threads

Location:

trunk/src/VBox/Runtime/r0drv/linux

Files:

• the-linux-kernel.h (modified) (2 diffs)
• thread2-r0drv-linux.c (modified) (1 diff)

trunk/src/VBox/Runtime/r0drv/linux/the-linux-kernel.h

@@ -119 +119 @@
 #include <asm/div64.h>
 
+#if LINUX_VERSION_CODE >= KERNEL_VERSION(2, 6, 0)
+# include <linux/kthread.h>
+#endif
+
 #if LINUX_VERSION_CODE < KERNEL_VERSION(2, 6, 0)
 # ifndef page_to_pfn
@@ -364 +368 @@
 #endif
 
-
-#endif
-
+#endif

trunk/src/VBox/Runtime/r0drv/linux/thread2-r0drv-linux.c

@@ -38 +38 @@
 
 
-/** @todo Later.
 RTDECL(RTTHREAD) RTThreadSelf(void)
 {
     return rtThreadGetByNative((RTNATIVETHREAD)current);
 }
-*/
 
+int rtThreadNativeInit(void)
+{
+    return VINF_SUCCESS;
+}
+
+int rtThreadNativeSetPriority(PRTTHREADINT pThread, RTTHREADTYPE enmType)
+{
+    int Priority = 0;
+    switch (enmType)
+    {
+        case RTTHREADTYPE_INFREQUENT_POLLER:    Priority = 9; break;
+        case RTTHREADTYPE_EMULATION:            Priority = 7; break;
+        case RTTHREADTYPE_DEFAULT:              Priority = 8; break;
+        case RTTHREADTYPE_MSG_PUMP:             Priority = 9; break;
+        case RTTHREADTYPE_IO:                   Priority = 10; break;
+        case RTTHREADTYPE_TIMER:                Priority = 11; break;
+
+        default:
+            AssertMsgFailed(("enmType=%d\n", enmType));
+            return VERR_INVALID_PARAMETER;
+    }
+    return VINF_SUCCESS;
+}
+
+int rtThreadNativeAdopt(PRTTHREADINT pThread)
+{
+    return VERR_NOT_IMPLEMENTED;
+}
+
+
+void rtThreadNativeDestroy(PRTTHREADINT pThread)
+{
+    NOREF(pThread);
+}
+
+/**
+ * Native kernel thread wrapper function.
+ *
+ * This will forward to rtThreadMain and do termination upon return.
+ *
+ * @param pvArg         Pointer to the argument package.
+ */
+static int rtThreadNativeMain(void *pvArg)
+{
+    PRTTHREADINT pThread = (PRTTHREADINT)pvArg;
+
+    rtThreadMain(pThread, (RTNATIVETHREAD)current, &pThread->szName[0]);
+    return 0;
+}
+
+
+int rtThreadNativeCreate(PRTTHREADINT pThreadInt, PRTNATIVETHREAD pNativeThread)
+{
+    struct task_struct *NativeThread;
+
+    RT_ASSERT_PREEMPTIBLE();
+
+    NativeThread = kthread_run(rtThreadNativeMain, pThreadInt, "%s", pThreadInt->szName);
+
+    if (IS_ERR(NativeThread))
+        return VERR_GENERAL_FAILURE;
+
+    *pNativeThread = (RTNATIVETHREAD)NativeThread;
+    return VINF_SUCCESS;
+}