RuhNetConsulting
/
go-rabbitmq
mirror of https://github.com/wagslane/go-rabbitmq
1
0
Fork 0
Code Issues 0 Projects 0 Releases 33 Wiki Activity
Browse Source

fix ConfirmSafe race condition

pull/131/head
Hristo Karchokov 3 years ago
parent
85ee5640a7
commit
1930b9d7ad
Failed to extract signature
1 changed files with 2 additions and 2 deletions
Split View
Diff Options
Show Stats Download Patch File Download Diff File
  1. +2
    -2
      internal/channelmanager/safe_wraps.go

+ 2
- 2
internal/channelmanager/safe_wraps.go View File

@ -203,8 +203,8 @@ func (chanManager *ChannelManager) NotifyReturnSafe(
func (chanManager *ChannelManager) ConfirmSafe(
noWait bool,
) error {
chanManager.channelMux.RLock()
defer chanManager.channelMux.RUnlock()
chanManager.channelMux.Lock()
defer chanManager.channelMux.Unlock()
return chanManager.channel.Confirm(
noWait,


Write Preview
Loading…
Cancel
Save