Skip to content

Commit 2d726df

Browse files
committed
Use buffer of type 'bytes' to accumulate from socket.
1 parent e20a2c1 commit 2d726df

File tree

1 file changed

+9
-9
lines changed

1 file changed

+9
-9
lines changed

Lib/idlelib/rpc.py

Lines changed: 9 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -337,13 +337,13 @@ def putmessage(self, message):
337337
else:
338338
s = s[n:]
339339

340-
buffer = ""
340+
buff = b''
341341
bufneed = 4
342342
bufstate = 0 # meaning: 0 => reading count; 1 => reading data
343343

344344
def pollpacket(self, wait):
345345
self._stage0()
346-
if len(self.buffer) < self.bufneed:
346+
if len(self.buff) < self.bufneed:
347347
r, w, x = select.select([self.sock.fileno()], [], [], wait)
348348
if len(r) == 0:
349349
return None
@@ -353,21 +353,21 @@ def pollpacket(self, wait):
353353
raise EOFError
354354
if len(s) == 0:
355355
raise EOFError
356-
self.buffer += s
356+
self.buff += s
357357
self._stage0()
358358
return self._stage1()
359359

360360
def _stage0(self):
361-
if self.bufstate == 0 and len(self.buffer) >= 4:
362-
s = self.buffer[:4]
363-
self.buffer = self.buffer[4:]
361+
if self.bufstate == 0 and len(self.buff) >= 4:
362+
s = self.buff[:4]
363+
self.buff = self.buff[4:]
364364
self.bufneed = struct.unpack("<i", s)[0]
365365
self.bufstate = 1
366366

367367
def _stage1(self):
368-
if self.bufstate == 1 and len(self.buffer) >= self.bufneed:
369-
packet = self.buffer[:self.bufneed]
370-
self.buffer = self.buffer[self.bufneed:]
368+
if self.bufstate == 1 and len(self.buff) >= self.bufneed:
369+
packet = self.buff[:self.bufneed]
370+
self.buff = self.buff[self.bufneed:]
371371
self.bufneed = 4
372372
self.bufstate = 0
373373
return packet

0 commit comments

Comments
 (0)