rpcserver: Always read wsclient filter with mutex held.
This commit is contained in:
parent
e6a2e6a159
commit
f656ceb652
@ -1751,16 +1751,17 @@ func handleLoadTxFilter(wsc *wsClient, icmd interface{}) (interface{}, error) {
|
||||
wsc.filterData = makeWSClientFilter(cmd.Addresses, outPoints)
|
||||
wsc.Unlock()
|
||||
} else {
|
||||
filter := wsc.filterData
|
||||
wsc.Unlock()
|
||||
|
||||
wsc.filterData.mu.Lock()
|
||||
filter.mu.Lock()
|
||||
for _, a := range cmd.Addresses {
|
||||
wsc.filterData.addAddressStr(a)
|
||||
filter.addAddressStr(a)
|
||||
}
|
||||
for _, op := range outPoints {
|
||||
wsc.filterData.addUnspentOutPoint(op)
|
||||
filter.addUnspentOutPoint(op)
|
||||
}
|
||||
wsc.filterData.mu.Unlock()
|
||||
filter.mu.Unlock()
|
||||
}
|
||||
|
||||
return nil, nil
|
||||
|
||||
Loading…
Reference in New Issue
Block a user