From d48f5f097a55d547544bfae62f61cf565a0945d1 Mon Sep 17 00:00:00 2001 From: Eugenio Panero Date: Thu, 25 Jun 2026 20:37:23 -0700 Subject: [PATCH] [codex] fix ingress CI failures --- codex-rs/linux-sandbox/src/ingress.rs | 2 +- .../tests/suite/managed_proxy.rs | 28 +++++++++---------- 2 files changed, 15 insertions(+), 15 deletions(-) diff --git a/codex-rs/linux-sandbox/src/ingress.rs b/codex-rs/linux-sandbox/src/ingress.rs index 0339e930d9..7cd401aa2e 100644 --- a/codex-rs/linux-sandbox/src/ingress.rs +++ b/codex-rs/linux-sandbox/src/ingress.rs @@ -262,7 +262,7 @@ mod tests { #[test] fn connection_limiter_waits_for_available_slot() { - let connection_limiter = Arc::new(ConnectionLimiter::new(1)); + let connection_limiter = Arc::new(ConnectionLimiter::new(/*max_connections*/ 1)); let first_connection = connection_limiter.acquire(); let (acquired_tx, acquired_rx) = mpsc::channel(); let waiting_limiter = Arc::clone(&connection_limiter); diff --git a/codex-rs/linux-sandbox/tests/suite/managed_proxy.rs b/codex-rs/linux-sandbox/tests/suite/managed_proxy.rs index 1c67531db2..aab830a340 100644 --- a/codex-rs/linux-sandbox/tests/suite/managed_proxy.rs +++ b/codex-rs/linux-sandbox/tests/suite/managed_proxy.rs @@ -417,20 +417,20 @@ async fn ingress_routes_parent_connection_into_sandbox_local_server() { listener.as_raw_fd().to_string(), ); - let server_script = format!( - "import http.server\n\ - class Handler(http.server.BaseHTTPRequestHandler):\n\ - def do_GET(self):\n\ - body = b'ingress-ok'\n\ - self.send_response(200)\n\ - self.send_header('Content-Length', str(len(body)))\n\ - self.end_headers()\n\ - self.wfile.write(body)\n\ - def log_message(self, format, *args):\n\ - pass\n\ - server = http.server.ThreadingHTTPServer(('127.0.0.1', {ingress_port}), Handler)\n\ - server.handle_request()\n" - ); + let server_script = format!(concat!( + "import http.server\n", + "class Handler(http.server.BaseHTTPRequestHandler):\n", + " def do_GET(self):\n", + " body = b'ingress-ok'\n", + " self.send_response(200)\n", + " self.send_header('Content-Length', str(len(body)))\n", + " self.end_headers()\n", + " self.wfile.write(body)\n", + " def log_message(self, format, *args):\n", + " pass\n", + "server = http.server.ThreadingHTTPServer(('127.0.0.1', {ingress_port}), Handler)\n", + "server.handle_request()\n", + )); let command = ["python3", "-c", server_script.as_str()]; let mut cmd = linux_sandbox_command( &command,