阅读历史 |

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

↑返回顶部↑

书页/目录