rtlola-streamir 0.1.0

A framework for the compilation of stream-based languages through an intermediate representation
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

use std::collections::HashMap;

use crate::ir::{
    memory::{Memory, StreamMemory},
    LivetimeEquivalences, Stmt, StreamReference,
};

use super::{ChangeSet, RewriteError, RewriteRule};

#[derive(Copy, Clone, Debug)]
/// Remove spawn statements when the stream lives for the whole runtime of the monitor
pub struct RemoveClose;

impl RewriteRule for RemoveClose {
    fn rewrite_stmt(
        &self,
        stmt: Stmt,
        memory: &HashMap<StreamReference, Memory>,
        _liveness_equivalences: &LivetimeEquivalences,
    ) -> Result<(Stmt, ChangeSet), RewriteError> {
        match stmt {
            Stmt::Close { sr, .. } => match &memory[&StreamReference::Out(sr)].buffer {
                StreamMemory::NoMemory
                | StreamMemory::Static(_)
                | StreamMemory::Dynamic {
                    buffer: _,
                    has_spawn: _,
                    has_close: false,
                } => Ok((Stmt::Skip, ChangeSet::local_change())),
                StreamMemory::Dynamic {
                    buffer: _,
                    has_spawn: _,
                    has_close: true,
                }
                | StreamMemory::Instances { .. } => Ok((stmt, ChangeSet::default())),
            },
            other => Ok((other, ChangeSet::default())),
        }
    }
}