1
0

use functools.wraps() for some wrappers

to help debugging
This commit is contained in:
SomberNight
2021-03-04 16:44:13 +01:00
parent 859f8ccf8e
commit ff485cee62
3 changed files with 13 additions and 2 deletions

View File

@@ -35,6 +35,7 @@ from ipaddress import IPv4Network, IPv6Network, ip_address, IPv6Address, IPv4Add
import itertools
import logging
import hashlib
import functools
import aiorpcx
from aiorpcx import TaskGroup
@@ -375,10 +376,13 @@ class Interface(Logger):
# Dump network messages (only for this interface). Set at runtime from the console.
self.debug = False
asyncio.run_coroutine_threadsafe(
self.network.taskgroup.spawn(self.run()), self.network.asyncio_loop)
self.taskgroup = SilentTaskGroup()
async def spawn_task():
task = await self.network.taskgroup.spawn(self.run())
task.set_name(f"interface::{str(server)}")
asyncio.run_coroutine_threadsafe(spawn_task(), self.network.asyncio_loop)
@property
def host(self):
return self.server.host
@@ -476,6 +480,7 @@ class Interface(Logger):
return sslc
def handle_disconnect(func):
@functools.wraps(func)
async def wrapper_func(self: 'Interface', *args, **kwargs):
try:
return await func(self, *args, **kwargs)