yumoqing/kivyblocks
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

bugfix

Browse Source
This commit is contained in:
yumoqing 2021-07-14 16:14:36 +08:00
parent 1725184141
commit 02b8cc22b9
1 changed files with 3 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
kivyblocks/udp_widget.py
View File

@ -4,6 +4,7 @@ except:
import json import json
import time import time
import zlib
from kivy.event import EventDispatcher from kivy.event import EventDispatcher
from kivy.clock import Clock from kivy.clock import Clock
from appPublic.udp_comm import UdpComm from appPublic.udp_comm import UdpComm
@ -55,6 +56,7 @@ class UdpWidget(EventDispatcher):
} }
} }
b = b'0x00' * 18 + json.dumps(d).encode('utf-8') b = b'0x00' * 18 + json.dumps(d).encode('utf-8')
b = zlib.compress(b)
self.udp_transport.broadcast(b) self.udp_transport.broadcast(b)
if peer_id is None: if peer_id is None:
print('get_peer_pubkey():return') print('get_peer_pubkey():return')
@ -127,9 +129,9 @@ class UdpWidget(EventDispatcher):
self.send(peer, data) self.send(peer, data)
def send(self, peer_id, data): def send(self, peer_id, data):
print('send():', peer_id, data)
d = self.dataencoder.pack(peer_id, data) d = self.dataencoder.pack(peer_id, data)
addr = (peer_id, self.udp_port) addr = (peer_id, self.udp_port)
print('send():', peer_id, data)
self.udp_transport.send(d, addr) self.udp_transport.send(d, addr)
def stop(self): def stop(self):