Changeset 31737 in vbox for trunk/src/VBox/VMM/FTM.cpp

Timestamp:

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

Author:

vboxsync

Message:

FT updates

File:

• trunk/src/VBox/VMM/FTM.cpp (modified) (3 diffs)

trunk/src/VBox/VMM/FTM.cpp

@@ -21 +21 @@
 *******************************************************************************/
 #define LOG_GROUP LOG_GROUP_FTM
+#include "FTMInternal.h"
+#include <VBox/vm.h>
 #include <VBox/vmm.h>
-#include <VBox/vm.h>
 #include <VBox/err.h>
 #include <VBox/param.h>
-#include "FTMInternal.h"
+#include <VBox/ssm.h>
 
 #include <iprt/assert.h>
+#include <iprt/thread.h>
+#include <iprt/string.h>
+#include <iprt/mem.h>
 #include <VBox/log.h>
 
+/**
+ * Initializes the FTM.
+ *
+ * @returns VBox status code.
+ * @param   pVM         The VM to operate on.
+ */
+VMMR3DECL(int) FTMR3Init(PVM pVM)
+{
+    /** @todo saved state for master nodes! */
+    pVM->ftm.s.pszAddress     = NULL;
+    pVM->fFaultTolerantMaster = false;
+    return VINF_SUCCESS;
+}
+
+/**
+ * Terminates the FTM.
+ *
+ * Termination means cleaning up and freeing all resources,
+ * the VM it self is at this point powered off or suspended.
+ *
+ * @returns VBox status code.
+ * @param   pVM         The VM to operate on.
+ */
+VMMR3DECL(int) FTMR3Term(PVM pVM)
+{
+    if (pVM->ftm.s.pszAddress)
+        RTMemFree(pVM->ftm.s.pszAddress);
+
+    return VINF_SUCCESS;
+}
+
+/**
+ * Thread function which starts syncing process for this master VM
+ *
+ * @param   Thread      The thread id.
+ * @param   pvUser      Not used
+ * @return  VINF_SUCCESS (ignored).
+ *
+ * @note Locks the Console object for writing.
+ */
+static DECLCALLBACK(int) ftmR3MasterThread(RTTHREAD Thread, void *pvUser)
+{
+    return VINF_SUCCESS;
+}
 
 /**
@@ -48 +96 @@
 VMMR3DECL(int) FTMR3PowerOn(PVM pVM, bool fMaster, unsigned uInterval, const char *pszAddress, unsigned uPort)
 {
+    int rc;
+
     VMSTATE enmVMState = VMR3GetState(pVM);
     AssertMsgReturn(enmVMState == VMSTATE_POWERING_ON,
@@ -53 +103 @@
                     VERR_INTERNAL_ERROR_4);
 
+    pVM->ftm.s.uInterval  = uInterval;
+    pVM->ftm.s.uPort      = uPort;
+    pVM->ftm.s.pszAddress = RTStrDup(pszAddress);
     if (fMaster)
     {
+        rc = RTThreadCreate(NULL, ftmR3MasterThread, NULL,
+                            0, RTTHREADTYPE_IO /* higher than normal priority */, 0, "ftmR3MasterThread");
+        if (RT_FAILURE(rc))
+            return rc;
+
+        pVM->fFaultTolerantMaster = true;
         return VMR3PowerOn(pVM);
     }