70镜像[番外](2 / 2)
defbroadcast_mirrorbroadcaster,souls,message:
confirmations={soul['port']:Falseforsoulinsouls}
for_inrange3:#三次广播
forsoulinsouls:
broadcaster.sendto
f"GHOST_SPLIT_MIRROR:{message}".encode,
soul['ip'],soul['port']
sleep0.5#量子纠缠间隔
#确认接收状态
try:
broadcaster.settimeout3.0
whilenotallconfirmations.values:
data,addr=broadcaster.recvfrom1024
if"_CONFIRMED"indata.decode:
confirmations[addr[1]]=True
printf"收到来自端口{addr[1]}的量子确认"
exceptsocket.timeout:
print"警告:部分灵魂未完成量子纠缠"
#初始化量子灵魂节点
soul_threads=[]
foriinrange3:
soul=QuantumSouli+1
t=threading.Threadtarget=soul.receive_mirror
t.daemon=True
soul_threads.appendt
t.start
#创建广播器
br
↑返回顶部↑