summaryrefslogtreecommitdiff
path: root/ext/node/polyfills/_fs
diff options
context:
space:
mode:
Diffstat (limited to 'ext/node/polyfills/_fs')
-rw-r--r--ext/node/polyfills/_fs/_fs_fdatasync.ts7
-rw-r--r--ext/node/polyfills/_fs/_fs_fstat.ts4
-rw-r--r--ext/node/polyfills/_fs/_fs_fsync.ts7
-rw-r--r--ext/node/polyfills/_fs/_fs_ftruncate.ts7
-rw-r--r--ext/node/polyfills/_fs/_fs_futimes.ts7
-rw-r--r--ext/node/polyfills/_fs/_fs_readFile.ts2
-rw-r--r--ext/node/polyfills/_fs/_fs_writeFile.ts4
7 files changed, 25 insertions, 13 deletions
diff --git a/ext/node/polyfills/_fs/_fs_fdatasync.ts b/ext/node/polyfills/_fs/_fs_fdatasync.ts
index 41990b070..0c3f50f1c 100644
--- a/ext/node/polyfills/_fs/_fs_fdatasync.ts
+++ b/ext/node/polyfills/_fs/_fs_fdatasync.ts
@@ -10,9 +10,12 @@ export function fdatasync(
fd: number,
callback: CallbackWithError,
) {
- new FsFile(fd).syncData().then(() => callback(null), callback);
+ new FsFile(fd, Symbol.for("Deno.internal.FsFile")).syncData().then(
+ () => callback(null),
+ callback,
+ );
}
export function fdatasyncSync(fd: number) {
- new FsFile(fd).syncDataSync();
+ new FsFile(fd, Symbol.for("Deno.internal.FsFile")).syncDataSync();
}
diff --git a/ext/node/polyfills/_fs/_fs_fstat.ts b/ext/node/polyfills/_fs/_fs_fstat.ts
index fe97235bf..c1722487e 100644
--- a/ext/node/polyfills/_fs/_fs_fstat.ts
+++ b/ext/node/polyfills/_fs/_fs_fstat.ts
@@ -41,7 +41,7 @@ export function fstat(
if (!callback) throw new Error("No callback function supplied");
- new FsFile(fd).stat().then(
+ new FsFile(fd, Symbol.for("Deno.internal.FsFile")).stat().then(
(stat) => callback(null, CFISBIS(stat, options.bigint)),
(err) => callback(err),
);
@@ -60,6 +60,6 @@ export function fstatSync(
fd: number,
options?: statOptions,
): Stats | BigIntStats {
- const origin = new FsFile(fd).statSync();
+ const origin = new FsFile(fd, Symbol.for("Deno.internal.FsFile")).statSync();
return CFISBIS(origin, options?.bigint || false);
}
diff --git a/ext/node/polyfills/_fs/_fs_fsync.ts b/ext/node/polyfills/_fs/_fs_fsync.ts
index 942aecf6a..75d4b3756 100644
--- a/ext/node/polyfills/_fs/_fs_fsync.ts
+++ b/ext/node/polyfills/_fs/_fs_fsync.ts
@@ -10,9 +10,12 @@ export function fsync(
fd: number,
callback: CallbackWithError,
) {
- new FsFile(fd).sync().then(() => callback(null), callback);
+ new FsFile(fd, Symbol.for("Deno.internal.FsFile")).sync().then(
+ () => callback(null),
+ callback,
+ );
}
export function fsyncSync(fd: number) {
- new FsFile(fd).syncSync();
+ new FsFile(fd, Symbol.for("Deno.internal.FsFile")).syncSync();
}
diff --git a/ext/node/polyfills/_fs/_fs_ftruncate.ts b/ext/node/polyfills/_fs/_fs_ftruncate.ts
index 71186e868..92af46f52 100644
--- a/ext/node/polyfills/_fs/_fs_ftruncate.ts
+++ b/ext/node/polyfills/_fs/_fs_ftruncate.ts
@@ -20,9 +20,12 @@ export function ftruncate(
if (!callback) throw new Error("No callback function supplied");
- new FsFile(fd).truncate(len).then(() => callback(null), callback);
+ new FsFile(fd, Symbol.for("Deno.internal.FsFile")).truncate(len).then(
+ () => callback(null),
+ callback,
+ );
}
export function ftruncateSync(fd: number, len?: number) {
- new FsFile(fd).truncateSync(len);
+ new FsFile(fd, Symbol.for("Deno.internal.FsFile")).truncateSync(len);
}
diff --git a/ext/node/polyfills/_fs/_fs_futimes.ts b/ext/node/polyfills/_fs/_fs_futimes.ts
index 9bd41e114..cc4e35b0b 100644
--- a/ext/node/polyfills/_fs/_fs_futimes.ts
+++ b/ext/node/polyfills/_fs/_fs_futimes.ts
@@ -40,7 +40,10 @@ export function futimes(
mtime = getValidTime(mtime, "mtime");
// TODO(@littledivy): Treat `fd` as real file descriptor.
- new FsFile(fd).utime(atime, mtime).then(() => callback(null), callback);
+ new FsFile(fd, Symbol.for("Deno.internal.FsFile")).utime(atime, mtime).then(
+ () => callback(null),
+ callback,
+ );
}
export function futimesSync(
@@ -52,5 +55,5 @@ export function futimesSync(
mtime = getValidTime(mtime, "mtime");
// TODO(@littledivy): Treat `fd` as real file descriptor.
- new FsFile(fd).utimeSync(atime, mtime);
+ new FsFile(fd, Symbol.for("Deno.internal.FsFile")).utimeSync(atime, mtime);
}
diff --git a/ext/node/polyfills/_fs/_fs_readFile.ts b/ext/node/polyfills/_fs/_fs_readFile.ts
index de1a2a30d..0f05ee167 100644
--- a/ext/node/polyfills/_fs/_fs_readFile.ts
+++ b/ext/node/polyfills/_fs/_fs_readFile.ts
@@ -73,7 +73,7 @@ export function readFile(
let p: Promise<Uint8Array>;
if (path instanceof FileHandle) {
- const fsFile = new FsFile(path.fd);
+ const fsFile = new FsFile(path.fd, Symbol.for("Deno.internal.FsFile"));
p = readAll(fsFile);
} else {
p = Deno.readFile(path);
diff --git a/ext/node/polyfills/_fs/_fs_writeFile.ts b/ext/node/polyfills/_fs/_fs_writeFile.ts
index 40d368566..60b31897e 100644
--- a/ext/node/polyfills/_fs/_fs_writeFile.ts
+++ b/ext/node/polyfills/_fs/_fs_writeFile.ts
@@ -74,7 +74,7 @@ export function writeFile(
(async () => {
try {
file = isRid
- ? new FsFile(pathOrRid as number)
+ ? new FsFile(pathOrRid as number, Symbol.for("Deno.internal.FsFile"))
: await Deno.open(pathOrRid as string, openOptions);
// ignore mode because it's not supported on windows
@@ -139,7 +139,7 @@ export function writeFileSync(
let error: Error | null = null;
try {
file = isRid
- ? new FsFile(pathOrRid as number)
+ ? new FsFile(pathOrRid as number, Symbol.for("Deno.internal.FsFile"))
: Deno.openSync(pathOrRid as string, openOptions);
// ignore mode because it's not supported on windows