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