Changeset 13765 in vbox for trunk/src/VBox/VMM/VMReq.cpp

Timestamp:

Nov 3, 2008 5:20:11 PM (16 years ago)

Author:

vboxsync

Message:

VM request updates for dispatching packets to individual CPU threads.

File:

• trunk/src/VBox/VMM/VMReq.cpp (modified) (5 diffs)

trunk/src/VBox/VMM/VMReq.cpp

@@ -401 +401 @@
                     VERR_VM_REQUEST_INVALID_TYPE);
     AssertPtrReturn(ppReq, VERR_INVALID_POINTER);
+    AssertMsgReturn(enmDest == VMREQDEST_ALL || (unsigned)enmDest < pUVM->pVM->cCPUs, ("Invalid destination %d (max=%d)\n", enmDest, pUVM->pVM->cCPUs), VERR_INVALID_PARAMETER);
 
     /*
@@ -619 +620 @@
     int rc = VINF_SUCCESS;
     PUVM pUVM = ((VMREQ volatile *)pReq)->pUVM;                 /* volatile paranoia */
-    if (pUVM->vm.s.NativeThreadEMT != RTThreadNativeSelf())
+    if (    pReq->enmDest == VMREQDEST_ALL
+        &&  pUVM->vm.s.NativeThreadEMT != RTThreadNativeSelf())
     {
         unsigned fFlags = ((VMREQ volatile *)pReq)->fFlags;     /* volatile paranoia */
@@ -639 +641 @@
         if (pUVM->pVM)
             VM_FF_SET(pUVM->pVM, VM_FF_REQUEST);
+        VMR3NotifyFFU(pUVM, false);
+
+        /*
+         * Wait and return.
+         */
+        if (!(fFlags & VMREQFLAGS_NO_WAIT))
+            rc = VMR3ReqWait(pReq, cMillies);
+        LogFlow(("VMR3ReqQueue: returns %Vrc\n", rc));
+    }
+    else
+    if (    pReq->enmDest != VMREQDEST_ALL
+        &&  pUVM->aCpu[pReq->enmDest].vm.s.NativeThreadEMT != RTThreadNativeSelf())
+    {
+        RTCPUID  idTarget = (RTCPUID)pReq->enmDest;
+        unsigned fFlags = ((VMREQ volatile *)pReq)->fFlags;     /* volatile paranoia */
+
+        /*
+         * Insert it.
+         */
+        pReq->enmState = VMREQSTATE_QUEUED;
+        PVMREQ pNext;
+        do
+        {
+            pNext = pUVM->aCpu[idTarget].vm.s.pReqs;
+            pReq->pNext = pNext;
+        } while (!ASMAtomicCmpXchgPtr((void * volatile *)&pUVM->aCpu[idTarget].vm.s.pReqs, (void *)pReq, (void *)pNext));
+
+        /*
+         * Notify EMT.
+         */
+        if (pUVM->pVM)
+            VMCPU_FF_SET(pUVM->pVM, VM_FF_REQUEST, idTarget);
+        /* @todo: VMR3NotifyFFU*/
+        AssertFailed();
         VMR3NotifyFFU(pUVM, false);
 
@@ -735 +771 @@
  *
  * @param   pUVM            Pointer to the user mode VM structure.
- */
-VMMR3DECL(int) VMR3ReqProcessU(PUVM pUVM)
-{
-    LogFlow(("VMR3ReqProcessU: (enmVMState=%d)\n", pUVM->pVM ? pUVM->pVM->enmVMState : VMSTATE_CREATING));
+ * @param   enmDest         Destination of the request packet (global or per VCPU).
+ */
+VMMR3DECL(int) VMR3ReqProcessU(PUVM pUVM, VMREQDEST enmDest)
+{
+    LogFlow(("VMR3ReqProcessU: (enmVMState=%d) enmDest=%d\n", pUVM->pVM ? pUVM->pVM->enmVMState : VMSTATE_CREATING, enmDest));
 
     /*
@@ -749 +786 @@
     while (rc <= VINF_SUCCESS)
     {
+        void *volatile *ppReqs;
+
         /*
          * Get pending requests.
          */
-        if (RT_LIKELY(pUVM->pVM))
-            VM_FF_CLEAR(pUVM->pVM, VM_FF_REQUEST);
-        PVMREQ pReqs = (PVMREQ)ASMAtomicXchgPtr((void * volatile *)&pUVM->vm.s.pReqs, NULL);
+        if (enmDest == VMREQDEST_ALL)
+        {
+            ppReqs = (void * volatile *)&pUVM->vm.s.pReqs;
+            if (RT_LIKELY(pUVM->pVM))
+                VM_FF_CLEAR(pUVM->pVM, VM_FF_REQUEST);
+        }
+        else
+        {
+            ppReqs = (void * volatile *)&pUVM->aCpu[enmDest].vm.s.pReqs;
+            if (RT_LIKELY(pUVM->pVM))
+                VMCPU_FF_CLEAR(pUVM->pVM, enmDest, VM_FF_REQUEST);
+        }
+
+        PVMREQ pReqs = (PVMREQ)ASMAtomicXchgPtr(ppReqs, NULL);
         if (!pReqs)
             break;