[fix] Change variable references for Websockets, bugs found from using wsbench

This commit is contained in:
indexzero 2011-05-19 00:37:18 -04:00
parent 32a15dd79d
commit 7bf0caef9f

View File

@ -579,10 +579,10 @@ HttpProxy.prototype.proxyWebSocketRequest = function (req, socket, head, options
// Detach event listeners from reverseProxy
function detach() {
reverseProxy.removeListener('close', listeners._r_close);
reverseProxy.removeListener('end', listeners._r_close);
reverseProxy.removeListener('data', listeners._r_data);
out.incoming.socket.removeListener('data', listeners._data);
out.incoming.socket.removeListener('close', listeners._close);
out.incoming.socket.removeListener('end', listeners._close);
}
// Hook disconnections
@ -591,7 +591,7 @@ HttpProxy.prototype.proxyWebSocketRequest = function (req, socket, head, options
detach();
});
socket.on('end', listeners._close = function() {
out.incoming.socket.on('end', listeners._close = function() {
reverseProxy.end();
detach();
});