qsu 0.10.1

Service subsystem utilities and runtime wrapper.
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
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109

mod apps;
mod err;

use std::sync::Arc;

use parking_lot::Mutex;

use qsu::rt::RunCtx;

const SVCNAME: &str = "svctest";

/// Make sure that `init()`, `run()` and `shutdown()` are called for the sync
/// case.
#[test]
fn all_sync_callbacks() {
  let runctx = RunCtx::new(SVCNAME).test_mode();

  let visited = apps::Visited::default();

  assert!(!visited.init);
  assert!(!visited.run);
  assert!(!visited.shutdown);

  let visited = Arc::new(Mutex::new(visited));

  let svcevt_handler = Box::new(move |_msg| {});
  let rt_handler = Box::new(apps::MySyncService {
    visited: Arc::clone(&visited),
    ..Default::default()
  });
  let Ok(()) = runctx.run_sync(svcevt_handler, rt_handler) else {
    panic!("run_sync() unexpectedly failed");
  };

  let visited = Arc::into_inner(visited)
    .expect("Unable to into_inner Arc")
    .into_inner();
  assert!(visited.init);
  assert!(visited.run);
  assert!(visited.shutdown);
}

/// Make sure that `init()`, `run()` and `shutdown()` are called for the tokio
/// case.
#[cfg(feature = "tokio")]
#[test]
fn all_tokio_callbacks() {
  let runctx = RunCtx::new(SVCNAME).test_mode();

  let visited = apps::Visited::default();

  assert!(!visited.init);
  assert!(!visited.run);
  assert!(!visited.shutdown);

  let visited = Arc::new(Mutex::new(visited));

  let svcevt_handler = Box::new(move |_msg| {});
  let rt_handler = Box::new(apps::MyTokioService {
    visited: Arc::clone(&visited),
    ..Default::default()
  });
  let Ok(()) = runctx.run_tokio(None, svcevt_handler, rt_handler) else {
    panic!("run_sync() unexpectedly failed");
  };

  let visited = Arc::into_inner(visited)
    .expect("Unable to into_inner Arc")
    .into_inner();
  assert!(visited.init);
  assert!(visited.run);
  assert!(visited.shutdown);
}


/// Make sure that `init()`, `run()` and `shutdown()` are called for the Rocket
/// case.
#[cfg(feature = "rocket")]
#[test]
fn all_rocket_callbacks() {
  let runctx = RunCtx::new(SVCNAME).test_mode();

  let visited = apps::Visited::default();

  assert!(!visited.init);
  assert!(!visited.run);
  assert!(!visited.shutdown);

  let visited = Arc::new(Mutex::new(visited));

  let svcevt_handler = Box::new(move |_msg| {});
  let rt_handler = Box::new(apps::MyRocketService {
    visited: Arc::clone(&visited),
    ..Default::default()
  });

  let Ok(()) = runctx.run_rocket(svcevt_handler, rt_handler) else {
    panic!("run_sync() unexpectedly failed");
  };

  let visited = Arc::into_inner(visited)
    .expect("Unable to into_inner Arc")
    .into_inner();
  assert!(visited.init);
  assert!(visited.run);
  assert!(visited.shutdown);
}

// vim: set ft=rust et sw=2 ts=2 sts=2 cinoptions=2 tw=79 :