diff options
author | andy finch <andyfinch7@gmail.com> | 2019-03-18 20:03:37 -0400 |
---|---|---|
committer | Ryan Dahl <ry@tinyclouds.org> | 2019-03-18 20:03:37 -0400 |
commit | cdfd32dd74d6286afe99fb5400e3dc0e9f2cec49 (patch) | |
tree | e8daa342c70ee472de28158d5448ed2078d0d9e9 /src/workers.rs | |
parent | 34a2aa4de6cfe334cf0d26620d244d5c66a976a4 (diff) |
Re-implement init scripts in core (#1958)
Re-enables arm64 CI test
Diffstat (limited to 'src/workers.rs')
-rw-r--r-- | src/workers.rs | 20 |
1 files changed, 10 insertions, 10 deletions
diff --git a/src/workers.rs b/src/workers.rs index 8393de222..edded7756 100644 --- a/src/workers.rs +++ b/src/workers.rs @@ -3,7 +3,6 @@ use crate::cli::Buf; use crate::cli::Cli; use crate::flags::DenoFlags; use crate::isolate::Isolate; -use crate::isolate_init::IsolateInit; use crate::isolate_state::IsolateState; use crate::isolate_state::WorkerChannels; use crate::js_errors::JSErrorColor; @@ -11,6 +10,7 @@ use crate::permissions::DenoPermissions; use crate::resources; use crate::tokio_util; use deno_core::JSError; +use deno_core::StartupData; use futures::future::lazy; use futures::sync::mpsc; use futures::sync::oneshot; @@ -26,7 +26,7 @@ pub struct Worker { impl Worker { pub fn new( - init: IsolateInit, + startup_data: Option<StartupData>, flags: DenoFlags, argv: Vec<String>, permissions: DenoPermissions, @@ -40,7 +40,7 @@ impl Worker { let state = Arc::new(IsolateState::new(flags, argv, Some(internal_channels))); - let cli = Cli::new(init, state, permissions); + let cli = Cli::new(startup_data, state, permissions); let isolate = Isolate::new(cli); let worker = Worker { isolate }; @@ -62,7 +62,7 @@ impl Future for Worker { } pub fn spawn( - init: IsolateInit, + startup_data: Option<StartupData>, state: &IsolateState, js_source: String, permissions: DenoPermissions, @@ -81,7 +81,7 @@ pub fn spawn( .spawn(move || { tokio_util::run(lazy(move || { let (mut worker, external_channels) = - Worker::new(init, flags, argv, permissions); + Worker::new(startup_data, flags, argv, permissions); let resource = resources::add_worker(external_channels); p.send(resource.clone()).unwrap(); @@ -113,13 +113,13 @@ pub fn spawn( #[cfg(test)] mod tests { use super::*; - use crate::isolate_init; + use crate::startup_data; #[test] fn test_spawn() { - let isolate_init = isolate_init::compiler_isolate_init(); + let startup_data = startup_data::compiler_isolate_init(); let resource = spawn( - isolate_init, + Some(startup_data), &IsolateState::mock(), r#" onmessage = function(e) { @@ -154,9 +154,9 @@ mod tests { #[test] fn removed_from_resource_table_on_close() { - let isolate_init = isolate_init::compiler_isolate_init(); + let startup_data = startup_data::compiler_isolate_init(); let resource = spawn( - isolate_init, + Some(startup_data), &IsolateState::mock(), "onmessage = () => close();".into(), DenoPermissions::default(), |