git.delta.rocks / unique-network / refs/commits / 7eeb64bd9e5e

difftreelog

feat future pool increase option

Yaroslav Bolyukin2024-07-10parent: #0ceea0a.patch.diff
in: master

9 files changed

modified.baedeker/forkless-data.jsonnetdiffbeforeafterboth
54 [name]: {54 [name]: {
55 bin: $.bin,55 bin: $.bin,
56 wantedKeys: 'para',56 wantedKeys: 'para',
57 extraArgs: [
58 '--increase-future-pool',
59 ],
57 },60 },
58 for name in ['alice', 'bob']61 for name in ['alice', 'bob']
59 },62 },
modified.baedeker/node-only.jsonnetdiffbeforeafterboth
30 [name]: {30 [name]: {
31 bin: $.bin,31 bin: $.bin,
32 wantedKeys: 'para',32 wantedKeys: 'para',
33 extraArgs: [
34 '--increase-future-pool',
35 ],
33 },36 },
34 for name in ['alice', 'bob']37 for name in ['alice', 'bob']
35 },38 },
modified.baedeker/xcm-opal-async-backing.jsonnetdiffbeforeafterboth
55 [name]: {55 [name]: {
56 bin: $.bin,56 bin: $.bin,
57 wantedKeys: 'para',57 wantedKeys: 'para',
58 extraArgs: [
59 '--increase-future-pool',
60 ],
58 },61 },
59 for name in ['alice', 'bob', 'charlie', 'dave', 'eve']62 for name in ['alice', 'bob', 'charlie', 'dave', 'eve']
60 },63 },
modified.baedeker/xcm-opal.jsonnetdiffbeforeafterboth
35 [name]: {35 [name]: {
36 bin: $.bin,36 bin: $.bin,
37 wantedKeys: 'para',37 wantedKeys: 'para',
38 extraArgs: [
39 '--increase-future-pool',
40 ],
38 },41 },
39 for name in ['alice', 'bob']42 for name in ['alice', 'bob']
40 },43 },
modified.baedeker/xcm-quartz.jsonnetdiffbeforeafterboth
40 [name]: {40 [name]: {
41 bin: $.bin,41 bin: $.bin,
42 wantedKeys: 'para',42 wantedKeys: 'para',
43 extraArgs: [
44 '--increase-future-pool',
45 ],
43 },46 },
44 for name in ['alice', 'bob']47 for name in ['alice', 'bob']
45 },48 },
modified.baedeker/xcm-unique.jsonnetdiffbeforeafterboth
41 [name]: {41 [name]: {
42 bin: $.bin,42 bin: $.bin,
43 wantedKeys: 'para',43 wantedKeys: 'para',
44 extraArgs: [
45 '--increase-future-pool',
46 ],
44 },47 },
45 for name in ['alice', 'bob']48 for name in ['alice', 'bob']
46 },49 },
modified.github/workflows/node-only-update.ymldiffbeforeafterboth
158 .baedeker/vendor158 .baedeker/vendor
159 tla-str: |159 tla-str: |
160 relay_spec=${{ env.RELAY_CHAIN_TYPE }}-local160 relay_spec=${{ env.RELAY_CHAIN_TYPE }}-local
161 inputs: |161 inputs: |
162 .baedeker/node-only.jsonnet162 .baedeker/node-only.jsonnet
163 snippet:(import 'baedeker-library/ops/rewrites.libsonnet').rewriteNodePaths({'bin/polkadot':{dockerImage:'${{ steps.polkadot.outputs.name }}'}})163 snippet:(import 'baedeker-library/ops/rewrites.libsonnet').rewriteNodePaths({'bin/polkadot':{dockerImage:'${{ steps.polkadot.outputs.name }}'}})
164 ephemeral:snippet:(import 'baedeker-library/ops/rewrites.libsonnet').rewriteNodePaths({'bin/unique':{dockerImage:'${{ steps.mainnet.outputs.name }}'}})164 # extra_node_mixin due to mainnet unique node not supporting --increase-future-pool
165 ephemeral:snippet:(import 'baedeker-library/ops/rewrites.libsonnet').rewriteNodePaths({'bin/unique':{dockerImage:'${{ steps.mainnet.outputs.name }}'}}, extra_node_mixin={extraArgs: []})
165166
166 - name: Run Parallel tests before Node Parachain upgrade167 - name: Run Parallel tests before Node Parachain upgrade
167 working-directory: ${{ matrix.mainnet_branch }}/tests168 working-directory: ${{ matrix.mainnet_branch }}/tests
modifiednode/cli/src/cli.rsdiffbeforeafterboth
106 #[clap(long)]106 #[clap(long)]
107 pub no_hardware_benchmarks: bool,107 pub no_hardware_benchmarks: bool,
108
109 /// Make future pool the same size as the ready pool.
110 ///
111 /// By default, future pool is factor 10 smaler than the ready pool, which causes transactions to be dropped as they
112 /// are retracted, without the ability to move them back to the ready pool after revalidation.
113 ///
114 /// This switch makes that transactions still can be dropped, but only when there is more transactions than the pool
115 /// size configured with `--pool-limit` (amount of txes), `--pool-kbytes` (size of all txes in kbytes).
116 pub increase_future_pool: bool,
108117
109 /// Relaychain arguments118 /// Relaychain arguments
110 #[structopt(raw = true)]119 #[structopt(raw = true)]
modifiednode/cli/src/command.rsdiffbeforeafterboth
458 let runner = cli.create_runner(&cli.run.normalize())?;458 let runner = cli.create_runner(&cli.run.normalize())?;
459 let collator_options = cli.run.collator_options();459 let collator_options = cli.run.collator_options();
460460
461 runner.run_node_until_exit(|config| async move {461 runner.run_node_until_exit(|mut config| async move {
462 let hwbench = if !cli.no_hardware_benchmarks {462 let hwbench = if !cli.no_hardware_benchmarks {
463 config.database.path().map(|database_path| {463 config.database.path().map(|database_path| {
464 let _ = std::fs::create_dir_all(database_path);464 let _ = std::fs::create_dir_all(database_path);
468 None468 None
469 };469 };
470
471 if cli.increase_future_pool {
472 config.transaction_pool.future = config.transaction_pool.ready.clone();
473 }
470474
471 let extensions = chain_spec::Extensions::try_get(&*config.chain_spec);475 let extensions = chain_spec::Extensions::try_get(&*config.chain_spec);
472476