Method open

src/executor/shared/fifo.rs:115–132

(ctl_path: &Path, ack_path: &Path)

    }

    pub fn open(ctl_path: &Path, ack_path: &Path) -> anyhow::Result<Self> {
        create_fifo(ctl_path)?;
        create_fifo(ack_path)?;

        let ack_fifo = open_fifo_sender(ack_path)?;
        let ctl_fifo = open_fifo_receiver(ctl_path)?;

        let codec = LengthDelimitedCodec::builder()
            .length_field_length(4)
            .little_endian()
            .new_codec();
        let ctl_reader = FramedRead::new(ctl_fifo, codec);

        Ok(Self {
            ack_fifo,
            ctl_reader,
        })
    }

    pub async fn recv_cmd(&mut self) -> anyhow::Result<FifoCommand> {
        let bytes = self