NgTech-LTD/gns3-server
2
0
Fork 0
mirror of https://github.com/GNS3/gns3-server.git synced 2026-08-27 12:30:13 +03:00
Code Issues Packages Projects Releases Wiki Activity

log: add start/stop/close progress lines; revert start concurrency to 3

Browse Source 
- start_all, stop_all: emit 'starting/stopping N nodes...' and complete
  lines with project name+id, matching the open-node/link log style.
- close: emit 'project closing.../closed' bracketing the whole teardown.
- Revert start_all concurrency 20->3 and reset_console 20->3: start
  (ubridge process + docker start + network) is heavy enough that high
  concurrency risks overwhelming the server. stop remains 100 (kill is
  light) and suspend remains 50 (pause is light).
This commit is contained in:
YueGuobin 2026-08-11 00:48:13 +08:00
parent ec2a0ffff3
commit c366f20340
No known key found for this signature in database
1 changed files with 18 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

26
gns3server/controller/project.py
View File

@ -1372,6 +1372,7 @@ class Project:
log.warning(f"Closing project '{self.name}' ignored because it is being loaded")
return
self._closing = True
log.info("Project '%s' [%s]: closing...", self._name, self._id)
try:
await self.stop_all()
except HTTPException as e:
@ -1395,6 +1396,7 @@ class Project:
self.reset()
self._closing = False
log.info("Project '%s' [%s]: closed", self._name, self._id)
def _clean_pictures(self):
"""
@ -2072,22 +2074,30 @@ class Project:
"""
Start all nodes (except always-running types like Ethernet switch, Cloud, NAT, etc.)
"""
pool = Pool(concurrency=20)
for node in self.nodes.values():
if not node.is_always_running():
pool.append(node.start)
nodes_to_start = [n for n in self.nodes.values() if not n.is_always_running()]
if not nodes_to_start:
return
log.info("Project '%s' [%s]: starting %d nodes...", self._name, self._id, len(nodes_to_start))
pool = Pool(concurrency=3)
for node in nodes_to_start:
pool.append(node.start)
await pool.join()
log.info("Project '%s' [%s]: started %d nodes", self._name, self._id, len(nodes_to_start))
@open_required
async def stop_all(self):
"""
Stop all nodes (except always-running types like Ethernet switch, Cloud, NAT, etc.)
"""
nodes_to_stop = [n for n in self.nodes.values() if not n.is_always_running()]
if not nodes_to_stop:
return
log.info("Project '%s' [%s]: stopping %d nodes...", self._name, self._id, len(nodes_to_stop))
pool = Pool(concurrency=100)
for node in self.nodes.values():
if not node.is_always_running():
pool.append(node.stop)
for node in nodes_to_stop:
pool.append(node.stop)
await pool.join()
log.info("Project '%s' [%s]: stopped %d nodes", self._name, self._id, len(nodes_to_stop))
@open_required
async def suspend_all(self):
@ -2105,7 +2115,7 @@ class Project:
Reset console for all nodes
"""
pool = Pool(concurrency=20)
pool = Pool(concurrency=3)
for node in self.nodes.values():
pool.append(node.reset_console)
await pool.join()