diff options
Diffstat (limited to 'src')
-rw-r--r-- | src/handlers.rs | 13 | ||||
-rw-r--r-- | src/msg.fbs | 4 |
2 files changed, 8 insertions, 9 deletions
diff --git a/src/handlers.rs b/src/handlers.rs index 2fff5a06f..7d8fafc10 100644 --- a/src/handlers.rs +++ b/src/handlers.rs @@ -49,7 +49,7 @@ pub extern "C" fn msg_from_js(d: *const DenoC, buf: deno_buf) { msg::Any::TimerStart => handle_timer_start, msg::Any::TimerClear => handle_timer_clear, msg::Any::MakeTempDir => handle_make_temp_dir, - msg::Any::MkdirSync => handle_mkdir_sync, + msg::Any::Mkdir => handle_mkdir, msg::Any::ReadFile => handle_read_file, msg::Any::RenameSync => handle_rename_sync, msg::Any::SetEnv => handle_set_env, @@ -418,18 +418,17 @@ fn handle_make_temp_dir(d: *const DenoC, base: &msg::Base) -> Box<Op> { }())) } -fn handle_mkdir_sync(d: *const DenoC, base: &msg::Base) -> Box<Op> { - let msg = base.msg_as_mkdir_sync().unwrap(); - let path = msg.path().unwrap(); +fn handle_mkdir(d: *const DenoC, base: &msg::Base) -> Box<Op> { + let msg = base.msg_as_mkdir().unwrap(); // TODO let mode = msg.mode(); + let path = msg.path().unwrap(); let deno = from_c(d); - debug!("handle_mkdir_sync {}", path); if !deno.flags.allow_write { return odd_future(permission_denied()); } - - // TODO(ry) use blocking + // TODO Use tokio_threadpool. Box::new(futures::future::result(|| -> OpResult { + debug!("handle_mkdir {}", path); // TODO(ry) Use mode. deno_fs::mkdir(Path::new(path))?; Ok(None) diff --git a/src/msg.fbs b/src/msg.fbs index 77aae8ffb..33278a669 100644 --- a/src/msg.fbs +++ b/src/msg.fbs @@ -14,7 +14,7 @@ union Any { FetchRes, MakeTempDir, MakeTempDirRes, - MkdirSync, + Mkdir, ReadFile, ReadFileRes, RenameSync, @@ -167,7 +167,7 @@ table MakeTempDirRes { path: string; } -table MkdirSync { +table Mkdir { path: string; mode: uint; // mode specified by https://godoc.org/os#FileMode |