1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
|
/*---
includes: [compareArray.js, compatFs.js]
flags: [async]
---*/
var fname = `${test_dir}/fs_promises_03`;
let stages = [];
var testSync = () => new Promise((resolve, reject) => {
try {
try {
fs.unlinkSync(fname);
} catch (e) {
void e;
}
try {
fs.unlinkSync(fname);
throw new Error('unlinkSync error 1');
} catch (e) {
if (e.syscall != 'unlink') {
throw e;
}
}
fs.writeFileSync(fname, fname);
fs.unlinkSync(fname);
try {
fs.accessSync(fname);
reject(new Error('unlinkSync error 2'));
return;
} catch (e) {
void e;
}
stages.push("unlinkSync");
resolve();
} catch (e) {
reject(e);
}
});
var testCallback = () => new Promise((resolve, reject) => {
fs.unlink(fname, () => {
fs.unlink(fname, (err) => {
if (!err) {
reject(new Error('fs.unlink error 1'));
return;
}
if (err.syscall != 'unlink') {
reject(err);
return;
}
fs.writeFileSync(fname, fname);
fs.unlink(fname, (err) => {
if (err) {
reject(err);
return;
}
try {
fs.accessSync(fname);
reject(new Error('fs.unlink error 2'));
return;
} catch (e) {
void e;
}
stages.push("unlink");
resolve();
});
});
});
});
let testFsp = () => Promise.resolve()
.then(() => fsp.unlink(fname)
.catch(() => {}))
.then(() => fsp.unlink(fname))
.then(() => { throw new Error('fsp.unlink error 1'); })
.catch((e) => { if (e.syscall != 'unlink') { throw e; } })
.then(() => {
fs.writeFileSync(fname, fname);
return fsp.unlink(fname);
})
.then(() => fsp.access(fname))
.then(() => { throw new Error('fsp.unlink error 2'); })
.catch((e) => { if (e.syscall != 'access') { throw e; } })
.then(() => {
stages.push("fsp.unlink");
})
let p = Promise.resolve()
.then(testSync)
.then(testCallback)
.then(testFsp)
.then(() => assert.compareArray(stages, ['unlinkSync', 'unlink', 'fsp.unlink']))
p.then($DONE, $DONE);
|
