RanchiMall/blockbook
3
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Fix synchronization issue in mempool

Browse Source
This commit is contained in:
Martin Boehm 2019-04-11 14:57:39 +02:00
parent 8c1691be8d
commit 230b5e5d32
1 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
bchain/basemempool.go
View File

@ -65,6 +65,7 @@ func (a MempoolTxidEntries) Less(i, j int) bool {
return hi > hj return hi > hj
} }
// removeEntryFromMempool removes entry from mempool structs. The caller is responsible for locking!
func (m *BaseMempool) removeEntryFromMempool(txid string, entry txEntry) { func (m *BaseMempool) removeEntryFromMempool(txid string, entry txEntry) {
delete(m.txEntries, txid) delete(m.txEntries, txid)
for _, si := range entry.addrIndexes { for _, si := range entry.addrIndexes {
@ -87,9 +88,9 @@ func (m *BaseMempool) removeEntryFromMempool(txid string, entry txEntry) {
// GetAllEntries returns all mempool entries sorted by fist seen time in descending order // GetAllEntries returns all mempool entries sorted by fist seen time in descending order
func (m *BaseMempool) GetAllEntries() MempoolTxidEntries { func (m *BaseMempool) GetAllEntries() MempoolTxidEntries {
entries := make(MempoolTxidEntries, len(m.txEntries))
i := 0 i := 0
m.mux.Lock() m.mux.Lock()
entries := make(MempoolTxidEntries, len(m.txEntries))
for txid, entry := range m.txEntries { for txid, entry := range m.txEntries {
entries[i] = MempoolTxidEntry{ entries[i] = MempoolTxidEntry{
Txid: txid, Txid: txid,