From cdba5ab6fc633606aaa6f95d0825832c3ac6fe5c Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Bartek=20Iwa=C5=84czuk?= Date: Sat, 8 Feb 2020 20:34:31 +0100 Subject: refactor: rename ThreadSafeState, use RefCell for mutable state (#3931) * rename ThreadSafeState to State * State stores InnerState wrapped in Rc and RefCell --- cli/ops/repl.rs | 24 +++++++++++++----------- 1 file changed, 13 insertions(+), 11 deletions(-) (limited to 'cli/ops/repl.rs') diff --git a/cli/ops/repl.rs b/cli/ops/repl.rs index 9b47f262a..d7c94a56e 100644 --- a/cli/ops/repl.rs +++ b/cli/ops/repl.rs @@ -4,12 +4,12 @@ use crate::deno_error::bad_resource; use crate::ops::json_op; use crate::repl; use crate::repl::Repl; -use crate::state::ThreadSafeState; +use crate::state::State; use deno_core::*; use std::sync::Arc; use std::sync::Mutex; -pub fn init(i: &mut Isolate, s: &ThreadSafeState) { +pub fn init(i: &mut Isolate, s: &State) { i.register_op( "repl_start", s.core_op(json_op(s.stateful_op(op_repl_start))), @@ -29,7 +29,7 @@ struct ReplStartArgs { } fn op_repl_start( - state: &ThreadSafeState, + state: &State, args: Value, _zero_copy: Option, ) -> Result { @@ -37,11 +37,11 @@ fn op_repl_start( debug!("op_repl_start {}", args.history_file); let history_path = - repl::history_path(&state.global_state.dir, &args.history_file); + repl::history_path(&state.borrow().global_state.dir, &args.history_file); let repl = repl::Repl::new(history_path); + let mut state = state.borrow_mut(); let resource = ReplResource(Arc::new(Mutex::new(repl))); - let mut table = state.lock_resource_table(); - let rid = table.add("repl", Box::new(resource)); + let rid = state.resource_table.add("repl", Box::new(resource)); Ok(JsonOp::Sync(json!(rid))) } @@ -52,7 +52,7 @@ struct ReplReadlineArgs { } fn op_repl_readline( - state: &ThreadSafeState, + state: &State, args: Value, _zero_copy: Option, ) -> Result { @@ -60,12 +60,14 @@ fn op_repl_readline( let rid = args.rid as u32; let prompt = args.prompt; debug!("op_repl_readline {} {}", rid, prompt); - let state = state.clone(); + let state = state.borrow(); + let resource = state + .resource_table + .get::(rid) + .ok_or_else(bad_resource)?; + let repl = resource.0.clone(); blocking_json(false, move || { - let table = state.lock_resource_table(); - let resource = table.get::(rid).ok_or_else(bad_resource)?; - let repl = resource.0.clone(); let line = repl.lock().unwrap().readline(&prompt)?; Ok(json!(line)) }) -- cgit v1.2.3