Skip to content

Commit 486eb4b

Browse files
committed
chore: make memory queue log with the debug level
1 parent 969b562 commit 486eb4b

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

fs/contube/memory.go

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -45,7 +45,7 @@ func (f *MemoryQueueFactory) getOrCreateChan(name string) chan Record {
4545
f.mu.Lock()
4646
defer f.mu.Unlock()
4747
defer func() {
48-
slog.InfoContext(f.ctx, "Get memory queue chan",
48+
slog.DebugContext(f.ctx, "Get memory queue chan",
4949
"current_use_count", atomic.LoadInt32(&f.queues[name].refCnt),
5050
"name", name)
5151
}()
@@ -72,7 +72,7 @@ func (f *MemoryQueueFactory) release(name string) {
7272
close(q.c)
7373
delete(f.queues, name)
7474
}
75-
slog.InfoContext(f.ctx, "Released memory queue",
75+
slog.DebugContext(f.ctx, "Released memory queue",
7676
"current_use_count", atomic.LoadInt32(&q.refCnt),
7777
"name", name)
7878
}

0 commit comments

Comments
 (0)