From d396a35713ad9232c05641e807f9e1ec074cba9b Mon Sep 17 00:00:00 2001 From: mountain Date: Mon, 4 Sep 2023 09:54:40 +0900 Subject: [PATCH] =?UTF-8?q?=EB=A1=9C=EA=B7=B8=20=EC=A0=9C=EA=B1=B0?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- session/consumer_common.go | 10 ---------- 1 file changed, 10 deletions(-) diff --git a/session/consumer_common.go b/session/consumer_common.go index 870eb79..0169d6c 100644 --- a/session/consumer_common.go +++ b/session/consumer_common.go @@ -4,8 +4,6 @@ import ( "context" "sync" "time" - - "repositories.action2quare.com/ayo/gocommon/logger" ) type cache_stage[T any] struct { @@ -33,8 +31,6 @@ func (c *consumer_common[T]) add_internal(sk storagekey, si T) { delete(c.stages[0].deleted, sk) c.stages[1].cache[sk] = si delete(c.stages[1].deleted, sk) - - logger.Printf("add : %v, %v\n", *c.stages[0], *c.stages[1]) } func (c *consumer_common[T]) add(sk storagekey, si T) { @@ -49,8 +45,6 @@ func (c *consumer_common[T]) delete_internal(sk storagekey) { c.stages[0].deleted[sk] = true delete(c.stages[1].cache, sk) c.stages[1].deleted[sk] = true - - logger.Printf("delete : %v, %v\n", *c.stages[0], *c.stages[1]) } func (c *consumer_common[T]) delete(sk storagekey) { @@ -64,10 +58,6 @@ func (c *consumer_common[T]) changeStage() { c.lock.Lock() defer c.lock.Unlock() - logger.Printf("changeStage : %v, %v\n", *c.stages[0], *c.stages[1]) - c.stages[1] = c.stages[0] c.stages[0] = make_cache_stage[T]() - - logger.Printf("---> : %v, %v\n", *c.stages[0], *c.stages[1]) }