Madiator2011/lbry-sdk
1
0
Fork 0
forked from LBRYCommunity/lbry-sdk
Code Pull requests Activity

silence "[Errno 11] Resource temporarily unavailable" error

Browse source
This commit is contained in:
Alex Grintsvayg 2017-01-03 19:13:16 -05:00 committed by jobevers
parent 41abd0a171
commit 35b2e56bd4
1 changed files with 9 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

8
lbrynet/dht/protocol.py
View file

@ -10,6 +10,8 @@
import logging import logging
import binascii import binascii
import time import time
import socket
import errno
from twisted.internet import protocol, defer from twisted.internet import protocol, defer
from twisted.python import failure from twisted.python import failure
@ -251,7 +253,13 @@ class KademliaProtocol(protocol.DatagramProtocol):
def _write_and_remove(self, key, txData, address): def _write_and_remove(self, key, txData, address):
del self._call_later_list[key] del self._call_later_list[key]
if self.transport: if self.transport:
try:
# i'm scared this may swallow important errors, but i get a million of these
# on Linux and it doesnt seem to affect anything -grin
self.transport.write(txData, address) self.transport.write(txData, address)
except socket.error as err:
if err.errno != errno.EWOULDBLOCK:
raise err
def _sendResponse(self, contact, rpcID, response): def _sendResponse(self, contact, rpcID, response):
""" Send a RPC response to the specified contact """ Send a RPC response to the specified contact