diff options
Diffstat (limited to 'cli/tests/unit_node/_fs/_fs_fdatasync_test.ts')
-rw-r--r-- | cli/tests/unit_node/_fs/_fs_fdatasync_test.ts | 63 |
1 files changed, 63 insertions, 0 deletions
diff --git a/cli/tests/unit_node/_fs/_fs_fdatasync_test.ts b/cli/tests/unit_node/_fs/_fs_fdatasync_test.ts new file mode 100644 index 000000000..d7ccae927 --- /dev/null +++ b/cli/tests/unit_node/_fs/_fs_fdatasync_test.ts @@ -0,0 +1,63 @@ +// Copyright 2018-2023 the Deno authors. All rights reserved. MIT license. +import { + assertEquals, + fail, +} from "../../../../test_util/std/testing/asserts.ts"; +import { fdatasync, fdatasyncSync } from "node:fs"; + +Deno.test({ + name: + "ASYNC: flush any pending data operations of the given file stream to disk", + async fn() { + const file: string = await Deno.makeTempFile(); + const { rid } = await Deno.open(file, { + read: true, + write: true, + create: true, + }); + const data = new Uint8Array(64); + await Deno.write(rid, data); + + await new Promise<void>((resolve, reject) => { + fdatasync(rid, (err: Error | null) => { + if (err !== null) reject(); + else resolve(); + }); + }) + .then( + async () => { + assertEquals(await Deno.readFile(file), data); + }, + () => { + fail("No error expected"); + }, + ) + .finally(async () => { + Deno.close(rid); + await Deno.remove(file); + }); + }, +}); + +Deno.test({ + name: + "SYNC: flush any pending data operations of the given file stream to disk.", + fn() { + const file: string = Deno.makeTempFileSync(); + const { rid } = Deno.openSync(file, { + read: true, + write: true, + create: true, + }); + const data = new Uint8Array(64); + Deno.writeSync(rid, data); + + try { + fdatasyncSync(rid); + assertEquals(Deno.readFileSync(file), data); + } finally { + Deno.close(rid); + Deno.removeSync(file); + } + }, +}); |