security_vision/trap
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity

list which processes occupy port

Browse source
This commit is contained in:
Ruben van de Ven 2023-12-06 12:08:12 +01:00
parent 44a618a5ee
commit cd8a06a53b
1 changed files with 10 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

9
trap/socket_forwarder.py
View file

@ -1,8 +1,10 @@
from argparse import Namespace from argparse import Namespace
import asyncio import asyncio
import errno
import logging import logging
from multiprocessing import Event from multiprocessing import Event
import subprocess
from typing import Set, Union, Dict, Any from typing import Set, Union, Dict, Any
from typing_extensions import Self from typing_extensions import Self
@ -145,7 +147,14 @@ class WsRouter:
# loop = tornado.ioloop.IOLoop.current() # loop = tornado.ioloop.IOLoop.current()
logger.info(f"Listen on {self.config.ws_port}") logger.info(f"Listen on {self.config.ws_port}")
try:
self.application.listen(self.config.ws_port) self.application.listen(self.config.ws_port)
except OSError as e:
if e.errno == errno.EADDRINUSE:
logger.critical("Address already in use by process")
subprocess.run(["lsof", "-i", f"tcp:{self.config.ws_port:d}"])
raise
loop = asyncio.get_event_loop() loop = asyncio.get_event_loop()
task = self.evt_loop.create_task(self.prediction_forwarder()) task = self.evt_loop.create_task(self.prediction_forwarder())