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

extern crate proc_macro;

extern crate syn;

use proc_macro::TokenStream;
use quote::ToTokens;
use syn::*;

extern crate quote;
use syn::fold::Fold;

/// Inserts `thread_yield` in function so programmer don't need to insert it by hand
#[proc_macro_attribute]
pub fn greenify(_args: TokenStream, input: TokenStream) -> TokenStream {
    let input: ItemFn = parse_macro_input!(input as ItemFn);
    let new_stmt: Stmt = parse(TokenStream::from(quote::quote!(greenie::thread_yield();))).unwrap();
    let f = GreenFolder::new(new_stmt).fold_item_fn(input);
    TokenStream::from(f.to_token_stream())
}

struct GreenFolder {
    #[allow(dead_code)]
    stmt: Stmt,
}

impl GreenFolder {
    pub fn new(s: Stmt) -> GreenFolder {
        Self { stmt: s }
    }

    fn gen_block(&self, old_block: &Block) -> Block {
        /*let mut new_stmts = old_block.stmts.clone();
        new_stmts.insert(0, self.stmt.clone());
        Block {
            stmts: new_stmts,
            brace_token: old_block.brace_token.clone(),
        };*/
        parse_quote! {
            {
                greenie::yield_thread();
                #old_block
            }
        }
    }
}

impl syn::fold::Fold for GreenFolder {
    fn fold_expr(&mut self, mut expr: Expr) -> Expr {
        let new_expr = match expr {
            Expr::Loop(ExprLoop {
                body,
                attrs,
                label,
                loop_token,
            }) => Expr::Loop(ExprLoop {
                body: self.gen_block(&body),
                attrs,
                label,
                loop_token,
            }),
            Expr::ForLoop(ExprForLoop { ref mut body, .. }) => {
                *body = self.gen_block(&body);
                expr
            }
            Expr::While(ExprWhile { ref mut body, .. }) => {
                *body = self.gen_block(&body);
                expr
            }
            Expr::Closure(ExprClosure { ref mut body, .. }) => {
                *body = Box::new(self.fold_expr(*body.clone()));
                expr
            }
            _ => syn::fold::fold_expr(self, expr),
        };
        new_expr
    }
    fn fold_block(&mut self, i: Block) -> Block {
        self.gen_block(&i)
    }

    fn fold_item_fn(&mut self, mut i: ItemFn) -> ItemFn {
        let mut stmts = vec![];
        for stmt in i.block.stmts.iter() {
            stmts.push(syn::fold::fold_stmt(self, stmt.clone()));
        }
        i.block.stmts = stmts;
        i.block = Box::new(self.gen_block(&*i.block));
        i
    }
}