From 38a3da271a8e7225020ac5a84eddda80256a9e8b Mon Sep 17 00:00:00 2001 From: mountain Date: Tue, 5 Aug 2025 21:48:12 +0900 Subject: [PATCH] =?UTF-8?q?defer=20=EB=B9=BC=EB=A8=B9=EC=9D=8C;;;?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- opensearch/client.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/opensearch/client.go b/opensearch/client.go index 938dbef..c2c5fba 100644 --- a/opensearch/client.go +++ b/opensearch/client.go @@ -64,7 +64,7 @@ func (c *Client) Send(ld *LogDocument) { serialized, _ := json.Marshal(ld) go func(serialized []byte) { sending := atomic.AddInt32(&c.sendingCount, 1) - atomic.AddInt32(&c.sendingCount, -1) + defer atomic.AddInt32(&c.sendingCount, -1) if sending > 100 { logger.Println("sending log bottleneck :", sending) @@ -102,7 +102,7 @@ func (c *Client) SendBulk(ds map[string]*LogDocument) { go func(contents string) { sending := atomic.AddInt32(&c.sendingCount, 1) - atomic.AddInt32(&c.sendingCount, -1) + defer atomic.AddInt32(&c.sendingCount, -1) if sending > 100 { logger.Println("sending log bottleneck :", sending)