diff --git a/eth/filters/api.go b/eth/filters/api.go index 3d93cf3cc5..6184927a99 100644 --- a/eth/filters/api.go +++ b/eth/filters/api.go @@ -380,13 +380,10 @@ func (api *FilterAPI) histLogs(notifier notifier, rpcSub *rpc.Subscription, from } continue } - // TODO: if reorg occured in more than once? - if reorgBlock == 0 { - reorgBlock = logs[0].BlockNumber - if reorgBlock <= delivered { - logger.Info("Reorg detected", "reorgBlock", reorgBlock, "delivered", delivered) - reorged = true - } + reorgBlock = logs[0].BlockNumber + if reorgBlock <= delivered { + logger.Info("Reorg detected", "reorgBlock", reorgBlock, "delivered", delivered) + reorged = true } if !reorged { continue