NgTech-LTD/gns3-server
2
0
Fork 0
mirror of https://github.com/GNS3/gns3-server.git synced 2026-10-27 18:52:23 +02:00
Code Issues Packages Projects Releases Wiki Activity

debug: add per-command timing to _connect_nio ubridge calls

Browse Source 
Temporary diagnostic instrumentation to measure the wall-clock time of
each ubridge command during NIO addition (add_nio_udp, bridge start,
filters, markers).  The logs will reveal whether the 12-NIO/s
throughput stems from ubridge command latency itself or from lock
contention / HTTP overhead outside _connect_nio.
This commit is contained in:
YueGuobin 2026-08-10 22:45:32 +08:00
parent acc9e670af
commit 82fc7f2bd1
No known key found for this signature in database
1 changed files with 12 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
gns3server/compute/docker/docker_vm.py
View File

@ -27,6 +27,7 @@ import aiohttp
import subprocess import subprocess
import os import os
import re import re
import time
from gns3server.utils.asyncio.ssh_server import AsyncioSSHServer from gns3server.utils.asyncio.ssh_server import AsyncioSSHServer
from gns3server.utils.asyncio.telnet_server import AsyncioTelnetServer from gns3server.utils.asyncio.telnet_server import AsyncioTelnetServer
@ -1215,6 +1216,7 @@ class DockerVM(BaseNode):
return int(result["State"]["Pid"]) return int(result["State"]["Pid"])
async def _connect_nio(self, adapter_number, nio): async def _connect_nio(self, adapter_number, nio):
_t0 = time.perf_counter()
bridge_name = f"bridge{adapter_number}" bridge_name = f"bridge{adapter_number}"
await self._ubridge_send( await self._ubridge_send(
@ -1222,6 +1224,7 @@ class DockerVM(BaseNode):
bridge_name=bridge_name, lport=nio.lport, rhost=nio.rhost, rport=nio.rport bridge_name=bridge_name, lport=nio.lport, rhost=nio.rhost, rport=nio.rport
) )
) )
_t1 = time.perf_counter()
if nio.capturing: if nio.capturing:
await self._ubridge_send( await self._ubridge_send(
@ -1230,8 +1233,17 @@ class DockerVM(BaseNode):
) )
) )
await self._ubridge_send(f"bridge start {bridge_name}") await self._ubridge_send(f"bridge start {bridge_name}")
_t2 = time.perf_counter()
await self._ubridge_apply_filters(bridge_name, nio.filters) await self._ubridge_apply_filters(bridge_name, nio.filters)
_t3 = time.perf_counter()
await self._ubridge_apply_markers(bridge_name, nio) await self._ubridge_apply_markers(bridge_name, nio)
_t4 = time.perf_counter()
log.info(
"NIO timing [adapter=%d] add_nio_udp=%.3fms start=%.3fms filters=%.3fms markers=%.3fms total=%.3fms",
adapter_number,
1000 * (_t1 - _t0), 1000 * (_t2 - _t1),
1000 * (_t3 - _t2), 1000 * (_t4 - _t3),
1000 * (_t4 - _t0))
async def adapter_add_nio_binding(self, adapter_number, nio): async def adapter_add_nio_binding(self, adapter_number, nio):
""" """