qns.entity package

Subpackages

• qns.entity.cchannel package
  • Submodules
  • qns.entity.cchannel.cchannel module
    • ClassicChannel
      • ClassicChannel.install()
      • ClassicChannel.send()
    • ClassicPacket
      • ClassicPacket.encode()
      • ClassicPacket.get()
    • NextHopNotConnectionException
    • RecvClassicPacket
      • RecvClassicPacket.invoke()
  • Module contents
    • ClassicChannel
      • ClassicChannel.install()
      • ClassicChannel.send()
    • ClassicPacket
      • ClassicPacket.encode()
      • ClassicPacket.get()
    • RecvClassicPacket
      • RecvClassicPacket.invoke()
• qns.entity.memory package
  • Submodules
  • qns.entity.memory.event module
    • MemoryReadRequestEvent
      • MemoryReadRequestEvent.invoke()
    • MemoryReadResponseEvent
      • MemoryReadResponseEvent.invoke()
    • MemoryWriteRequestEvent
      • MemoryWriteRequestEvent.invoke()
    • MemoryWriteResponseEvent
      • MemoryWriteResponseEvent.invoke()
  • qns.entity.memory.memory module
    • OutOfMemoryException
    • QuantumMemory
      • QuantumMemory.count
      • QuantumMemory.get()
      • QuantumMemory.get_store_time()
      • QuantumMemory.handle()
      • QuantumMemory.install()
      • QuantumMemory.is_full()
      • QuantumMemory.read()
      • QuantumMemory.write()
  • Module contents
    • MemoryReadRequestEvent
      • MemoryReadRequestEvent.invoke()
    • MemoryReadResponseEvent
      • MemoryReadResponseEvent.invoke()
    • MemoryWriteRequestEvent
      • MemoryWriteRequestEvent.invoke()
    • MemoryWriteResponseEvent
      • MemoryWriteResponseEvent.invoke()
    • QuantumMemory
      • QuantumMemory.count
      • QuantumMemory.get()
      • QuantumMemory.get_store_time()
      • QuantumMemory.handle()
      • QuantumMemory.install()
      • QuantumMemory.is_full()
      • QuantumMemory.read()
      • QuantumMemory.write()
• qns.entity.monitor package
  • Submodules
  • qns.entity.monitor.monitor module
    • Monitor
      • Monitor.add_attribution()
      • Monitor.at_event()
      • Monitor.at_finish()
      • Monitor.at_period()
      • Monitor.at_start()
      • Monitor.calculate_date()
      • Monitor.get_date()
      • Monitor.handle()
      • Monitor.install()
    • MonitorEvent
      • MonitorEvent.invoke()
  • Module contents
    • Monitor
      • Monitor.add_attribution()
      • Monitor.at_event()
      • Monitor.at_finish()
      • Monitor.at_period()
      • Monitor.at_start()
      • Monitor.calculate_date()
      • Monitor.get_date()
      • Monitor.handle()
      • Monitor.install()
    • MonitorEvent
      • MonitorEvent.invoke()
• qns.entity.node package
  • Submodules
  • qns.entity.node.app module
    • Application
      • Application.add_handler()
      • Application.get_node()
      • Application.get_simulator()
      • Application.handle()
      • Application.install()
  • qns.entity.node.node module
    • QNode
      • QNode.add_apps()
      • QNode.add_cchannel()
      • QNode.add_memory()
      • QNode.add_network()
      • QNode.add_operator()
      • QNode.add_qchannel()
      • QNode.add_request()
      • QNode.clear_request()
      • QNode.get_apps()
      • QNode.get_cchannel()
      • QNode.get_memory()
      • QNode.get_qchannel()
      • QNode.handle()
      • QNode.install()
  • Module contents
    • Application
      • Application.add_handler()
      • Application.get_node()
      • Application.get_simulator()
      • Application.handle()
      • Application.install()
    • QNode
      • QNode.add_apps()
      • QNode.add_cchannel()
      • QNode.add_memory()
      • QNode.add_network()
      • QNode.add_operator()
      • QNode.add_qchannel()
      • QNode.add_request()
      • QNode.clear_request()
      • QNode.get_apps()
      • QNode.get_cchannel()
      • QNode.get_memory()
      • QNode.get_qchannel()
      • QNode.handle()
      • QNode.install()
• qns.entity.operator package
  • Submodules
  • qns.entity.operator.event module
    • OperateRequestEvent
      • OperateRequestEvent.invoke()
    • OperateResponseEvent
      • OperateResponseEvent.invoke()
  • qns.entity.operator.operator module
    • QuantumOperator
      • QuantumOperator.handle()
      • QuantumOperator.install()
      • QuantumOperator.operate()
      • QuantumOperator.set_own()
  • qns.entity.operator.operator module
    • QuantumOperator
      • QuantumOperator.handle()
      • QuantumOperator.install()
      • QuantumOperator.operate()
      • QuantumOperator.set_own()
  • Module contents
    • OperateRequestEvent
      • OperateRequestEvent.invoke()
    • OperateResponseEvent
      • OperateResponseEvent.invoke()
    • QuantumOperator
      • QuantumOperator.handle()
      • QuantumOperator.install()
      • QuantumOperator.operate()
      • QuantumOperator.set_own()
• qns.entity.qchannel package
  • Submodules
  • qns.entity.qchannel.losschannel module
    • QubitLossChannel
  • qns.entity.qchannel.qchannel module
    • NextHopNotConnectionException
    • QuantumChannel
      • QuantumChannel.install()
      • QuantumChannel.send()
    • RecvQubitPacket
      • RecvQubitPacket.invoke()
  • Module contents
    • Link_Decoherence_QuantumChannel
      • Link_Decoherence_QuantumChannel.create_entanglement_pool()
      • Link_Decoherence_QuantumChannel.find_fidlity_index()
      • Link_Decoherence_QuantumChannel.find_max_min_fidelity()
      • Link_Decoherence_QuantumChannel.remove_entanglement_by_fidelity()
      • Link_Decoherence_QuantumChannel.remove_entanglement_by_index()
    • QuantumChannel
      • QuantumChannel.install()
      • QuantumChannel.send()
    • QubitLossChannel
    • RecvQubitPacket
      • RecvQubitPacket.invoke()
• qns.entity.timer package
  • Submodules
  • qns.entity.timer.timer module
    • Timer
      • Timer.install()
      • Timer.trigger()
    • TimerEvent
      • TimerEvent.invoke()
  • Module contents
    • Timer
      • Timer.install()
      • Timer.trigger()

Submodules

qns.entity.entity module

class qns.entity.entity.Entity(name: str = None)

Bases: object

This is the basic entity class, including memories, channels and nodes.

handle(event: Event) → None

handle is called to process an receiving Event.

Parameters:

event (qns.simulator.event.Event) – the event that send to this entity

install(simulator: Simulator) → None

install is called before simulator runs to initialize or set initial events

Parameters:

simulator (qns.simulator.simulator.Simulator) – the simulator

Module contents

class qns.entity.Application

Bases: object

Application can be deployed on the quantum nodes.

add_handler(handler, EventTypeList: List = [], ByList: List = [])

Add a handler function to the dispather.

Parameters:

• handler – The handler to process the event. It is an object method whose function signature is the same to handle function.

• EventTypeList – a list of Event Class Type. An empty list meaning to match all events.

• ByList – a list of Entities, QNodes or Applications, that generates this event. An empty list meaning to match all entities.

get_node()

get the node that runs this application

Returns:

the quantum node

get_simulator()

get the simulator

Returns:

the simulator

handle(node, event: Event) → bool | None

process the event on the node.

Parameters:

• node (QNode) – the node that will handle this event

• event (Event) – the event

Returns:

if skip is True, further applications will not handle this event

Return type:

skip (bool, None)

install(node, simulator: Simulator)

install initial events for this QNode

Parameters:

• node (QNode) – the node that will handle this event

• simulator (Simulator) – the simulator

class qns.entity.ClassicChannel(name: str = None, node_list: List[QNode] = [], bandwidth: int = 0, delay: float | DelayModel = 0, length: float | None = 0, drop_rate: float = 0, max_buffer_size: int = 0)

Bases: Entity

ClassicChannel is the channel for classic message

install(simulator: Simulator) → None

install is called before simulator runs to initialize or set initial events

Parameters:

simulator (qns.simulator.simulator.Simulator) – the simulator

send(packet: ClassicPacket, next_hop: QNode)

Send a classic packet to the next_hop

Parameters:

• packet (ClassicPacket) – the packet

• next_hop (QNode) – the next hop QNode

Raises:

qns.entity.cchannel.cchannel.NextHopNotConnectionException – the next_hop is not connected to this channel

class qns.entity.ClassicPacket(msg: str | bytes | Any, src: QNode = None, dest: QNode = None)

Bases: object

ClassicPacket is the message that transfer on a ClassicChannel

encode() → bytes

encode the self.msg if it is a str

Returns:

(bytes) a bytes object

get()

get the message from packet

Returns:

(Union[str, bytes, Any])

class qns.entity.Entity(name: str = None)

Bases: object

This is the basic entity class, including memories, channels and nodes.

handle(event: Event) → None

handle is called to process an receiving Event.

Parameters:

event (qns.simulator.event.Event) – the event that send to this entity

install(simulator: Simulator) → None

install is called before simulator runs to initialize or set initial events

Parameters:

simulator (qns.simulator.simulator.Simulator) – the simulator

class qns.entity.Link_Decoherence_QuantumChannel(name: str = None, node_list: List[QNode] = [], init_fidelity: float = 0.8, bandwidth: int = 1, delay: float | DelayModel = 0, drop_rate: float = 0, max_buffer_size: int = 0, length: float = 0, decoherence_rate: float | None = 0, transfer_error_model_args: dict = {}, max_storage_time=0.4, min_storage_time=0.0)

Bases: QuantumChannel

Link_Decoherence_QuantumChannel is the channel in which the fidelity of entangled pairs decoherence within the quantum memory.

create_entanglement_pool()

Creat entangled pairs.

find_fidlity_index(fidelity)

Find the entanglement pair whose fidelity is equal to the specified fidelity.

Parameters:

fidelity – the specified fidelity.

find_max_min_fidelity()

Find the entanglement pairs with maximum and minimum fidelity.

remove_entanglement_by_fidelity(fidelity)

Remove the entanglement pair whose fidelity is equal to the specified fidelity.

remove_entanglement_by_index(index)

Remove the entanglement pair whose fidelity is equal to the specified index.

class qns.entity.MemoryReadRequestEvent(memory, key: QuantumModel | str, t: Time | None = None, name: str | None = None, by: Any | None = None)

Bases: Event

MemoryReadRequestEvent is the event that request a memory read

invoke() → None

Invoke the event, should be implemented

class qns.entity.MemoryReadResponseEvent(node: QNode, result: QuantumModel | None = None, request: MemoryReadRequestEvent = None, t: Time | None = None, name: str | None = None, by: Any | None = None)

Bases: Event

MemoryReadResponseEvent is the event that returns the memory read result

invoke() → None

Invoke the event, should be implemented

class qns.entity.MemoryWriteRequestEvent(memory, qubit: QuantumModel, t: Time | None = None, name: str | None = None, by: Any | None = None)

Bases: Event

MemoryWriteRequestEvent is the event that request a memory write

invoke() → None

Invoke the event, should be implemented

class qns.entity.MemoryWriteResponseEvent(node: QNode, result: QuantumModel | None = None, request: MemoryReadRequestEvent = None, t: Time | None = None, name: str | None = None, by: Any | None = None)

Bases: Event

MemoryWriteResponseEvent is the event that returns the memory write result

invoke() → None

Invoke the event, should be implemented

class qns.entity.Monitor(name: str | None = None, network=None)

Bases: Entity

add_attribution(name: str, calculate_func: Callable[[Simulator, Any, Event | None], Any]) → None

Set an attribution that will be recorded. For example, an attribution could be the throughput, or the fidelity.

Parameters:

• name (str) – the column’s name, e.g., fidelity, throughput, time …

• calculate_func (Callable[[Simulator, Optional[QuantumNetwork], Optional[Event]]) – a function to calculate the value, it has three input parameters (Simulator, QuantumNetwork, Event), and it returns the value.

Usage:

m = Monitor()

# record the event happening time m.add_attribution(“time”, lambda s,n,e: e.t)

# get the ‘name’ attribution of the last node m.add_attribution(“count”, lambda s,network,e: network.nodes[-1].name)

at_event(event_type) → None

Watch network status whenever the event happends

Parameters:

event_type (Event) – the watching event

Usage:

# record network status when a node receives a qubit m.at_event(RecvQubitPacket)

at_finish() → None

Watch the final status after the simulation.

Usage:

m.at_finish()

at_period(period_time: float) → None

Watch network status at a constant period.

Parameters:

period_time (float) – the period of watching network status [s]

Usage:

# record network status every 3 seconds. m.at_period(3)

at_start() → None

Watch the initial status before the simulation starts.

Usage:

m.at_start()

calculate_date(event: Event)

get_date()

Get the collected data.

Returns:

the collected data, as a pd.DataFrame.

handle(event: Event) → None

handle is called to process an receiving Event.

Parameters:

event (qns.simulator.event.Event) – the event that send to this entity

install(simulator: Simulator) → None

install is called before simulator runs to initialize or set initial events

Parameters:

simulator (qns.simulator.simulator.Simulator) – the simulator

class qns.entity.MonitorEvent(t: Time | None, monitor, name: str | None = None, by: Any | None = None)

Bases: Event

the event that notify the monitor to write down network status

invoke() → None

Invoke the event, should be implemented

class qns.entity.OperateRequestEvent(operator, qubits: List[QuantumModel] = [], t: Time | None = None, name: str | None = None, by: Any | None = None)

Bases: Event

OperateRequestEvent is the event that request a operator to handle

invoke() → None

Invoke the event, should be implemented

class qns.entity.OperateResponseEvent(node: QNode, result: int | List[int] = None, request: OperateRequestEvent = None, t: Time | None = None, name: str | None = None, by: Any | None = None)

Bases: Event

OperateResponseEvent is the event that returns the operating result

invoke() → None

Invoke the event, should be implemented

class qns.entity.QNode(name: str = None, apps: List[Application] = None)

Bases: Entity

QNode is a quantum node in the quantum network

add_apps(app: Application)

Insert an Application into the app list.

Parameters:

app (Application) – the inserting application.

add_cchannel(cchannel)

Add a classic channel in this QNode

Parameters:

cchannel (ClassicChannel) – the classic channel

add_memory(memory)

Add a quantum memory in this QNode

Parameters:

memory (Memory) – the quantum memory

add_network(network)

add a network object to this node

Parameters:

network (qns.network.network.Network) – the network object

add_operator(operator)

Add a quantum operator in this node

Parameters:

operator (QuantumOperator) – the quantum operator

add_qchannel(qchannel)

Add a quantum channel in this QNode

Parameters:

qchannel (QuantumChannel) – the quantum channel

add_request(request)

add a request to this node

Parameters:

request (Request) – the inserting request

clear_request()

clear all requests

get_apps(app_type)

Get an Application that is app_type

Parameters:

app_type – the class of app_type

get_cchannel(dst: QNode)

Get the classic channel that connects to the dst

Parameters:

dst (QNode) – the destination

get_memory(memory: str | int)

Get the memory by index (in memories) or its name

Parameters:

memory (Union[str, int]) – the index or name of the memory

get_qchannel(dst: QNode)

Get the quantum channel that connects to the dst

Parameters:

dst (QNode) – the destination

handle(event: Event) → None

This function will handle an Event. This event will be passed to every applications in apps list in order.

Parameters:

event (Event) – the event that happens on this QNode

install(simulator: Simulator) → None

install is called before simulator runs to initialize or set initial events

Parameters:

simulator (qns.simulator.simulator.Simulator) – the simulator

class qns.entity.QuantumChannel(name: str = None, node_list: List[QNode] = [], fidelity: float = 0.8, bandwidth: int = 1, delay: float | DelayModel = 0, drop_rate: float = 0, max_buffer_size: int = 0, length: float = 0, decoherence_rate: float | None = 0, transfer_error_model_args: dict = {})

Bases: Entity

QuantumChannel is the channel for transmitting qubit

install(simulator: Simulator) → None

install is called before simulator runs to initialize or set initial events

Parameters:

simulator (Simulator) – the simulator

send(qubit: QuantumModel, next_hop: QNode)

Send a qubit to the next_hop

Parameters:

• qubit (QuantumModel) – the transmitting qubit

• next_hop (QNode) – the next hop QNode

Raises:

NextHopNotConnectionException – the next_hop is not connected to this channel

class qns.entity.QuantumMemory(name: str = None, node: QNode = None, capacity: int = 0, decoherence_rate: float | None = 0, store_error_model_args: dict = {}, delay: float | DelayModel = 0)

Bases: Entity

Quantum memory stores qubits or entangled pairs.

It has two modes:

Synchronous mode, users can use the read and write function to operate the memory directly without delay Asynchronous mode, users can use events to operate memories asynchronously

property count: int

return the current memory usage

get(key: QuantumModel | str | int) → QuantumModel | None

get a qubit from the memory but without removing it from the memory

Parameters:

key (Union[QuantumModel, str, int]) – the key. It can be a QuantumModel object, its name or the index number.

get_store_time(key: QuantumModel | str | int) → QuantumModel | None

get the store time of a qubit from the memory

Parameters:

key (Union[QuantumModel, str, int]) – the key. It can be a QuantumModel object, its name or the index number.

handle(event: Event) → None

handle is called to process an receiving Event.

Parameters:

event (qns.simulator.event.Event) – the event that send to this entity

install(simulator: Simulator) → None

install is called before simulator runs to initialize or set initial events

Parameters:

simulator (qns.simulator.simulator.Simulator) – the simulator

is_full() → bool

check whether the memory is full

read(key: QuantumModel | str) → QuantumModel | None

The API for reading a qubit from the memory

Parameters:

key (Union[QuantumModel, str]) – the key. It can be a QuantumModel object, its name or the index number.

write(qm: QuantumModel) → bool

The API for storing a qubit to the memory

Parameters:

qm (QuantumModel) – the QuantumModel, could be a qubit or an entangled pair

Returns:

whether the qubit is stored successfully

Return type:

bool

class qns.entity.QuantumOperator(name: str = None, node: QNode = None, gate: Callable[[...], None | int | List[int]] = None, delay: float | DelayModel = 0)

Bases: Entity

Quantum operator can perfrom quantum operation or measurements on qubits. It has two modes:

Synchronous mode, users can use the operate function to operate qubits directly without delay Asynchronous mode, users will use events to operate quantum operations asynchronously

handle(event: Event) → None

handle is called to process an receiving Event.

Parameters:

event (qns.simulator.event.Event) – the event that send to this entity

install(simulator: Simulator) → None

install is called before simulator runs to initialize or set initial events

Parameters:

simulator (qns.simulator.simulator.Simulator) – the simulator

operate(*qubits) → int | List[int] | None

operate on qubits and return the measure result

Parameters:

qubits – the operating qubits

Returns:

the measure result

set_own(node: QNode)

set the owner of this quantum operator

class qns.entity.RecvClassicPacket(t: Time | None = None, name: str | None = None, cchannel: ClassicChannel = None, packet: ClassicPacket = None, dest: QNode = None, by: Any | None = None)

Bases: Event

The event for a QNode to receive a classic packet

invoke() → None

Invoke the event, should be implemented

class qns.entity.RecvQubitPacket(t: Time | None = None, qchannel: QuantumChannel = None, qubit: QuantumModel = None, dest: QNode = None, name: str | None = None, by: Any | None = None)

Bases: Event

The event for a QNode to receive a classic packet

invoke() → None

Invoke the event, should be implemented

class qns.entity.Timer(name: str, start_time: float, end_time: float = 0, step_time: float = 1, trigger_func=None)

Bases: Entity

A Timer is an Entity that trigger the function trigger_func one-shot or periodically.

install(simulator: Simulator) → None

install is called before simulator runs to initialize or set initial events

Parameters:

simulator (qns.simulator.simulator.Simulator) – the simulator

trigger()