archive
/
ansible
mirror of https://github.com/ansible/ansible.git
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

Fix for network byte order issues in accelerate

Browse Source
reviewable/pr18780/r1
James Cammarata 11 years ago
parent a42d45872b
commit 3cd459faf7
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File

4
utilities/accelerate
Unescape Escape View File

@ -190,7 +190,7 @@ class ThreadedTCPServer(SocketServer.ThreadingTCPServer):
class ThreadedTCPRequestHandler(SocketServer.BaseRequestHandler): class ThreadedTCPRequestHandler(SocketServer.BaseRequestHandler):
def send_data(self, data): def send_data(self, data):
packed_len = struct.pack('Q', len(data)) packed_len = struct.pack('!Q', len(data))
return self.request.sendall(packed_len + data) return self.request.sendall(packed_len + data)
def recv_data(self): def recv_data(self):
@ -204,7 +204,7 @@ class ThreadedTCPRequestHandler(SocketServer.BaseRequestHandler):
return None return None
data += d data += d
vvvv("in recv_data(), got the header, unpacking") vvvv("in recv_data(), got the header, unpacking")
data_len = struct.unpack('Q',data[:header_len])[0] data_len = struct.unpack('!Q',data[:header_len])[0]
data = data[header_len:] data = data[header_len:]
vvvv("data received so far (expecting %d): %d" % (data_len,len(data))) vvvv("data received so far (expecting %d): %d" % (data_len,len(data)))
while len(data) < data_len: while len(data) < data_len:

Write Preview
Loading…
Cancel
Save