anyproto/any-sync
1
0
Fork 0
mirror of https://github.com/anyproto/any-sync.git synced 2025-06-08 05:57:03 +09:00
Code Activity

Renames

Browse source
This commit is contained in:
mcrakhman 2024-08-14 23:06:01 +02:00
parent 34a87a8a7a
commit 2989b11f3c
No known key found for this signature in database
GPG key ID: DED12CFEF5B8396B
3 changed files with 1 additions and 1 deletions
Download patch file Download diff file Expand all files Collapse all files

0
util/syncqueues/requestpool.go → util/syncqueues/actionpool.go
View file

0
util/syncqueues/requestpool_test.go → util/syncqueues/actionpool_test.go
View file

2
util/syncqueues/replaceablequeue.go
View file

@ -84,7 +84,7 @@ func (rp *replaceableQueue) callLoop() {
for { for {
id, err := rp.batch.WaitOne(rp.ctx) id, err := rp.batch.WaitOne(rp.ctx)
if err != nil { if err != nil {
log.Debug("close send loop", zap.Error(err)) log.Debug("close call loop", zap.Error(err))
return return
} }
rp.mx.Lock() rp.mx.Lock()