Swap dead sessions
This commit is contained in:
parent
3601184c8b
commit
0299fd5d70
|
@ -3,6 +3,7 @@ package yubihsm
|
||||||
import (
|
import (
|
||||||
"bytes"
|
"bytes"
|
||||||
"errors"
|
"errors"
|
||||||
|
"log"
|
||||||
"sync"
|
"sync"
|
||||||
"time"
|
"time"
|
||||||
|
|
||||||
|
@ -69,6 +70,12 @@ func (s *SessionManager) pingRoutine() {
|
||||||
if !bytes.Equal(parsedResp.Data, echoPayload) {
|
if !bytes.Equal(parsedResp.Data, echoPayload) {
|
||||||
err = errors.New("echoed data is invalid")
|
err = errors.New("echoed data is invalid")
|
||||||
}
|
}
|
||||||
|
} else {
|
||||||
|
// Session seems to be dead - reconnect and swap
|
||||||
|
err = s.swapSession()
|
||||||
|
if err != nil {
|
||||||
|
log.Printf("swapping dead session failed; err=%v", err)
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
s.keepAlive.Reset(pingInterval)
|
s.keepAlive.Reset(pingInterval)
|
||||||
|
|
Loading…
Reference in New Issue