mirror of
https://github.com/eosswedenorg/thalos
synced 2026-07-02 11:43:40 +02:00
main.go: in readerLoop() also switch to RS_CONNECT state on shipclient.ErrNotConnected error.
This commit is contained in:
parent
58d4538159
commit
d8c198c24d
1 changed files with 1 additions and 1 deletions
2
main.go
2
main.go
|
|
@ -81,7 +81,7 @@ func readerLoop() {
|
||||||
|
|
||||||
if shErr, ok := err.(shipclient.ShipClientError); ok {
|
if shErr, ok := err.(shipclient.ShipClientError); ok {
|
||||||
// Reconnect
|
// Reconnect
|
||||||
if shErr.Type == shipclient.ErrSockRead {
|
if shErr.Type == shipclient.ErrSockRead || shErr.Type == shipclient.ErrNotConnected {
|
||||||
state = RS_CONNECT
|
state = RS_CONNECT
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
|
||||||
Loading…
Add table
Add a link
Reference in a new issue