1 files changed, 0 insertions, 110 deletions
diff --git a/src/isolate_state.rs b/src/isolate_state.rs
deleted file mode 100644
index 4cc010389..000000000
--- a/src/isolate_state.rs
+++ /dev/null
@@ -1,110 +0,0 @@
-// Copyright 2018-2019 the Deno authors. All rights reserved. MIT license.
-use crate::cli::Buf;
-use crate::deno_dir;
-use crate::flags;
-use crate::global_timer::GlobalTimer;
-use crate::modules::Modules;
-use futures::sync::mpsc as async_mpsc;
-use std;
-use std::env;
-use std::sync::atomic::{AtomicUsize, Ordering};
-use std::sync::Mutex;
-
-pub type WorkerSender = async_mpsc::Sender<Buf>;
-pub type WorkerReceiver = async_mpsc::Receiver<Buf>;
-pub type WorkerChannels = (WorkerSender, WorkerReceiver);
-
-// AtomicU64 is currently unstable
-#[derive(Default)]
-pub struct Metrics {
-  pub ops_dispatched: AtomicUsize,
-  pub ops_completed: AtomicUsize,
-  pub bytes_sent_control: AtomicUsize,
-  pub bytes_sent_data: AtomicUsize,
-  pub bytes_received: AtomicUsize,
-  pub resolve_count: AtomicUsize,
-}
-
-// Isolate cannot be passed between threads but IsolateState can.
-// IsolateState satisfies Send and Sync.
-// So any state that needs to be accessed outside the main V8 thread should be
-// inside IsolateState.
-#[cfg_attr(feature = "cargo-clippy", allow(stutter))]
-pub struct IsolateState {
-  pub dir: deno_dir::DenoDir,
-  pub argv: Vec<String>,
-  pub flags: flags::DenoFlags,
-  pub metrics: Metrics,
-  pub modules: Mutex<Modules>,
-  pub worker_channels: Option<Mutex<WorkerChannels>>,
-  pub global_timer: Mutex<GlobalTimer>,
-}
-
-impl IsolateState {
-  pub fn new(
-    flags: flags::DenoFlags,
-    argv_rest: Vec<String>,
-    worker_channels: Option<WorkerChannels>,
-  ) -> Self {
-    let custom_root = env::var("DENO_DIR").map(|s| s.into()).ok();
-
-    Self {
-      dir: deno_dir::DenoDir::new(flags.reload, flags.recompile, custom_root)
-        .unwrap(),
-      argv: argv_rest,
-      flags,
-      metrics: Metrics::default(),
-      modules: Mutex::new(Modules::new()),
-      worker_channels: worker_channels.map(Mutex::new),
-      global_timer: Mutex::new(GlobalTimer::new()),
-    }
-  }
-
-  pub fn main_module(&self) -> Option<String> {
-    if self.argv.len() <= 1 {
-      None
-    } else {
-      let specifier = self.argv[1].clone();
-      let referrer = ".";
-      match self.dir.resolve_module_url(&specifier, referrer) {
-        Ok(url) => Some(url.to_string()),
-        Err(e) => {
-          debug!("Potentially swallowed error {}", e);
-          None
-        }
-      }
-    }
-  }
-
-  #[cfg(test)]
-  pub fn mock() -> IsolateState {
-    let argv = vec![String::from("./deno"), String::from("hello.js")];
-    // For debugging: argv.push_back(String::from("-D"));
-    let (flags, rest_argv, _) = flags::set_flags(argv).unwrap();
-    IsolateState::new(flags, rest_argv, None)
-  }
-
-  pub fn metrics_op_dispatched(
-    &self,
-    bytes_sent_control: usize,
-    bytes_sent_data: usize,
-  ) {
-    self.metrics.ops_dispatched.fetch_add(1, Ordering::SeqCst);
-    self
-      .metrics
-      .bytes_sent_control
-      .fetch_add(bytes_sent_control, Ordering::SeqCst);
-    self
-      .metrics
-      .bytes_sent_data
-      .fetch_add(bytes_sent_data, Ordering::SeqCst);
-  }
-
-  pub fn metrics_op_completed(&self, bytes_received: usize) {
-    self.metrics.ops_completed.fetch_add(1, Ordering::SeqCst);
-    self
-      .metrics
-      .bytes_received
-      .fetch_add(bytes_received, Ordering::SeqCst);
-  }
-}