ayo/gocommon
8
0
Fork 1
Code Issues Pull Requests Projects Releases Wiki Activity

defer 빼먹음;;;

Browse Source
This commit is contained in:
mountain
2025-08-05 21:48:12 +09:00
parent fb3f038506
commit 38a3da271a
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
opensearch/client.go
View File

@ -64,7 +64,7 @@ func (c *Client) Send(ld *LogDocument) {
serialized, _ := json.Marshal(ld) serialized, _ := json.Marshal(ld)
go func(serialized []byte) { go func(serialized []byte) {
sending := atomic.AddInt32(&c.sendingCount, 1) sending := atomic.AddInt32(&c.sendingCount, 1)
atomic.AddInt32(&c.sendingCount, -1) defer atomic.AddInt32(&c.sendingCount, -1)
if sending > 100 { if sending > 100 {
logger.Println("sending log bottleneck :", sending) logger.Println("sending log bottleneck :", sending)
@ -102,7 +102,7 @@ func (c *Client) SendBulk(ds map[string]*LogDocument) {
go func(contents string) { go func(contents string) {
sending := atomic.AddInt32(&c.sendingCount, 1) sending := atomic.AddInt32(&c.sendingCount, 1)
atomic.AddInt32(&c.sendingCount, -1) defer atomic.AddInt32(&c.sendingCount, -1)
if sending > 100 { if sending > 100 {
logger.Println("sending log bottleneck :", sending) logger.Println("sending log bottleneck :", sending)