PTV/ptvp35
1
1
Fork 0
Code Issues Pull Requests Packages Projects Releases 4 Wiki Activity

connection classes separation

Browse Source
This commit is contained in:
AF 2023-02-03 14:38:25 +00:00
parent 3b622984bf
commit 28f964a3e6
3 changed files with 498 additions and 304 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
docs/scripts/traced_example.py
View File

@ -144,6 +144,8 @@ async def main():
with ExitStack() as es: with ExitStack() as es:
LogWrites().enter(es) LogWrites().enter(es)
if run_all: if run_all:
print('not yet properly instrumented; exiting;')
raise NotImplementedError
LogEE(__import__('ptvp35').Request, '__init__').enter(es) LogEE(__import__('ptvp35').Request, '__init__').enter(es)
LogEE(__import__('ptvp35').Request, 'waiting').enter(es) LogEE(__import__('ptvp35').Request, 'waiting').enter(es)
LogEE(__import__('ptvp35').Request, 'set_result').enter(es) LogEE(__import__('ptvp35').Request, 'set_result').enter(es)

798
ptvp35/__init__.py
View File

File diff suppressed because it is too large Load Diff

2
ptvp35/instrumentation.py
View File

@ -6,7 +6,7 @@ __all__ = ('InstrumentDiskWrites', 'NightlyInstrumentation')
class InstrumentDiskWrites(Instrumentation): class InstrumentDiskWrites(Instrumentation):
def __init__(self, /): def __init__(self, /):
super().__init__(ptvp35.DbConnection, '_write_to_disk_sync') super().__init__(ptvp35.File, 'write_to_disk_sync')
def on_write(self, line: str, /) -> None: def on_write(self, line: str, /) -> None:
pass pass