forked from p15670423/monkey
Agent: Use timeout in build_tcprelay_deps()
This commit is contained in:
parent
732751f007
commit
5c7c54e450
|
@ -1,14 +1,14 @@
|
||||||
from . import TCPConnectionHandler, TCPPipeSpawner, RelayUserHandler, RelayConnectionHandler
|
|
||||||
from ipaddress import IPv4Address
|
from ipaddress import IPv4Address
|
||||||
from typing import Tuple
|
from typing import Tuple
|
||||||
|
|
||||||
|
from . import RelayConnectionHandler, RelayUserHandler, TCPConnectionHandler, TCPPipeSpawner
|
||||||
|
|
||||||
|
|
||||||
def build_tcprelay_deps(
|
def build_tcprelay_deps(
|
||||||
local_port: int, dest_addr: IPv4Address, dest_port: int, client_disconnect_timeout: float
|
local_port: int, dest_addr: IPv4Address, dest_port: int, client_disconnect_timeout: float
|
||||||
) -> Tuple[RelayUserHandler, TCPPipeSpawner, TCPConnectionHandler]:
|
) -> Tuple[RelayUserHandler, TCPPipeSpawner, TCPConnectionHandler]:
|
||||||
|
|
||||||
# TODO: Add the timeouts
|
relay_user_handler = RelayUserHandler(client_disconnect_timeout=client_disconnect_timeout)
|
||||||
relay_user_handler = RelayUserHandler()
|
|
||||||
pipe_spawner = TCPPipeSpawner(dest_addr, dest_port)
|
pipe_spawner = TCPPipeSpawner(dest_addr, dest_port)
|
||||||
relay_filter = RelayConnectionHandler(pipe_spawner, relay_user_handler)
|
relay_filter = RelayConnectionHandler(pipe_spawner, relay_user_handler)
|
||||||
connection_handler = TCPConnectionHandler(
|
connection_handler = TCPConnectionHandler(
|
||||||
|
|
Loading…
Reference in New Issue