INNER CODE UNIT · Rust
start_dataplane_forward_writes_the_preamble_then_the_request
Augani/dory · dory-core/ffi/src/lib.rs:422
async fn start_dataplane_forward_writes_the_preamble_then_the_request() {
use dory_proto::preamble::{read_preamble, Direction};
use std::os::unix::io::IntoRawFd;
use std::sync::Mutex;
use tokio::io::{AsyncReadExt, AsyncWriteExt};
use tokio::net::{UnixListener, UnixStream};
let base = std::env::temp_dir();
let pid = std::process::id();
let sock = base.join(format!("dory-ffi-fwd-serve-{pid}.sock"));
let fwd = base.join(format!("dory-ffi-fwd-{pid}.sock"));
let _ = std::fs::remove_file(&sock);
let _ = std::fs::remove_file(&fwd);
let fwd_listener = UnixListener::bind(&fwd).unwrap();
let got_preamble = std::sync::Arc::new(Mutex::new(None));
let got_request = std::sync::Arc::new(Mutex::new(Vec::new()));
let (gp, gr) = (got_preamble.clone(), got_request.clone());