a7n-platform 0.18.0

Native desktop backends for the Apeirogon software KVM
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40

// SPDX-License-Identifier: GPL-3.0-or-later

use std::thread;
use std::time::{Duration, Instant};

use a7n_core::clipboard::Generation;
use tokio::sync::{mpsc, oneshot};

use super::PasteRequest;

const REPLY_INTERVAL: Duration = Duration::from_millis(10);

/// Blocks until the daemon answers or `timeout` passes.
pub(super) fn fetch(
    generation: Generation,
    item_index: u32,
    timeout: Duration,
    pastes: &mpsc::Sender<PasteRequest>,
) -> Option<Vec<u8>> {
    let (reply, mut receiver) = oneshot::channel();
    pastes
        .try_send(PasteRequest {
            generation,
            item_index,
            reply,
        })
        .ok()?;
    let deadline = Instant::now() + timeout;
    loop {
        match receiver.try_recv() {
            Ok(bytes) => return bytes,
            Err(oneshot::error::TryRecvError::Empty) if Instant::now() < deadline => {
                thread::sleep(
                    REPLY_INTERVAL.min(deadline.saturating_duration_since(Instant::now())),
                );
            }
            _ => return None,
        }
    }
}