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