Skip to content

Use linkedhashmap for P-Chain mempool #1536

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
merged 72 commits into from
Nov 22, 2023
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
72 commits
Select commit Hold shift + click to select a range
0c14a71
platformvm/mempool: use linkedhashmap with more efficient PeekTxs
gyuho May 22, 2023
dd97118
Merge branch 'dev' into gyuho-p-mempool-like-avm
gyuho May 25, 2023
b04e98a
Merge branch 'dev' into gyuho-p-mempool-like-avm
gyuho May 26, 2023
56edac1
Merge branch 'dev' into gyuho-p-mempool-like-avm
gyuho May 28, 2023
9917595
platformvm/txs: add TxIterator to mempool interface
gyuho May 28, 2023
921614c
TODO: remove PeekTxs
gyuho May 28, 2023
aead6b1
platformvm/mempool: combine into one txs field
gyuho May 28, 2023
6a5ec7d
mempool
gyuho May 28, 2023
de5c185
vms/platformvm/blocks/builder: fix tests
gyuho May 28, 2023
985921e
mempool: add PeekTxs unit tests with fix
gyuho May 28, 2023
5d03a47
Merge branch 'dev' into gyuho-p-mempool-like-avm
gyuho Jun 1, 2023
72f6e3a
Merge branch 'dev' into gyuho-p-mempool-like-avm
gyuho Jun 2, 2023
1eaedc9
Merge branch 'dev' into gyuho-p-mempool-like-avm
abi87 Jun 2, 2023
4c93854
remove PeekTx
gyuho Jun 2, 2023
90bfc84
Merge branch 'dev' into gyuho-p-mempool-like-avm
gyuho Jun 4, 2023
21677c6
Merge branch 'dev' into gyuho-p-mempool-like-avm
abi87 Jun 5, 2023
4f1273e
Merge branch 'dev' into gyuho-p-mempool-like-avm
abi87 Jun 19, 2023
dd89917
merged
dhrubabasu Nov 7, 2023
d803c4c
merged
dhrubabasu Nov 9, 2023
5595706
fix merge
dhrubabasu Nov 9, 2023
e910b5d
Move management of platformvm preferred block to `executor.Manager`
dhrubabasu Nov 10, 2023
5851eed
Add `VerifyTx` to `executor.Manager`
dhrubabasu Nov 10, 2023
a93a379
`vms/platformvm`: Remove `Network` interface from `Builder`
dhrubabasu Nov 10, 2023
149d211
move to own pkg
dhrubabasu Nov 10, 2023
691f9ec
remove todo
dhrubabasu Nov 10, 2023
87dbb0c
nit
dhrubabasu Nov 10, 2023
23c2ce7
nit
dhrubabasu Nov 10, 2023
6032c36
cleanup (#2272)
dhrubabasu Nov 12, 2023
011e4d0
Merge branch 'dev' into gyuho-p-mempool-like-avm
dhrubabasu Nov 12, 2023
85adc91
reduce diff
dhrubabasu Nov 12, 2023
c418f6c
Merge branch 'move-preferred-to-blk-manager' into move-verify-tx-to-b…
dhrubabasu Nov 12, 2023
bdd6da1
fix merge
dhrubabasu Nov 12, 2023
bbcc960
merged
dhrubabasu Nov 14, 2023
662bbdc
merged
dhrubabasu Nov 14, 2023
46cd75c
merged
dhrubabasu Nov 14, 2023
f739b51
Move `AddUnverifiedTx` logic to `Network` interface
dhrubabasu Nov 14, 2023
b3844a9
Remove `AddUnverifiedTx` from `Builder`
dhrubabasu Nov 14, 2023
fec3091
Remove `Network` interface from `Builder`
dhrubabasu Nov 14, 2023
ac427c5
merged
dhrubabasu Nov 14, 2023
c2515b7
nit
dhrubabasu Nov 14, 2023
3433403
maybe
dhrubabasu Nov 15, 2023
7772c04
fill in contextx
dhrubabasu Nov 15, 2023
068469a
fill in ctxs
dhrubabasu Nov 15, 2023
290e5f3
merged
dhrubabasu Nov 15, 2023
8131488
Merge branch 'remove-network-interface-from-builder' into remove-add-…
dhrubabasu Nov 15, 2023
cbc5cee
push
dhrubabasu Nov 15, 2023
de5185a
merged
dhrubabasu Nov 15, 2023
9a4b955
nit
dhrubabasu Nov 15, 2023
ac930ea
revert
dhrubabasu Nov 15, 2023
8fb176c
merged
dhrubabasu Nov 15, 2023
d69f0e4
Merge branch 'delete-add-unverified-tx' into remove-network-interface…
dhrubabasu Nov 15, 2023
5c92cbf
Merge branch 'remove-network-interface-from-builder' into remove-add-…
dhrubabasu Nov 15, 2023
599248a
merged
dhrubabasu Nov 16, 2023
eef0f77
Merge branch 'remove-network-interface-from-builder' into remove-add-…
dhrubabasu Nov 16, 2023
f6a9140
merged
dhrubabasu Nov 16, 2023
1d1be7c
Merge branch 'dev' into remove-add-unverified-tx
dhrubabasu Nov 16, 2023
d4999bf
Merge branch 'remove-add-unverified-tx' into gyuho-p-mempool-like-avm
dhrubabasu Nov 16, 2023
c5dae8d
reduce diff
dhrubabasu Nov 16, 2023
0f7e2f3
fix tests
dhrubabasu Nov 16, 2023
c0c73ab
remove `remover`
dhrubabasu Nov 16, 2023
503b334
remove issuer
dhrubabasu Nov 16, 2023
372fac4
reduce diff
dhrubabasu Nov 16, 2023
444c141
fix and add test
dhrubabasu Nov 17, 2023
d6f81eb
Merge branch 'dev' into gyuho-p-mempool-like-avm
dhrubabasu Nov 17, 2023
187011e
linter
dhrubabasu Nov 17, 2023
9750e0e
Merge branch 'dev' into gyuho-p-mempool-like-avm
dhrubabasu Nov 20, 2023
6e3c8f2
Merge branch 'dev' into gyuho-p-mempool-like-avm
dhrubabasu Nov 21, 2023
66c2e42
Remove dead code
StephenButtolph Nov 22, 2023
a95ddcd
nit reduce diff
StephenButtolph Nov 22, 2023
dbac2e9
nits
StephenButtolph Nov 22, 2023
35620a9
nit
StephenButtolph Nov 22, 2023
b44ede7
Merge branch 'dev' into gyuho-p-mempool-like-avm
StephenButtolph Nov 22, 2023
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 1 addition & 1 deletion vms/platformvm/block/builder/builder.go
Original file line number Diff line number Diff line change
Expand Up @@ -270,7 +270,7 @@ func buildBlock(
}

// Clean out the mempool's transactions with invalid timestamps.
droppedStakerTxIDs := mempool.DropExpiredStakerTxs(builder.Mempool, timestamp.Add(txexecutor.SyncBound))
droppedStakerTxIDs := builder.Mempool.DropExpiredStakerTxs(timestamp.Add(txexecutor.SyncBound))
for _, txID := range droppedStakerTxIDs {
builder.txExecutorBackend.Ctx.Log.Debug("dropping tx",
zap.Stringer("txID", txID),
Expand Down
10 changes: 5 additions & 5 deletions vms/platformvm/block/builder/builder_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -401,7 +401,7 @@ func TestBuildBlock(t *testing.T) {
mempool := mempool.NewMockMempool(ctrl)

// There are txs.
mempool.EXPECT().HasStakerTx().Return(false)
mempool.EXPECT().DropExpiredStakerTxs(gomock.Any()).Return([]ids.ID{})
mempool.EXPECT().HasTxs().Return(true)
mempool.EXPECT().PeekTxs(targetBlockSize).Return(transactions)
return &builder{
Expand Down Expand Up @@ -448,7 +448,7 @@ func TestBuildBlock(t *testing.T) {
mempool := mempool.NewMockMempool(ctrl)

// There are no txs.
mempool.EXPECT().HasStakerTx().Return(false)
mempool.EXPECT().DropExpiredStakerTxs(gomock.Any()).Return([]ids.ID{})
mempool.EXPECT().HasTxs().Return(false)

clk := &mockable.Clock{}
Expand Down Expand Up @@ -496,7 +496,7 @@ func TestBuildBlock(t *testing.T) {
mempool := mempool.NewMockMempool(ctrl)

// There are no txs.
mempool.EXPECT().HasStakerTx().Return(false)
mempool.EXPECT().DropExpiredStakerTxs(gomock.Any()).Return([]ids.ID{})
mempool.EXPECT().HasTxs().Return(false)
mempool.EXPECT().PeekTxs(targetBlockSize).Return(nil)

Expand Down Expand Up @@ -551,7 +551,7 @@ func TestBuildBlock(t *testing.T) {
mempool := mempool.NewMockMempool(ctrl)

// There is a tx.
mempool.EXPECT().HasStakerTx().Return(false)
mempool.EXPECT().DropExpiredStakerTxs(gomock.Any()).Return([]ids.ID{})
mempool.EXPECT().HasTxs().Return(true)
mempool.EXPECT().PeekTxs(targetBlockSize).Return([]*txs.Tx{transactions[0]})

Expand Down Expand Up @@ -605,7 +605,7 @@ func TestBuildBlock(t *testing.T) {

// There are no decision txs
// There is a staker tx.
mempool.EXPECT().HasStakerTx().Return(false)
mempool.EXPECT().DropExpiredStakerTxs(gomock.Any()).Return([]ids.ID{})
mempool.EXPECT().HasTxs().Return(true)
mempool.EXPECT().PeekTxs(targetBlockSize).Return([]*txs.Tx{transactions[0]})

Expand Down
95 changes: 0 additions & 95 deletions vms/platformvm/txs/mempool/issuer.go

This file was deleted.

Loading