Suggested-by: Reid Price <reid@nicira.com>
return self.status, None
while True:
return self.status, None
while True:
- if len(self.input) == 0:
error, data = self.stream.recv(4096)
if error:
if error == errno.EAGAIN:
error, data = self.stream.recv(4096)
if error:
if error == errno.EAGAIN:
% (self.name, os.strerror(error)))
self.error(error)
return self.status, None
% (self.name, os.strerror(error)))
self.error(error)
return self.status, None
self.error(EOF)
return EOF, None
else:
self.error(EOF)
return EOF, None
else:
return msg
def recv_wait(self, poller):
return msg
def recv_wait(self, poller):
- if self.status or len(self.input) > 0:
+ if self.status or self.input:
poller.immediate_wake()
else:
self.stream.recv_wait(poller)
poller.immediate_wake()
else:
self.stream.recv_wait(poller)