dope 0.12.0

The manifold runtime
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

use dope::manifold::{Manifold, timer::Timer};

trait AmbiguousIfSend<A> {}

impl<T: ?Sized> AmbiguousIfSend<()> for T {}

impl<T: ?Sized + Send> AmbiguousIfSend<u8> for T {}

trait AmbiguousIfSync<A> {}

impl<T: ?Sized> AmbiguousIfSync<()> for T {}

impl<T: ?Sized + Sync> AmbiguousIfSync<u8> for T {}

const _: fn() = || {
    fn not_send<T: ?Sized + AmbiguousIfSend<A>, A>() {}
    fn not_sync<T: ?Sized + AmbiguousIfSync<A>, A>() {}
    fn require_manifold<'d, M: Manifold<'d>>() {}
    fn require_send<T: Send>() {}

    not_send::<dope::driver::Driver, _>();
    not_sync::<dope::driver::Driver, _>();
    not_send::<dope::runtime::executor::Executor, _>();
    not_sync::<dope::runtime::executor::Executor, _>();
    not_send::<dope::runtime::executor::Session<'static, 'static>, _>();
    not_sync::<dope::runtime::executor::Session<'static, 'static>, _>();
    not_send::<dope::runtime::launcher::WorkerContext, _>();
    not_sync::<dope::runtime::launcher::WorkerContext, _>();
    not_send::<dope::hash::State, _>();
    not_sync::<dope::hash::State, _>();
    not_sync::<dope::runtime::launcher::Launcher, _>();
    require_send::<dope::runtime::launcher::Launcher>();
    not_sync::<dope::runtime::trigger::ShutdownTrigger, _>();
    require_send::<dope::runtime::trigger::ShutdownTrigger>();
    not_send::<dope::runtime::trigger::SignalShutdown, _>();
    not_sync::<dope::runtime::trigger::SignalShutdown, _>();
    not_send::<dope::driver::OutboundReservation, _>();
    not_sync::<dope::driver::OutboundReservation, _>();
    not_send::<dope::io::file::OsFile, _>();
    not_sync::<dope::io::file::OsFile, _>();
    not_send::<dope::manifold::timer::Ticket, _>();
    not_sync::<dope::manifold::timer::Ticket, _>();
    not_send::<Timer<'static>, _>();
    not_sync::<Timer<'static>, _>();
    require_manifold::<&'static Timer<'static, 7>>();
    not_send::<dope::manifold::connector::source::DialKey, _>();
    not_sync::<dope::manifold::connector::source::DialKey, _>();
};

#[test]
fn local_capabilities_keep_their_layout() {
    type TimerManifold = &'static Timer<'static, 7>;

    assert_eq!(<TimerManifold as Manifold<'static>>::ID, 7);
    assert_eq!(
        size_of::<dope::manifold::timer::Ticket>(),
        2 * size_of::<u32>()
    );
    assert_eq!(
        size_of::<dope::manifold::connector::source::DialKey>(),
        2 * size_of::<u32>()
    );
    assert_eq!(
        size_of::<dope::driver::OutboundReservation>(),
        2 * size_of::<u32>()
    );
}