@@ -30,16 +30,10 @@ const stream = require('stream');
30
30
const util = require ( 'util' ) ;
31
31
const Timer = process . binding ( 'timer_wrap' ) . Timer ;
32
32
const { fixturesDir } = require ( './fixtures' ) ;
33
-
34
- const testRoot = process . env . NODE_TEST_DIR ?
35
- fs . realpathSync ( process . env . NODE_TEST_DIR ) : path . resolve ( __dirname , '..' ) ;
33
+ const tmpdir = require ( './tmpdir' ) ;
36
34
37
35
const noop = ( ) => { } ;
38
36
39
- // Using a `.` prefixed name, which is the convention for "hidden" on POSIX,
40
- // gets tools to ignore it by default or by simple rules, especially eslint.
41
- let tmpDirName = '.tmp' ;
42
-
43
37
Object . defineProperty ( exports , 'PORT' , {
44
38
get : ( ) => {
45
39
if ( + process . env . TEST_PARALLEL ) {
@@ -120,62 +114,6 @@ if (process.env.NODE_TEST_WITH_ASYNC_HOOKS) {
120
114
} ) . enable ( ) ;
121
115
}
122
116
123
- function rimrafSync ( p ) {
124
- let st ;
125
- try {
126
- st = fs . lstatSync ( p ) ;
127
- } catch ( e ) {
128
- if ( e . code === 'ENOENT' )
129
- return ;
130
- }
131
-
132
- try {
133
- if ( st && st . isDirectory ( ) )
134
- rmdirSync ( p , null ) ;
135
- else
136
- fs . unlinkSync ( p ) ;
137
- } catch ( e ) {
138
- if ( e . code === 'ENOENT' )
139
- return ;
140
- if ( e . code === 'EPERM' )
141
- return rmdirSync ( p , e ) ;
142
- if ( e . code !== 'EISDIR' )
143
- throw e ;
144
- rmdirSync ( p , e ) ;
145
- }
146
- }
147
-
148
- function rmdirSync ( p , originalEr ) {
149
- try {
150
- fs . rmdirSync ( p ) ;
151
- } catch ( e ) {
152
- if ( e . code === 'ENOTDIR' )
153
- throw originalEr ;
154
- if ( e . code === 'ENOTEMPTY' || e . code === 'EEXIST' || e . code === 'EPERM' ) {
155
- const enc = exports . isLinux ? 'buffer' : 'utf8' ;
156
- fs . readdirSync ( p , enc ) . forEach ( ( f ) => {
157
- if ( f instanceof Buffer ) {
158
- const buf = Buffer . concat ( [ Buffer . from ( p ) , Buffer . from ( path . sep ) , f ] ) ;
159
- rimrafSync ( buf ) ;
160
- } else {
161
- rimrafSync ( path . join ( p , f ) ) ;
162
- }
163
- } ) ;
164
- fs . rmdirSync ( p ) ;
165
- }
166
- }
167
- }
168
-
169
- exports . refreshTmpDir = function ( ) {
170
- rimrafSync ( exports . tmpDir ) ;
171
- fs . mkdirSync ( exports . tmpDir ) ;
172
- } ;
173
-
174
- if ( process . env . TEST_THREAD_ID ) {
175
- tmpDirName += `.${ process . env . TEST_THREAD_ID } ` ;
176
- }
177
- exports . tmpDir = path . join ( testRoot , tmpDirName ) ;
178
-
179
117
let opensslCli = null ;
180
118
let inFreeBSDJail = null ;
181
119
let localhostIPv4 = null ;
@@ -269,7 +207,7 @@ Object.defineProperty(exports, 'hasFipsCrypto', {
269
207
} ) ;
270
208
271
209
{
272
- const localRelative = path . relative ( process . cwd ( ) , `${ exports . tmpDir } /` ) ;
210
+ const localRelative = path . relative ( process . cwd ( ) , `${ tmpdir . path } /` ) ;
273
211
const pipePrefix = exports . isWindows ? '\\\\.\\pipe\\' : localRelative ;
274
212
const pipeName = `node-test.${ process . pid } .sock` ;
275
213
exports . PIPE = path . join ( pipePrefix , pipeName ) ;
0 commit comments