andreas/heartbeat
Public Access
1
0
Fork 1
Code Issues Pull Requests Actions Packages Projects Releases 44 Wiki Activity

turn compression on

Browse Source
This commit is contained in:
Andreas Wrede
2016-04-29 18:45:13 +02:00
parent 712da9b9f1
commit d66dc6c66a
1 changed files with 3 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files
hbc
+3 -5
View File
@@ -11,7 +11,6 @@ import string
import select import select
import errno import errno
import traceback import traceback
import urllib2
import md5 import md5
import shutil import shutil
import zlib import zlib
@@ -94,10 +93,9 @@ class Conn:
msg['id'] = self.conId msg['id'] = self.conId
msg['ver'] = VER msg['ver'] = VER
msg['time'] = time.time() msg['time'] = time.time()
m = dicttos(ID, msg) m = dicttos(ID, msg, True) # always compress
mz = zlib.compress(m,9)
if verbose: if verbose:
log("conn.send('%s', (%s:%s) %s>%s)" % (msg, self.addr, self.port, len(m), len(mz))) log("conn.send('%s', (%s:%s) %s)" % (msg, self.addr, self.port, len(m)))
try: try:
self.sock.sendto(m, (self.addr, self.port)) self.sock.sendto(m, (self.addr, self.port))
except socket.error as e: except socket.error as e:
@@ -131,7 +129,7 @@ def shortname(name):
def dicttos(ID, d, compress=False): def dicttos(ID, d, compress=False):
s = [] s = []
for k in d: for k in d:
if type(d[k]) == type(1.2): if type(d[k]) == type(1.2):
s.append("%s=%0.5f" % (k, d[k])) s.append("%s=%0.5f" % (k, d[k]))
else: else: