diff options
Diffstat (limited to 'tests/unit_node/_fs/_fs_fsync_test.ts')
-rw-r--r-- | tests/unit_node/_fs/_fs_fsync_test.ts | 56 |
1 files changed, 56 insertions, 0 deletions
diff --git a/tests/unit_node/_fs/_fs_fsync_test.ts b/tests/unit_node/_fs/_fs_fsync_test.ts new file mode 100644 index 000000000..870055c00 --- /dev/null +++ b/tests/unit_node/_fs/_fs_fsync_test.ts @@ -0,0 +1,56 @@ +// Copyright 2018-2024 the Deno authors. All rights reserved. MIT license. +import { assertEquals, fail } from "@test_util/std/assert/mod.ts"; +import { fsync, fsyncSync } from "node:fs"; + +Deno.test({ + name: "ASYNC: flush any pending data of the given file stream to disk", + async fn() { + const filePath = await Deno.makeTempFile(); + using file = await Deno.open(filePath, { + read: true, + write: true, + create: true, + }); + const size = 64; + await file.truncate(size); + + await new Promise<void>((resolve, reject) => { + fsync(file.rid, (err: Error | null) => { + if (err !== null) reject(); + else resolve(); + }); + }) + .then( + async () => { + assertEquals((await Deno.stat(filePath)).size, size); + }, + () => { + fail("No error expected"); + }, + ) + .finally(async () => { + await Deno.remove(filePath); + }); + }, +}); + +Deno.test({ + name: "SYNC: flush any pending data the given file stream to disk", + fn() { + const filePath = Deno.makeTempFileSync(); + using file = Deno.openSync(filePath, { + read: true, + write: true, + create: true, + }); + const size = 64; + file.truncateSync(size); + + try { + fsyncSync(file.rid); + assertEquals(Deno.statSync(filePath).size, size); + } finally { + Deno.removeSync(filePath); + } + }, +}); |