mirror of
https://github.com/kovidgoyal/calibre.git
synced 2025-07-09 03:04:10 -04:00
Ignore ECONNRESET when reading from test server
This commit is contained in:
parent
b2a535a319
commit
560ebceac4
@ -4,7 +4,7 @@
|
|||||||
|
|
||||||
from __future__ import (unicode_literals, division, absolute_import,
|
from __future__ import (unicode_literals, division, absolute_import,
|
||||||
print_function)
|
print_function)
|
||||||
import socket, os, struct
|
import socket, os, struct, errno
|
||||||
from base64 import standard_b64encode
|
from base64 import standard_b64encode
|
||||||
from collections import deque, namedtuple
|
from collections import deque, namedtuple
|
||||||
from functools import partial
|
from functools import partial
|
||||||
@ -73,7 +73,12 @@ class WSClient(object):
|
|||||||
return data
|
return data
|
||||||
self.read_buf.appendleft(data[max_amt+1:])
|
self.read_buf.appendleft(data[max_amt+1:])
|
||||||
return data[:max_amt + 1]
|
return data[:max_amt + 1]
|
||||||
|
try:
|
||||||
return self.socket.recv(max_amt)
|
return self.socket.recv(max_amt)
|
||||||
|
except socket.error as err:
|
||||||
|
if err.errno != errno.ECONNRESET:
|
||||||
|
raise
|
||||||
|
return b''
|
||||||
|
|
||||||
def read_size(self, size):
|
def read_size(self, size):
|
||||||
ans = b''
|
ans = b''
|
||||||
|
Loading…
x
Reference in New Issue
Block a user