Integration test of used IpcReceiver transmission

Author: glyn

src/bin/spawn_used_receiver_sender_client.rs

@@ -0,0 +1,31 @@
+// Copyright 2025 The Servo Project Developers. See the COPYRIGHT
+// file at the top-level directory of this distribution.
+//
+// Licensed under the Apache License, Version 2.0 <LICENSE-APACHE or
+// http://www.apache.org/licenses/LICENSE-2.0> or the MIT license
+// <LICENSE-MIT or http://opensource.org/licenses/MIT>, at your
+// option. This file may not be copied, modified, or distributed
+// except according to those terms.
+
+use ipc_channel::ipc::{self, IpcReceiver, IpcSender};
+use std::{env, process};
+
+/// Test executable which connects to the one-shot server with name
+/// passed in as an argument and then sends a receiver which it has
+/// already used to the server and then sends a test message to the
+/// receiver.
+fn main() {
+    let args: Vec<String> = env::args().collect();
+    let token = args.get(1).expect("missing argument");
+
+    let (sub_tx, sub_rx) = ipc::channel().unwrap();
+    sub_tx.send("test message".to_string()).expect("send failed");
+    let msg = sub_rx.recv().unwrap();
+    assert_eq!("test message", msg);
+
+    let tx: IpcSender<IpcReceiver<String>> = IpcSender::connect(token.to_string()).expect("connect failed");
+    tx.send(sub_rx).expect("send failed");
+    sub_tx.send("test message".to_string()).expect("send failed");
+
+    process::exit(0);
+}

tests/integration_test.rs

@@ -73,3 +73,35 @@ fn spawn_receiver_sender_client() {
         result.code().expect("exit status code not available")
     );
 }
+
+/// Test spawing a process which then acts as a client to a
+/// one-shot server in the parent process. The client sends a
+/// receiver, which it has already used, and then send a
+/// message to the receiver.
+#[cfg(not(any(feature = "force-inprocess", target_os = "android", target_os = "ios")))]
+#[test]
+fn spawn_used_receiver_sender_client() {
+    let executable_path: String = env!("CARGO_BIN_EXE_spawn_used_receiver_sender_client").to_string();
+
+    let (server, token) =
+        IpcOneShotServer::<IpcReceiver<String>>::new().expect("Failed to create IPC one-shot server.");
+
+    let mut command = process::Command::new(executable_path);
+    let child_process = command.arg(token);
+
+    let mut child = child_process
+        .spawn()
+        .expect("Failed to start child process");
+
+    let (_rx, sub_rx) = server.accept().expect("accept failed");
+
+    let msg = sub_rx.recv().unwrap();
+    assert_eq!("test message", msg);
+
+    let result = child.wait().expect("wait for child process failed");
+    assert!(
+        result.success(),
+        "child process failed with exit status code {}",
+        result.code().expect("exit status code not available")
+    );
+}