Skip to content

Commit 9a46780

Browse files
authored
Revert "remove unwanted log message"
This reverts commit 363564d.
1 parent 2c7224e commit 9a46780

File tree

1 file changed

+1
-0
lines changed

1 file changed

+1
-0
lines changed

lib/coordinator.go

+1
Original file line numberDiff line numberDiff line change
@@ -831,6 +831,7 @@ func (crd *Coordinator) dispatchRequest(request *netstring.Netstring) error {
831831
// donot return a stranded worker. recover inserts a good worker back to pool.
832832
//
833833
if err == ErrSaturationKill {
834+
logger.GetLogger().Log(logger.Info, "trigger recovery as part of ErrSaturationKill")
834835
go worker.Recover(workerpool, ticket, WorkerClientRecoverParam{allowSkipOciBreak: true}, &strandedCalInfo{raddr: crd.conn.RemoteAddr().String(), laddr: crd.conn.LocalAddr().String(), nameSuffix: "_SATURATION_RECOVERED"}, common.StrandedSaturationRecover)
835836
} else {
836837
go worker.Recover(workerpool, ticket, WorkerClientRecoverParam{allowSkipOciBreak: true}, &strandedCalInfo{raddr: crd.conn.RemoteAddr().String(), laddr: crd.conn.LocalAddr().String()})

0 commit comments

Comments
 (0)