Added to this branch

Author: StephanieWehner

examples/nativeMode/corrRNG/README.txt

@@ -10,3 +10,12 @@ Bob proceeds to recover the teleported qubit.
 
 In this example, we simply print out the initial state to be teleported, as well as the final state received by
 Bob to check whether the teleportation worked correctly.
+
+
+To start run:
+- simulaqron start --nodes=Alice,Bob --keep
+
+sh run.sh
+
+To terminate run:
+sh terminate.sh

examples/nativeMode/corrRNG/aliceTest.py

@@ -115,31 +115,24 @@ def remote_test(self):
 #
 def main():
 
-    # In this example, we are Alice.
-    myName = "Alice"
+    myName = "Alice" # we are Alice
 
     # This file defines the network of virtual quantum nodes
-    network_file = simulaqron_settings.network_config_file
+    virtualNet = SocketsConfig(str(simulaqron_settings.network_config_file), network_name="default", config_type="vnode")
 
-    # This file defines the nodes acting as servers in the classical communication network
-    classicalFile = "classicalNet.cfg"
+    # This file defines the network used for classical communication
+    classicalNet = SocketsConfig("classicalNet.json", network_name="default", config_type="app")
 
-    # Read configuration files for the virtual quantum, as well as the classical network
-    virtualNet = SocketsConfig(network_file)
-    classicalNet = SocketsConfig(classicalFile)
-
-    # Check if we should run a local classical server. If so, initialize the code
-    # to handle remote connections on the classical communication network
+   # Check if we should run a server (if this node is listed in classicalNet)
     if myName in classicalNet.hostDict:
-        lNode = localNode(classicalNet.hostDict[myName], classicalNet)
+        # Create the local classical server
+        logging.debug("LOCAL %s: Creating classical server.", myName)
+        myNode = localNode(virtualNet.hostDict[myName], classicalNet)
     else:
-        lNode = None
-
-        # Set up the local classical server if applicable, and connect to the virtual
-        # node and other classical servers. Once all connections are set up, this will
-        # execute the function runClientNode
-    setup_local(myName, virtualNet, classicalNet, lNode, runClientNode)
+        myNode = None
 
+	# Connect and run
+    setup_local(myName, virtualNet, classicalNet, myNode, runClientNode)
 
 ##################################################################################################
 logging.basicConfig(format="%(asctime)s:%(levelname)s:%(message)s", level=logging.DEBUG)

examples/nativeMode/corrRNG/bobTest.py

@@ -36,6 +36,8 @@
 from twisted.internet.defer import inlineCallbacks
 from twisted.spread import pb
 
+from qutip import Qobj
+
 
 #####################################################################################################
 #
@@ -103,6 +105,18 @@ def remote_process_qubit(self, virtualNum):
 
         print("BOB: My Random Number is ", x, "\n")
 
+    def assemble_qubit(self, realM, imagM):
+        """
+        Reconstitute the qubit as a qutip object from its real and imaginary components given as a list.
+        We need this since Twisted PB does not support sending complex valued object natively.
+        """
+        M = realM
+        for s in range(len(M)):
+            for t in range(len(M)):
+                M[s][t] = realM[s][t] + 1j * imagM[s][t]
+
+        return Qobj(M)
+
 
 #####################################################################################################
 #
@@ -113,27 +127,25 @@ def main():
     # In this example, we are Bob.
     myName = "Bob"
 
-    # This file defines the network of virtual quantum nodes
-    network_file = simulaqron_settings.network_config_file
 
-    # This file defines the nodes acting as servers in the classical communication network
-    classicalFile = "classicalNet.cfg"
+    logging.basicConfig(format='%(asctime)s:%(levelname)s:%(message)s', level=logging.DEBUG)
+
+    # This file defines the network of virtual quantum nodes
+    virtualNet = SocketsConfig(str(simulaqron_settings.network_config_file), network_name="default", config_type="vnode")
 
-    # Read configuration files for the virtual quantum, as well as the classical network
-    virtualNet = SocketsConfig(network_file)
-    classicalNet = SocketsConfig(classicalFile)
+    # This file defines the network used for classical communication
+    classicalNet = SocketsConfig("classicalNet.json", network_name="default", config_type="app")
 
-    # Check if we should run a local classical server. If so, initialize the code
-    # to handle remote connections on the classical communication network
+   # Check if we should run a server (if this node is listed in classicalNet)
     if myName in classicalNet.hostDict:
-        lNode = localNode(classicalNet.hostDict[myName], classicalNet)
+        # Create the local classical server
+        myNode = localNode(virtualNet.hostDict[myName], classicalNet)
     else:
-        lNode = None
+        myNode = None
+
+    # Connect and run
+    setup_local(myName, virtualNet, classicalNet, myNode, runClientNode)
 
-        # Set up the local classical server if applicable, and connect to the virtual
-        # node and other classical servers. Once all connections are set up, this will
-        # execute the function runClientNode
-    setup_local(myName, virtualNet, classicalNet, lNode, runClientNode)
 
 
 ##################################################################################################

examples/nativeMode/corrRNG/classicalNet.json

@@ -0,0 +1,17 @@
+{
+    "default": {
+        "nodes": {
+            "Alice": {
+                "app_socket": ["localhost", 8821],
+                "qnodeos_socket": ["localhost", 8822],
+                "vnode_socket": ["localhost", 8823]
+            },
+            "Bob": {
+                "app_socket": ["localhost", 8831],
+                "qnodeos_socket": ["localhost", 8832],
+                "vnode_socket": ["localhost", 8833]
+            }
+        },
+        "topology": null
+    }
+}

examples/nativeMode/corrRNG/run.sh

@@ -1,5 +1,10 @@
 #!/bin/sh
 
+# Check if SimulaQron is already running
+if [ ! -f ~/.simulaqron_pids/simulaqron_network_default.pid ]; then
+    simulaqron start --nodes=Alice,Bob --force
+fi
+
 python3 bobTest.py &
 python3 aliceTest.py
 

examples/nativeMode/corrRNG/terminate.sh

@@ -0,0 +1,12 @@
+#!/usr/bin/env sh
+TEST_PIDS=$(ps aux | grep python | grep -E "Test" | awk {'print $2'})
+if [ "$TEST_PIDS" != "" ]
+then
+        kill -9 $TEST_PIDS
+fi
+
+# Check if SimulaQron is running
+if [ -f ~/.simulaqron_pids/simulaqron_network_default.pid ]; then
+    cat $HOME/.simulaqron_pids/simulaqron_network_default.pid | xargs kill -9 
+fi
+