diff options
Diffstat (limited to 'ext/node/polyfills/_fs')
-rw-r--r-- | ext/node/polyfills/_fs/_fs_fdatasync.ts | 7 | ||||
-rw-r--r-- | ext/node/polyfills/_fs/_fs_fstat.ts | 4 | ||||
-rw-r--r-- | ext/node/polyfills/_fs/_fs_fsync.ts | 7 | ||||
-rw-r--r-- | ext/node/polyfills/_fs/_fs_ftruncate.ts | 7 | ||||
-rw-r--r-- | ext/node/polyfills/_fs/_fs_futimes.ts | 7 | ||||
-rw-r--r-- | ext/node/polyfills/_fs/_fs_readFile.ts | 2 | ||||
-rw-r--r-- | ext/node/polyfills/_fs/_fs_writeFile.ts | 4 |
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 |