mirror of
https://github.com/LBRYFoundation/LBRY-Vault.git
synced 2025-08-23 17:47:31 +00:00
follow-up prev
This commit is contained in:
parent
5a7c3dc4d0
commit
aae06116f9
1 changed files with 1 additions and 2 deletions
|
@ -132,7 +132,7 @@ class NotificationSession(RPCSession):
|
||||||
self.cache = {}
|
self.cache = {}
|
||||||
self.default_timeout = NetworkTimeout.Generic.NORMAL
|
self.default_timeout = NetworkTimeout.Generic.NORMAL
|
||||||
self._msg_counter = itertools.count(start=1)
|
self._msg_counter = itertools.count(start=1)
|
||||||
self.interface = interface # type: Interface
|
self.interface = interface
|
||||||
self.cost_hard_limit = 0 # disable aiorpcx resource limits
|
self.cost_hard_limit = 0 # disable aiorpcx resource limits
|
||||||
|
|
||||||
async def handle_request(self, request):
|
async def handle_request(self, request):
|
||||||
|
@ -612,7 +612,6 @@ class Interface(Logger):
|
||||||
host=self.host, port=self.port,
|
host=self.host, port=self.port,
|
||||||
ssl=sslc, proxy=self.proxy) as session:
|
ssl=sslc, proxy=self.proxy) as session:
|
||||||
self.session = session # type: NotificationSession
|
self.session = session # type: NotificationSession
|
||||||
self.session.interface = self
|
|
||||||
self.session.set_default_timeout(self.network.get_network_timeout_seconds(NetworkTimeout.Generic))
|
self.session.set_default_timeout(self.network.get_network_timeout_seconds(NetworkTimeout.Generic))
|
||||||
try:
|
try:
|
||||||
ver = await session.send_request('server.version', [self.client_name(), version.PROTOCOL_VERSION])
|
ver = await session.send_request('server.version', [self.client_name(), version.PROTOCOL_VERSION])
|
||||||
|
|
Loading…
Add table
Reference in a new issue