@@ -22,52 +22,39 @@ const kCurrentWriteRequest = Symbol('kCurrentWriteRequest');
22
22
const kCurrentShutdownRequest = Symbol ( 'kCurrentShutdownRequest' ) ;
23
23
const kPendingShutdownRequest = Symbol ( 'kPendingShutdownRequest' ) ;
24
24
25
- function isClosing ( ) {
26
- let socket = this [ owner_symbol ] ;
25
+ function checkReusedHandle ( t ) {
26
+ let socket = t [ owner_symbol ] ;
27
27
28
- if ( socket . constructor . name === 'ReusedHandle' ) {
28
+ if ( socket . constructor . name === 'ReusedHandle' )
29
29
socket = socket . handle ;
30
- }
30
+ }
31
+
32
+ function isClosing ( ) {
33
+ checkReusedHandle ( this ) ;
31
34
32
35
return socket . isClosing ( ) ;
33
36
}
34
37
35
38
function onreadstart ( ) {
36
- let socket = this [ owner_symbol ] ;
37
-
38
- if ( socket . constructor . name === 'ReusedHandle' ) {
39
- socket = socket . handle ;
40
- }
39
+ checkReusedHandle ( this ) ;
41
40
42
41
return socket . readStart ( ) ;
43
42
}
44
43
45
44
function onreadstop ( ) {
46
- let socket = this [ owner_symbol ] ;
47
-
48
- if ( socket . constructor . name === 'ReusedHandle' ) {
49
- socket = socket . handle ;
50
- }
45
+ checkReusedHandle ( this ) ;
51
46
52
47
return socket . readStop ( ) ;
53
48
}
54
49
55
50
function onshutdown ( req ) {
56
- let socket = this [ owner_symbol ] ;
57
-
58
- if ( socket . constructor . name === 'ReusedHandle' ) {
59
- socket = socket . handle ;
60
- }
51
+ checkReusedHandle ( this ) ;
61
52
62
53
return socket . doShutdown ( req ) ;
63
54
}
64
55
65
56
function onwrite ( req , bufs ) {
66
- let socket = this [ owner_symbol ] ;
67
-
68
- if ( socket . constructor . name === 'ReusedHandle' ) {
69
- socket = socket . handle ;
70
- }
57
+ checkReusedHandle ( this ) ;
71
58
72
59
return socket . doWrite ( req , bufs ) ;
73
60
}
0 commit comments