nik/signal-cli-rest-api
1
0
Fork 0
mirror of https://github.com/bbernhard/signal-cli-rest-api.git synced 2026-11-02 09:59:33 +00:00
Code Issues Packages Projects Releases Wiki Activity

Shorten the critical section

Browse Source
This commit is contained in:
Mykola Balakin 2026-10-17 19:24:17 +03:00
parent 2cb7ad4fb1
commit 090d9b135e
No known key found for this signature in database
GPG Key ID: B9B5039ECA2ACA32
1 changed files with 6 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
src/client/jsonrpc2.go
View File

@ -347,26 +347,30 @@ func (r *JsonRpc2Client) acquireReceiveSubscription(account string) error {
func (r *JsonRpc2Client) releaseReceiveSubscription(account string) error {
r.receiveSubscriptionsMutex.Lock()
defer r.receiveSubscriptionsMutex.Unlock()
sub, ok := r.receiveSubscriptions[account]
if !ok {
r.receiveSubscriptionsMutex.Unlock()
return nil
}
sub.refcount--
if sub.refcount > 0 {
r.receiveSubscriptionsMutex.Unlock()
return nil
}
delete(r.receiveSubscriptions, account)
err := r.unsubscribeReceive(account, sub.id)
r.receiveSubscriptionsMutex.Unlock()
if err != nil {
log.Warnf("Couldn't unsubscribed from receive notifications for account %s (subscription=%d): %s", account, sub.id, err.Error())
} else {
log.Debugf("Unsubscribed from receive notifications for account %s (subscription=%d)", account, sub.id)
}
delete(r.receiveSubscriptions, account)
return err
}