Updating for PIP

Author: stephendiadamo

build/lib/backends/eqsn_backend.py

@@ -1,4 +1,4 @@
-import eqsn
+from eqsn import EQSN
 import uuid
 from objects.qubit import Qubit
 import threading
@@ -117,6 +117,7 @@ def __init__(self):
         self._hosts = EQSNBackend.Hosts.get_instance()
         # keys are from : to, where from is the host calling create EPR
         self._entaglement_qubits = EQSNBackend.EntanglementIDs.get_instance()
+        self.eqsn = EQSN()
 
     def start(self, **kwargs):
         """
@@ -129,7 +130,7 @@ def stop(self):
         """
         Stops Backends which are running in an own thread or process.
         """
-        eqsn.stop_all()
+        self.eqsn.stop_all()
 
     def add_host(self, host):
         """
@@ -151,7 +152,7 @@ def create_qubit(self, host_id):
             Qubit of backend type.
         """
         id = str(uuid.uuid4())
-        eqsn.new_qubit(id)
+        self.eqsn.new_qubit(id)
         return id
 
     def send_qubit_to(self, qubit, from_host_id, to_host_id):
@@ -183,10 +184,10 @@ def create_EPR(self, host_a_id, host_b_id, q_id=None, block=False):
         uid2 = uuid.uuid4()
         host_a = self._hosts.get_from_dict(host_a_id)
         host_b = self._hosts.get_from_dict(host_b_id)
-        eqsn.new_qubit(uid1)
-        eqsn.new_qubit(uid2)
-        eqsn.H_gate(uid1)
-        eqsn.cnot_gate(uid2, uid1)
+        self.eqsn.new_qubit(uid1)
+        self.eqsn.new_qubit(uid2)
+        self.eqsn.H_gate(uid1)
+        self.eqsn.cnot_gate(uid2, uid1)
         q1 = Qubit(host_a, qubit=uid1, q_id=q_id, blocked=block)
         q2 = Qubit(host_b, qubit=uid2, q_id=q1.id, blocked=block)
         self.store_ent_pair(host_a.host_id, host_b.host_id, q2)
@@ -245,7 +246,7 @@ def X(self, qubit):
         Args:
             qubit (Qubit): Qubit on which gate should be applied to.
         """
-        eqsn.X_gate(qubit.qubit)
+        self.eqsn.X_gate(qubit.qubit)
 
     def Y(self, qubit):
         """
@@ -254,7 +255,7 @@ def Y(self, qubit):
         Args:
             qubit (Qubit): Qubit on which gate should be applied to.
         """
-        eqsn.Y_gate(qubit.qubit)
+        self.eqsn.Y_gate(qubit.qubit)
 
     def Z(self, qubit):
         """
@@ -263,7 +264,7 @@ def Z(self, qubit):
         Args:
             qubit (Qubit): Qubit on which gate should be applied to.
         """
-        eqsn.Z_gate(qubit.qubit)
+        self.eqsn.Z_gate(qubit.qubit)
 
     def H(self, qubit):
         """
@@ -272,7 +273,7 @@ def H(self, qubit):
         Args:
             qubit (Qubit): Qubit on which gate should be applied to.
         """
-        eqsn.H_gate(qubit.qubit)
+        self.eqsn.H_gate(qubit.qubit)
 
     def K(self, qubit):
         """
@@ -281,7 +282,7 @@ def K(self, qubit):
         Args:
             qubit (Qubit): Qubit on which gate should be applied to.
         """
-        eqsn.K_gate(qubit.qubit)
+        self.eqsn.K_gate(qubit.qubit)
 
     def S(self, qubit):
         """
@@ -290,7 +291,7 @@ def S(self, qubit):
         Args:
             qubit (Qubit): Qubit on which gate should be applied to.
         """
-        eqsn.S_gate(qubit.qubit)
+        self.eqsn.S_gate(qubit.qubit)
 
     def T(self, qubit):
         """
@@ -299,7 +300,7 @@ def T(self, qubit):
         Args:
             qubit (Qubit): Qubit on which gate should be applied to.
         """
-        eqsn.T_gate(qubit.qubit)
+        self.eqsn.T_gate(qubit.qubit)
 
     def rx(self, qubit, phi):
         """
@@ -309,7 +310,7 @@ def rx(self, qubit, phi):
             qubit (Qubit): Qubit on which gate should be applied to.
             phi (float): Amount of roation in Rad.
         """
-        eqsn.RX_gate(qubit.qubit, phi)
+        self.eqsn.RX_gate(qubit.qubit, phi)
 
     def ry(self, qubit, phi):
         """
@@ -319,7 +320,7 @@ def ry(self, qubit, phi):
             qubit (Qubit): Qubit on which gate should be applied to.
             phi (float): Amount of roation in Rad.
         """
-        eqsn.RY_gate(qubit.qubit, phi)
+        self.eqsn.RY_gate(qubit.qubit, phi)
 
     def rz(self, qubit, phi):
         """
@@ -329,7 +330,7 @@ def rz(self, qubit, phi):
             qubit (Qubit): Qubit on which gate should be applied to.
             phi (float): Amount of roation in Rad.
         """
-        eqsn.RZ_gate(qubit.qubit, phi)
+        self.eqsn.RZ_gate(qubit.qubit, phi)
 
     def cnot(self, qubit, target):
         """
@@ -339,7 +340,7 @@ def cnot(self, qubit, target):
             qubit (Qubit): Qubit to control cnot.
             target (Qubit): Qubit on which the cnot gate should be applied.
         """
-        eqsn.cnot_gate(target.qubit, qubit.qubit)
+        self.eqsn.cnot_gate(target.qubit, qubit.qubit)
 
     def cphase(self, qubit, target):
         """
@@ -349,7 +350,7 @@ def cphase(self, qubit, target):
             qubit (Qubit): Qubit to control cphase.
             target (Qubit): Qubit on which the cphase gate should be applied.
         """
-        eqsn.cphase_gate(target.qubit, qubit.qubit)
+        self.eqsn.cphase_gate(target.qubit, qubit.qubit)
 
     def measure(self, qubit, non_destructive):
         """
@@ -362,7 +363,7 @@ def measure(self, qubit, non_destructive):
         Returns:
             The value which has been measured.
         """
-        return eqsn.measure(qubit.qubit, non_destructive)
+        return self.eqsn.measure(qubit.qubit, non_destructive)
 
     def release(self, qubit):
         """
@@ -371,4 +372,4 @@ def release(self, qubit):
         Args:
             qubit (Qubit): The qubit which should be released.
         """
-        eqsn.measure(qubit.qubit)
+        self.eqsn.measure(qubit.qubit)

build/lib/components/host.py

@@ -7,7 +7,7 @@
 from objects.quantum_storage import QuantumStorage
 from objects.classical_storage import ClassicalStorage
 from objects.message import Message
-from backends.cqc_backend import CQCBackend
+from backends.eqsn_backend import EQSNBackend
 import uuid
 import time
 
@@ -35,7 +35,7 @@ def __init__(self, host_id, backend=None):
         self._classical_connections = []
         self._quantum_connections = []
         if backend is None:
-            self._backend = CQCBackend()
+            self._backend = EQSNBackend()
         else:
             self._backend = backend
         # add this host to the backend
@@ -359,6 +359,19 @@ def get_sequence_number(self, host):
 
         return self._seq_number_sender[host]
 
+    def get_sequence_number_receiver(self, host):
+
+        '''
+
+        :param host:
+        :return:
+        '''
+
+        if host not in self._seq_number_receiver:
+            return 0
+
+        return self._seq_number_receiver[host][1]
+
     def _get_message_w_seq_num(self, sender_id, seq_num, wait=-1):
         """
         Get a message from a sender with a specific sequence number.
@@ -476,8 +489,7 @@ def check_task(q, _sender, _seq_num, timeout, start_time):
                 expected_seq += 1
         elif seq_num > expected_seq:
             self._seq_number_sender_ack[sender][0].append(seq_num)
-        else:
-            raise Exception("Should never happen!")
+
         for t in self._ack_receiver_queue:
             res = check_task(*t)
             if res is True:
@@ -1118,7 +1130,7 @@ def add_checksum(self, qubits, size_per_qubit=2):
         i = 0
         check_qubits = []
         while i < len(qubits):
-            check = Qubit(self.host_id)
+            check = Qubit(self)
             j = 0
             while j < size_per_qubit:
                 qubits[i + j].cnot(check)

build/lib/components/network.py

@@ -13,7 +13,7 @@
 
 from objects.packet import Packet
 from objects.routing_packet import RoutingPacket
-from backends.cqc_backend import CQCBackend
+from backends.eqsn_backend import EQSNBackend
 
 
 # Network singleton
@@ -614,17 +614,16 @@ def stop(self, stop_hosts=False):
             self._stop_thread = True
             if self._backend is not None:
                 self._backend.stop()
-        except Exception:
-            Logger.get_instance().error("Network stopped with errors")
+        except Exception as e:
+            Logger.get_instance().error(e)
 
     def start(self, nodes=None, backend=None):
         """
         Starts the network.
 
         """
         if backend is None:
-            self._backend = CQCBackend()
-            self.use_ent_swap = True
+            self._backend = EQSNBackend()
         else:
             self._backend = backend
         if nodes is not None:

build/lib/objects/logger.py

@@ -4,7 +4,7 @@
 logging.basicConfig(format=FORMAT)
 
 
-class Logger:
+class Logger():
     __instance = None
     DISABLED = True
 

dist/qunetsim-0.0.10-py3-none-any.whl

@@ -113,24 +113,21 @@ def referee(ref, alice_id, bob_id):
 def main():
     network = Network.get_instance()
 
-    backend = ProjectQBackend()
-    # backend = EQSNBackend()
-
     nodes = ['A', 'B', 'C']
     network.delay = 0.1
-    network.start(nodes, backend)
+    network.start(nodes)
 
-    host_A = Host('A', backend)
+    host_A = Host('A')
     host_A.add_c_connection('C')
     host_A.delay = 0
     host_A.start()
 
-    host_B = Host('B', backend)
+    host_B = Host('B')
     host_B.add_c_connection('C')
     host_B.delay = 0
     host_B.start()
 
-    host_C = Host('C', backend)
+    host_C = Host('C')
     host_C.add_c_connections(['A', 'B'])
     host_C.delay = 0
     host_C.start()

dist/qunetsim-0.0.10.tar.gz

@@ -1,36 +1,34 @@
 from components.host import Host
 from components.network import Network
 from objects.logger import Logger
-from backends.projectq_backend import ProjectQBackend
 
-Logger.DISABLED = False
+Logger.DISABLED = True
 
 
 def main():
     network = Network.get_instance()
     nodes = ["Alice", "Bob", "Eve", "Dean"]
-    back = ProjectQBackend()
-    network.start(nodes, back)
+    network.start(nodes)
 
     network.delay = 0.1
 
-    host_alice = Host('Alice', back)
+    host_alice = Host('Alice')
     host_alice.add_connection('Bob')
     host_alice.add_connection('Eve')
     host_alice.start()
 
-    host_bob = Host('Bob', back)
+    host_bob = Host('Bob')
     host_bob.add_connection('Alice')
     host_bob.add_connection('Eve')
     host_bob.start()
 
-    host_eve = Host('Eve', back)
+    host_eve = Host('Eve')
     host_eve.add_connection('Bob')
     host_eve.add_connection('Dean')
     host_eve.add_connection('Alice')
     host_eve.start()
 
-    host_dean = Host('Dean', back)
+    host_dean = Host('Dean')
     host_dean.add_connection('Eve')
     host_dean.start()
 
@@ -40,30 +38,31 @@ def main():
     network.add_host(host_dean)
 
     share_list = ["Bob", "Eve", "Dean"]
-    q_id1, ack_received = host_alice.send_ghz(share_list, await_ack=True)
-
-    print("Alice received ACK from all? " + str(ack_received))
-
-    q1 = host_alice.get_ghz('Alice', q_id1, wait=10)
-    q2 = host_bob.get_ghz('Alice', q_id1, wait=10)
-    q3 = host_eve.get_ghz('Alice', q_id1, wait=10)
-    q4 = host_dean.get_ghz('Alice', q_id1, wait=10)
-
-    if q1 is None:
-        raise ValueError("Q1 is none")
-    if q2 is None:
-        raise ValueError("Q2 is none")
-    if q3 is None:
-        raise ValueError("Q3 is none")
-    if q4 is None:
-        raise ValueError("Q4 is none")
-
-    m1 = q1.measure()
-    m2 = q2.measure()
-    m3 = q3.measure()
-    m4 = q4.measure()
-
-    print("results of measurements are %d, %d, %d, and %d." % (m1, m2, m3, m4))
+    for _ in range(10):
+        q_id1, ack_received = host_alice.send_ghz(share_list, await_ack=True)
+
+        print("Alice received ACK from all? " + str(ack_received))
+
+        q1 = host_alice.get_ghz('Alice', q_id1, wait=10)
+        q2 = host_bob.get_ghz('Alice', q_id1, wait=10)
+        q3 = host_eve.get_ghz('Alice', q_id1, wait=10)
+        q4 = host_dean.get_ghz('Alice', q_id1, wait=10)
+
+        if q1 is None:
+            raise ValueError("Q1 is none")
+        if q2 is None:
+            raise ValueError("Q2 is none")
+        if q3 is None:
+            raise ValueError("Q3 is none")
+        if q4 is None:
+            raise ValueError("Q4 is none")
+
+        m1 = q1.measure()
+        m2 = q2.measure()
+        m3 = q3.measure()
+        m4 = q4.measure()
+
+        print("results of measurements are %d, %d, %d, and %d." % (m1, m2, m3, m4))
 
     network.stop(True)
     exit()