Changeset 31728 in vbox for trunk/src/VBox/Main

Timestamp:

Aug 17, 2010 12:52:17 PM (14 years ago)

Author:

vboxsync

Message:

FT updates

File:

• trunk/src/VBox/Main/ConsoleImpl.cpp (modified) (6 diffs)

trunk/src/VBox/Main/ConsoleImpl.cpp

@@ -86 +86 @@
 #include <VBox/vusb.h>
 #include <VBox/mm.h>
+#include <VBox/ftm.h>
 #include <VBox/ssm.h>
 #include <VBox/version.h>
@@ -216 +217 @@
           mStartPaused(false),
           mTeleporterEnabled(FALSE),
-          mFaultToleranceSyncEnabled(FALSE)
+          mEnmFaultToleranceState(FaultToleranceState_Inactive)
     {}
 
@@ -224 +225 @@
     bool mStartPaused;
     BOOL mTeleporterEnabled;
-    BOOL mFaultToleranceSyncEnabled;
+    FaultToleranceState_T mEnmFaultToleranceState;
 
     /* array of progress objects for hard disk reset operations */
@@ -5293 +5294 @@
         task->mSavedStateFile = savedStateFile;
     task->mTeleporterEnabled = fTeleporterEnabled;
-    task->mFaultToleranceSyncEnabled = fFaultToleranceSyncEnabled;
+    task->mEnmFaultToleranceState = enmFaultToleranceState;
 
     /* Reset differencing hard disks for which autoReset is true,
@@ -7273 +7274 @@
          */
         if (    !task->mTeleporterEnabled
-            &&  !task->mFaultToleranceSyncEnabled)
+            &&  task->mEnmFaultToleranceState != FaultToleranceState_Target)
         {
             rc = console->mControl->LockMedia();
@@ -7455 +7456 @@
                     }
                 }
-                else if (task->mFaultToleranceSyncEnabled)
+                else if (task->mEnmFaultToleranceState != FaultToleranceState_Inactive)
                 {
-                    /** @todo */
-                    rc = E_NOTIMPL;
+                    /*
+                     * Get the config.
+                     */
+                    ULONG uPort;
+                    ULONG uInterval;
+                    Bstr bstrAddress;
+
+                    rc = pMachine->COMGETTER(FaultTolerancePort)(&uPort);
+                    if (SUCCEEDED(rc))
+                    {
+                        rc = pMachine->COMGETTER(FaultToleranceSyncInterval)(&uInterval);
+                        if (SUCCEEDED(rc))
+                            rc = pMachine->COMGETTER(FaultToleranceAddress)(bstrAddress.asOutParam());
+                    }
+                    if (SUCCEEDED(rc))
+                    {
+                        Utf8Str strAddress(bstrAddress);
+                        const char *pszAddress = strAddress.isEmpty() ? NULL : strAddress.c_str();
+
+                        /* Start FT syncing. */
+                        vrc = FTMR3PowerOn(pVM, (task->mEnmFaultToleranceState == FaultToleranceState_Source) /* fSource */, uInterval, pszAddress, uPort);
+                        AssertRC(vrc);
+                    }
                 }
                 else if (task->mStartPaused)