fixes

Author: Zoxc

src/Cargo.lock

@@ -16,7 +16,7 @@ graphviz = { path = "../libgraphviz" }
 jobserver = "0.1"
 log = "0.3"
 rayon = { git = "https://github.com/Zoxc/rayon.git", branch = "fiber" }
-rayon-core = { git = "https://github.com/Zoxc/rayon.git", branch = "fiber", features=["debug", "tlv"] }
+rayon-core = { git = "https://github.com/Zoxc/rayon.git", branch = "fiber", features=["tlv"] }
 scoped-tls = { git = "https://github.com/Zoxc/scoped-tls.git", features=["nightly"] }
 owning_ref = { git = "https://github.com/Zoxc/owning-ref-rs.git" }
 rustc_back = { path = "../librustc_back" }

src/librustc/Cargo.toml

@@ -86,7 +86,6 @@ extern crate x86;
 extern crate owning_ref;
 extern crate rustc_back;
 #[macro_use] extern crate rustc_data_structures;
-#[macro_use] extern crate lazy_static;
 extern crate serialize;
 extern crate rustc_const_math;
 extern crate rustc_errors as errors;

src/librustc/lib.rs

@@ -45,20 +45,20 @@ impl<'tcx> QueryJob<'tcx> {
     }
 
     pub fn await(&self) {
-        #[cfg(parallel_queries)]
+        /*#[cfg(parallel_queries)]
         registry::in_worker(|worker, _| {
             unsafe {
                 worker.wait_until(&self.latch);
             }
-        });
+        });*/
     }
 
     pub fn signal_complete(&self) {
-        #[cfg(parallel_queries)]
+        /*#[cfg(parallel_queries)]
         {
             self.latch.set();
             Registry::current().signal();
-        }
+        }*/
     }
 }
 

src/librustc/ty/maps/job.rs

@@ -19,7 +19,6 @@ use ty::maps::Query; // NB: actually generated by the macros in this file
 use ty::maps::config::QueryDescription;
 use ty::maps::job::QueryResult;
 use ty::item_path;
-use std::sync::atomic::AtomicUsize;
 
 use rustc_data_structures::fx::{FxHashMap};
 use rustc_data_structures::sync::LockGuard;
@@ -169,8 +168,6 @@ macro_rules! profq_key {
     }
 }
 
-pub static QUERY_DEPTH: AtomicUsize = AtomicUsize::new(0);
-
 macro_rules! define_maps {
     (<$tcx:tt>
      $($(#[$attr:meta])*
@@ -182,8 +179,6 @@ macro_rules! define_maps {
         use std::mem;
         use std::panic;
         use errors::Diagnostic;
-        use ty::maps::plumbing::QUERY_DEPTH;
-        use std::sync::atomic::Ordering;
         use rayon_core;
 
         define_map_struct! {
@@ -298,19 +293,6 @@ macro_rules! define_maps {
                     } else {
                         break
                     };
-                    lazy_static! {
-                        static ref LOG: bool = ::std::env::var("QUERY_LOG").is_ok();
-                    }
-
-                    if *LOG {
-                        println!("({}) waiting on query {:?} latch {:x}",
-                        QUERY_DEPTH.load(Ordering::SeqCst),
-                        Query::$name(Clone::clone(&key)), &job.latch as *const _ as usize);
-                        for i in tcx.query().stack.iter() {
-                            println!("    query stack entry {:?}", i);
-
-                        }
-                    }
                     // If there is a cycle, waiting will never complete
                     tcx.cycle_check(span, &Query::$name(Clone::clone(&key)))?;
                     job.await();
@@ -441,25 +423,11 @@ macro_rules! define_maps {
 
                 tcx.cycle_check(span, &query)?;
 
-                lazy_static! {
-                    static ref LOG: bool = ::std::env::var("QUERY_LOG").is_ok();
-                }
-
                 let entry = (span, query);
                 let stack = tcx.query().stack.iter().cloned().chain(iter::once(entry)).collect();
                 let job = Lrc::new(QueryJob::new(stack, true, false));
                 job.start();
 
-                if *LOG {
-                    println!("({}) starting query {:?} latch {:x}",
-                    QUERY_DEPTH.load(Ordering::SeqCst),
-                       query.clone(), &job.latch as *const _ as usize);
-                    for i in tcx.query().stack.iter() {
-                        println!("    query stack entry {:?}", i);
-
-                    }
-                }
-                QUERY_DEPTH.fetch_add(1, Ordering::SeqCst);
 
                 #[cfg(parallel_queries)]
                 {
@@ -501,12 +469,6 @@ macro_rules! define_maps {
                     r
                 };
 
-                if *LOG {
-                    println!("ending query {:?}", query.clone());
-                }
-
-                QUERY_DEPTH.fetch_sub(1, Ordering::SeqCst);
-
                 let diagnostics: Vec<_> =  {
                     let mut diagnostics = job.diagnostics.lock();
                     let diagnostics: Vec<_> = diagnostics.drain(..).collect();

src/librustc/ty/maps/plumbing.rs

@@ -42,7 +42,7 @@ use std::fmt;
 use std::hash::{Hash, Hasher};
 use std::iter::FromIterator;
 use std::ops::Deref;
-use rustc_data_structures::sync::{Send, Sync, Lrc};
+use rustc_data_structures::sync::{par_iter, Send, Sync, Lrc};
 use std::slice;
 use std::vec::IntoIter;
 use std::mem;
@@ -2098,17 +2098,9 @@ impl<'a, 'gcx, 'tcx> TyCtxt<'a, 'gcx, 'tcx> {
     }
 
     pub fn par_body_owners<F: Fn(DefId) + Sync + Send>(self, f: F) {
-        #[cfg(not(parallel_queries))]
-        self.body_owners().for_each(|def_id| f(def_id));
-
-        #[cfg(parallel_queries)]
-        {
-            use rayon::prelude::*;
-            self.hir.krate()
-                    .body_ids
-                    .par_iter()
-                    .for_each(|&body_id| f(self.hir.body_owner_def_id(body_id)));
-        }
+        par_iter(&self.hir.krate().body_ids).for_each(|&body_id| {
+            f(self.hir.body_owner_def_id(body_id))
+        });
     }
 
     pub fn expr_span(self, id: NodeId) -> Span {