Function connect_scheduler

components/vmworker/src/lib.rs:425–457

(
    path: &str,
    id: u64,
)

#[cfg(target_family = "unix")]
async fn connect_scheduler(
    path: &str,
    id: u64,
) -> (
    mpsc::UnboundedSender<WorkerMessage>,
    mpsc::UnboundedReceiver<SchedulerMessage>,
) {
    let mut stream = tokio::net::UnixStream::connect(path)
        .await
        .expect("scheduler should have opened socket");

    simpleproto::write_message(&WorkerMessage::Hello(id), &mut stream)
        .await
        .expect("should write to scheduler successfully");

    let (mut reader_half, mut writer_half) = stream.into_split();

    let scheduler_rx = {
        let (tx, rx) = mpsc::unbounded_channel::<SchedulerMessage>();

        tokio::spawn(async move { simpleproto::message_reader(&mut reader_half, tx).await });
        rx
    };

    let scheduler_tx = {
        let (tx, rx) = mpsc::unbounded_channel::<WorkerMessage>();
        tokio::spawn(async move { simpleproto::message_writer(&mut writer_half, rx).await });

        tx
    };

    (scheduler_tx, scheduler_rx)
}

#[cfg(target_family = "windows")]
async fn connect_scheduler(