t_unicast.py

from abcast import abcast_node, abcast_system
import threading

a = abcast_system(4)

clock_thread = threading.Thread(target=a.start_global_clock) ## global clock
clock_thread.daemon = True  # Making it a daemon thread so that it doesn't block the main program
clock_thread.start()

## Setting random time-delays and unicast communication
thread1 = threading.Thread(target= (lambda: a.transmit("M1", 1, 2, 0))) 
thread2 = threading.Thread(target= (lambda: a.transmit("M2", 1, 4, 2))) 
thread3 = threading.Thread(target= (lambda: a.transmit("M3", 2, 3, 4))) 
thread4 = threading.Thread(target= (lambda: a.transmit("M4", 1, 2, 6))) 
thread5 = threading.Thread(target= (lambda: a.transmit("M5", 2, 3, 8))) 
thread6 = threading.Thread(target= (lambda: a.transmit("M6", 4, 1, 10))) 
thread7 = threading.Thread(target= (lambda: a.transmit("M7", 3, 1, 12))) 
thread8 = threading.Thread(target= (lambda: a.transmit("M8", 1, 2, 14))) 

threads_t = [thread1, thread2, thread3, thread4, thread5, thread6, thread7, thread8]
while True:
    a.event.wait()
    for thread in threads_t:
        thread.start()
    break

for thread in threads_t:
    thread.join()

clock_thread.join()

print("dv messages 1 = ", a.nodes[1].delivered_messages)
print("dv messages 2 = ", a.nodes[2].delivered_messages)
print("dv messages 3 = ", a.nodes[3].delivered_messages)
print("dv messages 4 = ", a.nodes[4].delivered_messages)