Skip to content
This repository was archived by the owner on May 14, 2024. It is now read-only.

Commit d32a765

Browse files
author
Martin Cizek
committed
cr
1 parent f0c864c commit d32a765

File tree

1 file changed

+13
-11
lines changed

1 file changed

+13
-11
lines changed

lib/client/client.js

Lines changed: 13 additions & 11 deletions
Original file line numberDiff line numberDiff line change
@@ -795,13 +795,7 @@ Client.prototype.connect = function connect () {
795795
// Establish basic socket connection
796796
function connectSocket (cb) {
797797
self._nextServer = (self._nextServer + 1) % self.urls.length
798-
self.url = self.urls[self._nextServer]
799-
800-
if (self.url) {
801-
self.host = self.url.hostname
802-
self.port = self.url.port
803-
self.secure = self.url.secure
804-
}
798+
var server = self.urls[self._nextServer]
805799

806800
cb = once(cb)
807801

@@ -831,16 +825,17 @@ Client.prototype.connect = function connect () {
831825
setupClient(cb)
832826
}
833827

834-
var port = (self.port || self.socketPath)
828+
var port = (server && server.port) || self.socketPath
829+
var host = server && server.hostname
835830
if (self.secure) {
836-
socket = tls.connect(port, self.host, self.tlsOptions)
831+
socket = tls.connect(port, host, self.tlsOptions)
837832
socket.once('secureConnect', onConnect)
838833
} else {
839-
socket = net.connect(port, self.host)
834+
socket = net.connect(port, host)
840835
socket.once('connect', onConnect)
841836
}
842837
socket.once('error', onResult)
843-
initSocket(self.url)
838+
initSocket(server)
844839

845840
// Setup connection timeout handling, if desired
846841
if (self.connectTimeout) {
@@ -976,6 +971,13 @@ Client.prototype.connect = function connect () {
976971
self.emit('socketTimeout')
977972
socket.end()
978973
})
974+
975+
var server = self.urls[self._nextServer]
976+
if (server) {
977+
self.host = server.hostname
978+
self.port = server.port
979+
self.secure = server.secure
980+
}
979981
}
980982

981983
var retry

0 commit comments

Comments
 (0)