tinterface: make changing max incoming msg size (1 MB) easier - electrum - Electrum Bitcoin wallet
HTML git clone https://git.parazyd.org/electrum
DIR Log
DIR Files
DIR Refs
DIR Submodules
---
DIR commit 787ac5fe994086b994524201fec4b63f876c7c85
DIR parent c19f9ee755b46701eb07d80370effffebbd67394
HTML Author: SomberNight <somber.night@protonmail.com>
Date: Fri, 27 Dec 2019 17:43:12 +0100
interface: make changing max incoming msg size (1 MB) easier
Diffstat:
M electrum/interface.py | 8 +++++++-
1 file changed, 7 insertions(+), 1 deletion(-)
---
DIR diff --git a/electrum/interface.py b/electrum/interface.py
t@@ -36,7 +36,7 @@ import itertools
import logging
import aiorpcx
-from aiorpcx import RPCSession, Notification, NetAddress
+from aiorpcx import RPCSession, Notification, NetAddress, NewlineFramer
from aiorpcx.curio import timeout_after, TaskTimeout
from aiorpcx.jsonrpc import JSONRPC, CodeMessageError
from aiorpcx.rawsocket import RSClient
t@@ -62,6 +62,8 @@ ca_path = certifi.where()
BUCKET_NAME_OF_ONION_SERVERS = 'onion'
+MAX_INCOMING_MSG_SIZE = 1_000_000 # in bytes
+
class NetworkTimeout:
# seconds
t@@ -157,6 +159,10 @@ class NotificationSession(RPCSession):
if self.interface.debug or self.interface.network.debug:
self.interface.logger.debug(msg)
+ def default_framer(self):
+ # overridden so that max_size can be customized
+ return NewlineFramer(max_size=MAX_INCOMING_MSG_SIZE)
+
class NetworkException(Exception): pass