LBRYCommunity/lbry-sdk
1
0
Fork 1
Code Issues Pull requests Projects Releases 282 Packages Wiki Activity

fix HTTPSHandler

Browse source
This commit is contained in:
Jack Robison 2017-07-13 14:48:37 -04:00
parent 06edd1f16a
commit 142d30bbcf
No known key found for this signature in database
GPG key ID: 284699E7404E3CFF
1 changed files with 11 additions and 12 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

23
lbrynet/core/log_support.py
View file

@ -7,6 +7,8 @@ import sys
import traceback import traceback
from txrequests import Session from txrequests import Session
from requests.exceptions import ConnectionError
from twisted.internet import defer
import twisted.python.log import twisted.python.log
from lbrynet import __version__ as lbrynet_version, build_type, conf from lbrynet import __version__ as lbrynet_version, build_type, conf
@ -32,11 +34,6 @@ _srcfile = os.path.normcase(_srcfile)
TRACE = 5 TRACE = 5
def bg_cb(sess, resp):
""" Don't do anything with the response """
pass
class HTTPSHandler(logging.Handler): class HTTPSHandler(logging.Handler):
def __init__(self, url, fqdn=False, localname=None, facility=None, session=None): def __init__(self, url, fqdn=False, localname=None, facility=None, session=None):
logging.Handler.__init__(self) logging.Handler.__init__(self)
@ -52,14 +49,16 @@ class HTTPSHandler(logging.Handler):
else: else:
return record.getMessage() return record.getMessage()
def emit(self, record): @defer.inlineCallbacks
def _emit(self, record):
payload = self.format(record)
try: try:
payload = self.format(record) yield self.session.post(self.url, data=payload)
self.session.post(self.url, data=payload, background_callback=bg_cb) except ConnectionError:
except (KeyboardInterrupt, SystemExit): pass
raise
except: def emit(self, record):
self.handleError(record) return self._emit(record)
DEFAULT_FORMAT = "%(asctime)s %(levelname)-8s %(name)s:%(lineno)d: %(message)s" DEFAULT_FORMAT = "%(asctime)s %(levelname)-8s %(name)s:%(lineno)d: %(message)s"