From 2989b11f3c43dddfd7117fdfefa95d5bfc9e17d5 Mon Sep 17 00:00:00 2001 From: mcrakhman Date: Wed, 14 Aug 2024 23:06:01 +0200 Subject: [PATCH] Renames --- util/syncqueues/{requestpool.go => actionpool.go} | 0 util/syncqueues/{requestpool_test.go => actionpool_test.go} | 0 util/syncqueues/replaceablequeue.go | 2 +- 3 files changed, 1 insertion(+), 1 deletion(-) rename util/syncqueues/{requestpool.go => actionpool.go} (100%) rename util/syncqueues/{requestpool_test.go => actionpool_test.go} (100%) 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()