diff --git a/util/syncqueues/requestpool.go b/util/syncqueues/actionpool.go similarity index 100% rename from util/syncqueues/requestpool.go rename to util/syncqueues/actionpool.go diff --git a/util/syncqueues/requestpool_test.go b/util/syncqueues/actionpool_test.go similarity index 100% rename from util/syncqueues/requestpool_test.go rename to util/syncqueues/actionpool_test.go diff --git a/util/syncqueues/replaceablequeue.go b/util/syncqueues/replaceablequeue.go index 5d748fa4..1c5fc2f9 100644 --- a/util/syncqueues/replaceablequeue.go +++ b/util/syncqueues/replaceablequeue.go @@ -84,7 +84,7 @@ func (rp *replaceableQueue) callLoop() { for { id, err := rp.batch.WaitOne(rp.ctx) if err != nil { - log.Debug("close send loop", zap.Error(err)) + log.Debug("close call loop", zap.Error(err)) return } rp.mx.Lock()