a9c1152c4b
This commit removes the `std::local_data` module in favor of a new `std::thread_local` module providing thread local storage. The module provides two variants of TLS: one which owns its contents and one which is based on scoped references. Each implementation has pros and cons listed in the documentation. Both flavors have accessors through a function called `with` which yield a reference to a closure provided. Both flavors also panic if a reference cannot be yielded and provide a function to test whether an access would panic or not. This is an implementation of [RFC 461][rfc] and full details can be found in that RFC. This is a breaking change due to the removal of the `std::local_data` module. All users can migrate to the new thread local system like so: thread_local!(static FOO: Rc<RefCell<Option<T>>> = Rc::new(RefCell::new(None))) The old `local_data` module inherently contained the `Rc<RefCell<Option<T>>>` as an implementation detail which must now be explicitly stated by users. [rfc]: https://github.com/rust-lang/rfcs/pull/461 [breaking-change]
215 lines
5.9 KiB
Rust
215 lines
5.9 KiB
Rust
// Copyright 2012-2014 The Rust Project Developers. See the COPYRIGHT
|
|
// file at the top-level directory of this distribution and at
|
|
// http://rust-lang.org/COPYRIGHT.
|
|
//
|
|
// Licensed under the Apache License, Version 2.0 <LICENSE-APACHE or
|
|
// http://www.apache.org/licenses/LICENSE-2.0> or the MIT license
|
|
// <LICENSE-MIT or http://opensource.org/licenses/MIT>, at your
|
|
// option. This file may not be copied, modified, or distributed
|
|
// except according to those terms.
|
|
|
|
#![allow(non_camel_case_types)]
|
|
|
|
use std::cell::{RefCell, Cell};
|
|
use std::collections::HashMap;
|
|
use std::fmt::Show;
|
|
use std::hash::{Hash, Hasher};
|
|
use std::time::Duration;
|
|
|
|
use syntax::ast;
|
|
use syntax::visit;
|
|
use syntax::visit::Visitor;
|
|
|
|
// Useful type to use with `Result<>` indicate that an error has already
|
|
// been reported to the user, so no need to continue checking.
|
|
#[deriving(Clone,Show)]
|
|
pub struct ErrorReported;
|
|
|
|
pub fn time<T, U>(do_it: bool, what: &str, u: U, f: |U| -> T) -> T {
|
|
thread_local!(static DEPTH: Cell<uint> = Cell::new(0));
|
|
if !do_it { return f(u); }
|
|
|
|
let old = DEPTH.with(|slot| {
|
|
let r = slot.get();
|
|
slot.set(r + 1);
|
|
r
|
|
});
|
|
|
|
let mut u = Some(u);
|
|
let mut rv = None;
|
|
let dur = Duration::span(|| {
|
|
rv = Some(f(u.take().unwrap()))
|
|
});
|
|
let rv = rv.unwrap();
|
|
|
|
println!("{}time: {}.{:03} \t{}", " ".repeat(old),
|
|
dur.num_seconds(), dur.num_milliseconds() % 1000, what);
|
|
DEPTH.with(|slot| slot.set(old));
|
|
|
|
rv
|
|
}
|
|
|
|
pub fn indent<R: Show>(op: || -> R) -> R {
|
|
// Use in conjunction with the log post-processor like `src/etc/indenter`
|
|
// to make debug output more readable.
|
|
debug!(">>");
|
|
let r = op();
|
|
debug!("<< (Result = {})", r);
|
|
r
|
|
}
|
|
|
|
pub struct Indenter {
|
|
_cannot_construct_outside_of_this_module: ()
|
|
}
|
|
|
|
impl Drop for Indenter {
|
|
fn drop(&mut self) { debug!("<<"); }
|
|
}
|
|
|
|
pub fn indenter() -> Indenter {
|
|
debug!(">>");
|
|
Indenter { _cannot_construct_outside_of_this_module: () }
|
|
}
|
|
|
|
struct LoopQueryVisitor<'a> {
|
|
p: |&ast::Expr_|: 'a -> bool,
|
|
flag: bool,
|
|
}
|
|
|
|
impl<'a, 'v> Visitor<'v> for LoopQueryVisitor<'a> {
|
|
fn visit_expr(&mut self, e: &ast::Expr) {
|
|
self.flag |= (self.p)(&e.node);
|
|
match e.node {
|
|
// Skip inner loops, since a break in the inner loop isn't a
|
|
// break inside the outer loop
|
|
ast::ExprLoop(..) | ast::ExprWhile(..) | ast::ExprForLoop(..) => {}
|
|
_ => visit::walk_expr(self, e)
|
|
}
|
|
}
|
|
}
|
|
|
|
// Takes a predicate p, returns true iff p is true for any subexpressions
|
|
// of b -- skipping any inner loops (loop, while, loop_body)
|
|
pub fn loop_query(b: &ast::Block, p: |&ast::Expr_| -> bool) -> bool {
|
|
let mut v = LoopQueryVisitor {
|
|
p: p,
|
|
flag: false,
|
|
};
|
|
visit::walk_block(&mut v, b);
|
|
return v.flag;
|
|
}
|
|
|
|
struct BlockQueryVisitor<'a> {
|
|
p: |&ast::Expr|: 'a -> bool,
|
|
flag: bool,
|
|
}
|
|
|
|
impl<'a, 'v> Visitor<'v> for BlockQueryVisitor<'a> {
|
|
fn visit_expr(&mut self, e: &ast::Expr) {
|
|
self.flag |= (self.p)(e);
|
|
visit::walk_expr(self, e)
|
|
}
|
|
}
|
|
|
|
// Takes a predicate p, returns true iff p is true for any subexpressions
|
|
// of b -- skipping any inner loops (loop, while, loop_body)
|
|
pub fn block_query(b: &ast::Block, p: |&ast::Expr| -> bool) -> bool {
|
|
let mut v = BlockQueryVisitor {
|
|
p: p,
|
|
flag: false,
|
|
};
|
|
visit::walk_block(&mut v, &*b);
|
|
return v.flag;
|
|
}
|
|
|
|
// K: Eq + Hash<S>, V, S, H: Hasher<S>
|
|
pub fn can_reach<S,H:Hasher<S>,T:Eq+Clone+Hash<S>>(
|
|
edges_map: &HashMap<T,Vec<T>,H>,
|
|
source: T,
|
|
destination: T)
|
|
-> bool
|
|
{
|
|
/*!
|
|
* Determines whether there exists a path from `source` to
|
|
* `destination`. The graph is defined by the `edges_map`, which
|
|
* maps from a node `S` to a list of its adjacent nodes `T`.
|
|
*
|
|
* Efficiency note: This is implemented in an inefficient way
|
|
* because it is typically invoked on very small graphs. If the graphs
|
|
* become larger, a more efficient graph representation and algorithm
|
|
* would probably be advised.
|
|
*/
|
|
|
|
if source == destination {
|
|
return true;
|
|
}
|
|
|
|
// Do a little breadth-first-search here. The `queue` list
|
|
// doubles as a way to detect if we've seen a particular FR
|
|
// before. Note that we expect this graph to be an *extremely
|
|
// shallow* tree.
|
|
let mut queue = vec!(source);
|
|
let mut i = 0;
|
|
while i < queue.len() {
|
|
match edges_map.get(&queue[i]) {
|
|
Some(edges) => {
|
|
for target in edges.iter() {
|
|
if *target == destination {
|
|
return true;
|
|
}
|
|
|
|
if !queue.iter().any(|x| x == target) {
|
|
queue.push((*target).clone());
|
|
}
|
|
}
|
|
}
|
|
None => {}
|
|
}
|
|
i += 1;
|
|
}
|
|
return false;
|
|
}
|
|
|
|
/// Memoizes a one-argument closure using the given RefCell containing
|
|
/// a type implementing MutableMap to serve as a cache.
|
|
///
|
|
/// In the future the signature of this function is expected to be:
|
|
/// ```
|
|
/// pub fn memoized<T: Clone, U: Clone, M: MutableMap<T, U>>(
|
|
/// cache: &RefCell<M>,
|
|
/// f: &|&: T| -> U
|
|
/// ) -> impl |&: T| -> U {
|
|
/// ```
|
|
/// but currently it is not possible.
|
|
///
|
|
/// # Example
|
|
/// ```
|
|
/// struct Context {
|
|
/// cache: RefCell<HashMap<uint, uint>>
|
|
/// }
|
|
///
|
|
/// fn factorial(ctxt: &Context, n: uint) -> uint {
|
|
/// memoized(&ctxt.cache, n, |n| match n {
|
|
/// 0 | 1 => n,
|
|
/// _ => factorial(ctxt, n - 2) + factorial(ctxt, n - 1)
|
|
/// })
|
|
/// }
|
|
/// ```
|
|
#[inline(always)]
|
|
pub fn memoized<T: Clone + Hash<S> + Eq, U: Clone, S, H: Hasher<S>>(
|
|
cache: &RefCell<HashMap<T, U, H>>,
|
|
arg: T,
|
|
f: |T| -> U
|
|
) -> U {
|
|
let key = arg.clone();
|
|
let result = cache.borrow().get(&key).map(|result| result.clone());
|
|
match result {
|
|
Some(result) => result,
|
|
None => {
|
|
let result = f(arg);
|
|
cache.borrow_mut().insert(key, result.clone());
|
|
result
|
|
}
|
|
}
|
|
}
|