mia/bumper
1
0
Fork 0
Code Issues 47 Pull requests 11 Projects Releases Packages Wiki Activity Actions

optimize data

Browse source 
increase buffer and split <iq earlier
This commit is contained in:
Brian Martin 2019-02-24 21:48:37 -05:00
parent 3ec51e754e
commit af29f69a99
1 changed files with 13 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

16
bumper/xmppserver.py
View file

@ -866,7 +866,8 @@ class Client(threading.Thread):
time.sleep(0.2) time.sleep(0.2)
if not self.connection._closed: if not self.connection._closed:
try: try:
data = self.connection.recv(4096) #data = self.connection.recv(4096)
data = self.connection.recv(8192)
except ConnectionResetError as e: except ConnectionResetError as e:
xmppserverlog.error("{}".format(e)) xmppserverlog.error("{}".format(e))
@ -876,5 +877,14 @@ class Client(threading.Thread):
xmppserverlog.exception("{}".format(e)) xmppserverlog.exception("{}".format(e))
if data != b"": if data != b"":
self._parse_data(data) splitdata = data.decode("utf-8")
splitdata = splitdata.split("<iq")
if len(splitdata) > 1:
for s in splitdata:
if not s.startswith("<iq") and s:
self._parse_data("<iq {}".format(s).encode("utf-8"))
else:
self._parse_data(s.encode("utf-8"))
else:
self._parse_data(data)