diff options
Diffstat (limited to 'ext/fs')
-rw-r--r-- | ext/fs/30_fs.js | 26 | ||||
-rw-r--r-- | ext/fs/lib.rs | 4 | ||||
-rw-r--r-- | ext/fs/ops.rs | 44 |
3 files changed, 58 insertions, 16 deletions
diff --git a/ext/fs/30_fs.js b/ext/fs/30_fs.js index 2136d88f6..f752c559a 100644 --- a/ext/fs/30_fs.js +++ b/ext/fs/30_fs.js @@ -15,12 +15,16 @@ const { op_fs_cwd, op_fs_fdatasync_async, op_fs_fdatasync_sync, + op_fs_fdatasync_async_unstable, + op_fs_fdatasync_sync_unstable, op_fs_flock_async, op_fs_flock_sync, op_fs_fstat_async, op_fs_fstat_sync, op_fs_fsync_async, op_fs_fsync_sync, + op_fs_fsync_async_unstable, + op_fs_fsync_sync_unstable, op_fs_ftruncate_async, op_fs_ftruncate_sync, op_fs_funlock_async, @@ -558,20 +562,10 @@ async function symlink( } function fdatasyncSync(rid) { - internals.warnOnDeprecatedApi( - "Deno.fdatasyncSync()", - new Error().stack, - "Use `file.dataSyncSync()` instead.", - ); op_fs_fdatasync_sync(rid); } async function fdatasync(rid) { - internals.warnOnDeprecatedApi( - "Deno.fdatasync()", - new Error().stack, - "Use `await file.dataSync()` instead.", - ); await op_fs_fdatasync_async(rid); } @@ -718,12 +712,12 @@ class FsFile { return fstatSync(this.#rid); } - async dataSync() { - await op_fs_fdatasync_async(this.#rid); + async syncData() { + await op_fs_fdatasync_async_unstable(this.#rid); } - dataSyncSync() { - op_fs_fdatasync_sync(this.#rid); + syncDataSync() { + op_fs_fdatasync_sync_unstable(this.#rid); } close() { @@ -745,11 +739,11 @@ class FsFile { } async sync() { - await op_fs_fsync_async(this.#rid); + await op_fs_fsync_async_unstable(this.#rid); } syncSync() { - op_fs_fsync_sync(this.#rid); + op_fs_fsync_sync_unstable(this.#rid); } async utime(atime, mtime) { diff --git a/ext/fs/lib.rs b/ext/fs/lib.rs index 5cfa6e5d9..0bf5462f8 100644 --- a/ext/fs/lib.rs +++ b/ext/fs/lib.rs @@ -130,8 +130,12 @@ deno_core::extension!(deno_fs, op_fs_seek_async, op_fs_fdatasync_sync, op_fs_fdatasync_async, + op_fs_fdatasync_sync_unstable, + op_fs_fdatasync_async_unstable, op_fs_fsync_sync, op_fs_fsync_async, + op_fs_fsync_sync_unstable, + op_fs_fsync_async_unstable, op_fs_fstat_sync, op_fs_fstat_async, op_fs_flock_sync, diff --git a/ext/fs/ops.rs b/ext/fs/ops.rs index e41d3308f..e8573229b 100644 --- a/ext/fs/ops.rs +++ b/ext/fs/ops.rs @@ -1349,6 +1349,17 @@ pub fn op_fs_fdatasync_sync( Ok(()) } +#[op2(fast)] +pub fn op_fs_fdatasync_sync_unstable( + state: &mut OpState, + #[smi] rid: ResourceId, +) -> Result<(), AnyError> { + check_unstable(state, "Deno.FsFile.syncDataSync"); + let file = FileResource::get_file(state, rid)?; + file.datasync_sync()?; + Ok(()) +} + #[op2(async)] pub async fn op_fs_fdatasync_async( state: Rc<RefCell<OpState>>, @@ -1359,6 +1370,17 @@ pub async fn op_fs_fdatasync_async( Ok(()) } +#[op2(async)] +pub async fn op_fs_fdatasync_async_unstable( + state: Rc<RefCell<OpState>>, + #[smi] rid: ResourceId, +) -> Result<(), AnyError> { + check_unstable(&state.borrow(), "Deno.FsFile.syncData"); + let file = FileResource::get_file(&state.borrow(), rid)?; + file.datasync_async().await?; + Ok(()) +} + #[op2(fast)] pub fn op_fs_fsync_sync( state: &mut OpState, @@ -1369,6 +1391,17 @@ pub fn op_fs_fsync_sync( Ok(()) } +#[op2(fast)] +pub fn op_fs_fsync_sync_unstable( + state: &mut OpState, + #[smi] rid: ResourceId, +) -> Result<(), AnyError> { + check_unstable(state, "Deno.FsFile.syncSync"); + let file = FileResource::get_file(state, rid)?; + file.sync_sync()?; + Ok(()) +} + #[op2(async)] pub async fn op_fs_fsync_async( state: Rc<RefCell<OpState>>, @@ -1379,6 +1412,17 @@ pub async fn op_fs_fsync_async( Ok(()) } +#[op2(async)] +pub async fn op_fs_fsync_async_unstable( + state: Rc<RefCell<OpState>>, + #[smi] rid: ResourceId, +) -> Result<(), AnyError> { + check_unstable(&state.borrow(), "Deno.FsFile.sync"); + let file = FileResource::get_file(&state.borrow(), rid)?; + file.sync_async().await?; + Ok(()) +} + #[op2(fast)] pub fn op_fs_fstat_sync( state: &mut OpState, |