@@ -14,6 +14,8 @@ var bench = common.createBenchmark(main, {
14
14
} ) ;
15
15
16
16
var TCP = process . binding ( 'tcp_wrap' ) . TCP ;
17
+ var TCPConnectWrap = process . binding ( 'tcp_wrap' ) . TCPConnectWrap ;
18
+ var WriteWrap = process . binding ( 'stream_wrap' ) . WriteWrap ;
17
19
var PORT = common . PORT ;
18
20
19
21
var dur ;
@@ -51,14 +53,15 @@ function server() {
51
53
if ( nread < 0 )
52
54
fail ( nread , 'read' ) ;
53
55
54
- var writeReq = { async : false } ;
56
+ var writeReq = new WriteWrap ( ) ;
57
+ writeReq . async = false ;
55
58
err = clientHandle . writeBuffer ( writeReq , buffer ) ;
56
59
57
60
if ( err )
58
61
fail ( err , 'write' ) ;
59
62
60
- writeReq . oncomplete = function ( status , handle , req ) {
61
- if ( status )
63
+ writeReq . oncomplete = function ( status , handle , req , err ) {
64
+ if ( err )
62
65
fail ( err , 'write' ) ;
63
66
} ;
64
67
} ;
@@ -88,7 +91,7 @@ function client() {
88
91
}
89
92
90
93
var clientHandle = new TCP ( ) ;
91
- var connectReq = { } ;
94
+ var connectReq = new TCPConnectWrap ( ) ;
92
95
var err = clientHandle . connect ( connectReq , '127.0.0.1' , PORT ) ;
93
96
var bytes = 0 ;
94
97
@@ -121,7 +124,8 @@ function client() {
121
124
} ;
122
125
123
126
function write ( ) {
124
- var writeReq = { oncomplete : afterWrite } ;
127
+ var writeReq = new WriteWrap ( ) ;
128
+ writeReq . oncomplete = afterWrite ;
125
129
var err ;
126
130
switch ( type ) {
127
131
case 'buf' :
0 commit comments