[libvirt] [PATCH 2/2] parallels: login to parallels SDK

[Dmitry Guryanov]

Add files parallels_sdk.c and parallels_sdk.h for code
which works with SDK, so libvirt's code will not mix with
dealing with parallels SDK.

To use Parallels SDK you must first call PrlApi_InitEx function,
and then you will be able to connect to a server with
PrlSrv_LoginLocalEx function. When you've done you must call
PrlApi_Deinit. So let's call PrlApi_InitEx on first .connectOpen,
count number of connections and deinitialize, when this counter
becomes zero.

Signed-off-by: Dmitry Guryanov <dguryanov at parallels.com>
---
 po/POTFILES.in                   |  1 +
 src/Makefile.am                  |  4 +++-
 src/parallels/parallels_driver.c | 46 +++++++++++++++++++++++++++++++++++++++-
 src/parallels/parallels_utils.h  |  3 +++
 4 files changed, 52 insertions(+), 2 deletions(-)

diff --git a/po/POTFILES.in b/po/POTFILES.in
index f17b35f..4c1302d 100644
--- a/po/POTFILES.in
+++ b/po/POTFILES.in
@@ -96,6 +96,7 @@ src/openvz/openvz_driver.c
 src/openvz/openvz_util.c
 src/parallels/parallels_driver.c
 src/parallels/parallels_network.c
+src/parallels/parallels_sdk.c
 src/parallels/parallels_utils.c
 src/parallels/parallels_utils.h
 src/parallels/parallels_storage.c
diff --git a/src/Makefile.am b/src/Makefile.am
index dad7c7f..d4c6465 100644
--- a/src/Makefile.am
+++ b/src/Makefile.am
@@ -787,7 +787,9 @@ PARALLELS_DRIVER_SOURCES =					\
 		parallels/parallels_utils.c			\
 		parallels/parallels_utils.h			\
 		parallels/parallels_storage.c		\
-		parallels/parallels_network.c
+		parallels/parallels_network.c		\
+		parallels/parallels_sdk.h			\
+		parallels/parallels_sdk.c
 
 BHYVE_DRIVER_SOURCES =						\
 		bhyve/bhyve_capabilities.c			\
diff --git a/src/parallels/parallels_driver.c b/src/parallels/parallels_driver.c
index bb9538f..7dc9963 100644
--- a/src/parallels/parallels_driver.c
+++ b/src/parallels/parallels_driver.c
@@ -55,6 +55,7 @@
 
 #include "parallels_driver.h"
 #include "parallels_utils.h"
+#include "parallels_sdk.h"
 
 #define VIR_FROM_THIS VIR_FROM_PARALLELS
 
@@ -73,6 +74,9 @@ VIR_LOG_INIT("parallels.parallels_driver");
 
 #define IS_CT(def)  (STREQ_NULLABLE(def->os.type, "exe"))
 
+unsigned int numConns = 0;
+virMutex numConnsLock;
+
 static int parallelsConnectClose(virConnectPtr conn);
 
 static const char * parallelsGetDiskBusName(int bus) {
@@ -929,9 +933,25 @@ parallelsOpenDefault(virConnectPtr conn)
     if (virMutexInit(&privconn->lock) < 0) {
         virReportError(VIR_ERR_INTERNAL_ERROR, "%s",
                        _("cannot initialize mutex"));
-        goto error;
+        goto err_free;
     }
 
+    virMutexLock(&numConnsLock);
+    numConns++;
+
+    if (numConns == 1) {
+        if (prlsdkInit()) {
+            VIR_DEBUG("%s", _("Can't initialize Parallels SDK"));
+            virMutexUnlock(&numConnsLock);
+            goto err_free;
+        }
+    }
+
+    virMutexUnlock(&numConnsLock);
+
+    if (prlsdkConnect(privconn) < 0)
+        goto err_free;
+
     if (!(privconn->caps = parallelsBuildCapabilities()))
         goto error;
 
@@ -953,6 +973,9 @@ parallelsOpenDefault(virConnectPtr conn)
     virObjectUnref(privconn->domains);
     virObjectUnref(privconn->caps);
     virStoragePoolObjListFree(&privconn->pools);
+    prlsdkDisconnect(privconn);
+    prlsdkDeinit();
+ err_free:
     VIR_FREE(privconn);
     return VIR_DRV_OPEN_ERROR;
 }
@@ -999,8 +1022,17 @@ parallelsConnectClose(virConnectPtr conn)
     virObjectUnref(privconn->caps);
     virObjectUnref(privconn->xmlopt);
     virObjectUnref(privconn->domains);
+    prlsdkDisconnect(privconn);
     conn->privateData = NULL;
 
+    virMutexLock(&numConnsLock);
+    numConns--;
+
+    if (numConns == 0)
+        prlsdkDeinit();
+
+    virMutexUnlock(&numConnsLock);
+
     parallelsDriverUnlock(privconn);
     virMutexDestroy(&privconn->lock);
 
@@ -2453,6 +2485,12 @@ static virDriver parallelsDriver = {
     .connectIsAlive = parallelsConnectIsAlive, /* 1.2.5 */
 };
 
+static virStateDriver parallelsStateDriver = {
+	.name = "parallels",
+	.stateInitialize = parallelsStateInitialize,
+	.stateCleanup = parallelsStateCleanup,
+};
+
 /**
  * parallelsRegister:
  *
@@ -2471,6 +2509,12 @@ parallelsRegister(void)
 
     VIR_FREE(prlctl_path);
 
+    if (virMutexInit(&numConnsLock) < 0) {
+        virReportError(VIR_ERR_INTERNAL_ERROR, "%s",
+                       _("cannot initialize mutex"));
+        return 0;
+    }
+
     if (virRegisterDriver(&parallelsDriver) < 0)
         return -1;
     if (parallelsStorageRegister())
diff --git a/src/parallels/parallels_utils.h b/src/parallels/parallels_utils.h
index 599e2c5..095c104 100644
--- a/src/parallels/parallels_utils.h
+++ b/src/parallels/parallels_utils.h
@@ -23,6 +23,8 @@
 #ifndef PARALLELS_UTILS_H
 # define PARALLELS_UTILS_H
 
+# include <Parallels.h>
+
 # include "driver.h"
 # include "conf/domain_conf.h"
 # include "conf/storage_conf.h"
@@ -40,6 +42,7 @@
 struct _parallelsConn {
     virMutex lock;
     virDomainObjListPtr domains;
+    PRL_HANDLE server;
     virStoragePoolObjList pools;
     virNetworkObjList networks;
     virCapsPtr caps;
-- 
1.9.3