session_lock/
session_lock.rs

1use std::time::Duration;
2use tokio::{sync::{mpsc, oneshot}, time::sleep};
3use wayland_protocols_async::ext_session_lock_v1::handler::{SessionLockHandler, SessionLockMessage};
4
5#[tokio::main]
6async fn main() {
7    // create mpsc channel for interacting with the session_lock handler
8    let (session_lock_msg_tx, mut session_lock_msg_rx) = mpsc::channel(128);
9
10    // create mpsc channel for receiving events from the session_lock handler
11    let (session_lock_event_tx, mut session_lock_event_rx) = mpsc::channel(128);
12    
13    // create the handler instance
14    let mut session_lock_handler = SessionLockHandler::new(session_lock_event_tx);
15
16
17    // start the session_lock handler
18    let session_lock_t = tokio::spawn(async move {
19        let _ = session_lock_handler.run(session_lock_msg_rx).await;
20    });
21
22    // receive all session_lock events
23    let session_lock_event_t = tokio::spawn(async move {
24        loop {
25            let msg = session_lock_event_rx.recv().await;
26            if msg.is_none() {
27                continue;
28            }
29            println!("received session_lock_event event={:?}", msg);
30        }
31    });
32
33    // send an event
34    let _ = tokio::spawn(async move {
35        // trigger lock
36        let _ = sleep(Duration::from_secs(5)).await;
37        let (tx, rx) = oneshot::channel();
38        let _ =session_lock_msg_tx.send(SessionLockMessage::Lock { wl_surface: None, reply_to: tx }).await;
39
40        let res = rx.await.expect("no reply from session_lock handler");
41        println!("locked session {:?}", res);
42
43        // trigger unlock
44        let _ = sleep(Duration::from_secs(5)).await;
45        let (tx, rx) = oneshot::channel();
46        let _ =session_lock_msg_tx.send(SessionLockMessage::Unlock { reply_to: tx }).await;
47
48        let res = rx.await.expect("no reply from session_lock handler");
49        println!("unlocked session {:?}", res);
50    });
51
52    let _ = session_lock_t.await.unwrap();
53    let _ = session_lock_event_t.await.unwrap();
54}
session_lock/session_lock.rs

session_lock/
session_lock.rs
