wip

hathor/builder/cli_builder.py

@@ -332,6 +332,13 @@ def create_manager(self, reactor: Reactor) -> HathorManager:
             log_vertex_bytes=self._args.log_vertex_bytes,
         )
 
+        if self._args.x_multiprocess_p2p:
+            self.check_or_raise(
+                self._args.x_remove_sync_v1,
+                'multiprocess support for P2P is only available if sync-v1 is removed (use --x-remove-sync-v1)'
+            )
+            raise NotImplementedError('Multiprocess support for P2P is not yet implemented.')
+
         p2p_dependencies = P2PDependencies(
             reactor=reactor,
             settings=settings,

hathor/cli/run_node.py

@@ -58,6 +58,7 @@ class RunNode:
         ('--x-enable-event-queue', lambda args: bool(args.x_enable_event_queue)),
         ('--x-asyncio-reactor', lambda args: bool(args.x_asyncio_reactor)),
         ('--x-ipython-kernel', lambda args: bool(args.x_ipython_kernel)),
+        ('--x-multiprocess-p2p', lambda args: bool(args.x_multiprocess_p2p)),
     ]
 
     env_vars_prefix: str | None = None
@@ -162,6 +163,7 @@ def create_parser(cls) -> ArgumentParser:
                             help='Log tx bytes for debugging')
         parser.add_argument('--disable-ws-history-streaming', action='store_true',
                             help='Disable websocket history streaming API')
+        parser.add_argument('--x-multiprocess-p2p', action='store_true', help='Enable multiprocess support for P2P.')
         return parser
 
     def prepare(self, *, register_resources: bool = True) -> None:

hathor/cli/run_node_args.py

@@ -83,3 +83,4 @@ class RunNodeArgs(BaseModel, extra=Extra.allow):
     nano_testnet: bool
     log_vertex_bytes: bool
     disable_ws_history_streaming: bool
+    x_multiprocess_p2p: bool