fix recv function

This commit is contained in:
zhangxiaoyang 2016-05-06 16:26:38 +08:00
parent a91c71574a
commit 9125a42d5d
1 changed files with 3 additions and 3 deletions

View File

@ -35,15 +35,15 @@ class GstoreConnector:
head = self._sock.recv(4)
context_len = 0
for i in range(4):
context_len |= (ord(head[i]) << i * 8)
context_len |= (ord(head[i]) & 0xFF) << i * 8
data = bytearray(context_len)
data = bytearray()
recv_len = 0
while recv_len < context_len:
chunk = self._sock.recv(1024)
data.extend(chunk)
recv_len += len(chunk)
return str(data)
return data.rstrip('\x00').decode('utf-8')
def _pack(self, msg):
data_context = bytearray()