Skip to content

Commit d677f1c

Browse files
authored
Merge pull request goburrow#22 from andig/reconnect
Always reconnect if connection was closed
2 parents 867898f + 7d993bd commit d677f1c

File tree

1 file changed

+5
-9
lines changed

1 file changed

+5
-9
lines changed

tcpclient.go

+5-9
Original file line numberDiff line numberDiff line change
@@ -149,11 +149,12 @@ func (mb *tcpTransporter) Send(aduRequest []byte) (aduResponse []byte, err error
149149
var data [tcpMaxLength]byte
150150
recoveryDeadline := time.Now().Add(mb.IdleTimeout)
151151

152-
// Establish a new connection if not connected
153-
if err = mb.connect(); err != nil {
154-
return
155-
}
156152
for {
153+
// Establish a new connection if not connected
154+
if err = mb.connect(); err != nil {
155+
return
156+
}
157+
157158
// Set timer to close when idle
158159
mb.lastActivity = time.Now()
159160
mb.startCloseTimer()
@@ -198,11 +199,6 @@ func (mb *tcpTransporter) Send(aduRequest []byte) (aduResponse []byte, err error
198199

199200
mb.close()
200201
time.Sleep(mb.LinkRecoveryTimeout)
201-
202-
// Establish a new connection if not connected
203-
if err = mb.connect(); err != nil {
204-
return
205-
}
206202
}
207203
}
208204

0 commit comments

Comments
 (0)