@@ -81,6 +81,7 @@ var createProxy = function () {
81
81
server . emit ( 'route' , req , res , function ( port , hostname ) {
82
82
var p = manager . getPool ( port , hostname ) ;
83
83
84
+ req . headers . Connection = req . headers . Connection || 'close' ;
84
85
p . request ( req . method , req . url , req . headers , function ( reverse_proxy ) {
85
86
var data = '' ;
86
87
reverse_proxy . on ( 'error' , function ( err ) {
@@ -103,12 +104,8 @@ var createProxy = function () {
103
104
sys . pump ( req , reverse_proxy ) ;
104
105
105
106
if ( e ) {
106
- sys . puts ( 'end outgoing request' ) ;
107
107
req . removeListener ( 'end' , e ) ;
108
- req . addListener ( 'end' , function ( ) {
109
- sys . puts ( 'request ended' ) ;
110
- reverse_proxy . end ( )
111
- } ) ;
108
+ req . addListener ( 'end' , function ( ) { reverse_proxy . end ( ) } ) ;
112
109
}
113
110
else {
114
111
reverse_proxy . end ( ) ;
@@ -125,10 +122,10 @@ var createProxy = function () {
125
122
response . addListener ( 'end' , function ( ) {
126
123
server . emit ( 'proxy' , null , data ) ;
127
124
} ) ;
128
- sys . puts ( 'response' ) ;
129
125
130
126
// Set the response headers of the client response
131
127
res . writeHead ( response . statusCode , response . headers ) ;
128
+
132
129
sys . pump ( response , res ) ;
133
130
} ) ;
134
131
} ) ;
0 commit comments