From 8e3e8ad16fd85713c158fb7c7422e6cf03ca1d14 Mon Sep 17 00:00:00 2001 From: Oliver Bundalo Date: Mon, 5 Aug 2024 08:36:48 +0200 Subject: [PATCH] LT gossip msg size -> 16 MB --- .github/workflows/nightly.yml | 4 ++-- consensus/polybft/consensus_runtime.go | 10 ---------- gasprice/gasprice_test.go | 8 +++++--- network/gossip_test.go | 2 +- 4 files changed, 8 insertions(+), 16 deletions(-) diff --git a/.github/workflows/nightly.yml b/.github/workflows/nightly.yml index 6e69c45891..3efa3caeb5 100644 --- a/.github/workflows/nightly.yml +++ b/.github/workflows/nightly.yml @@ -30,7 +30,7 @@ jobs: max_enqueued: "20000000" is_london_fork_active: true is_bridge_active: false - gossip_msg_size: "8388608" + gossip_msg_size: "16777216" notification: false secrets: AWS_ROLE_ARN: ${{ secrets.AWS_ROLE_ARN }} @@ -168,7 +168,7 @@ jobs: max_enqueued: "20000000" is_london_fork_active: true is_bridge_active: false - gossip_msg_size: "8388608" + gossip_msg_size: "16777216" logs: true build_blade_output: ${{ needs.ci.outputs.build_blade }} lint_output: ${{ needs.ci.outputs.lint }} diff --git a/consensus/polybft/consensus_runtime.go b/consensus/polybft/consensus_runtime.go index cfc9682f3f..c68184997a 100644 --- a/consensus/polybft/consensus_runtime.go +++ b/consensus/polybft/consensus_runtime.go @@ -902,16 +902,6 @@ func (c *consensusRuntime) BuildPrePrepareMessage( certificate *proto.RoundChangeCertificate, view *proto.View, ) *proto.IbftMessage { - // Add debug log for cases when RCC is not nil - if certificate != nil { - c.logger.Debug("BuildPrePrepareMessage", "rawProposal length", len(rawProposal), - "certificate length", len(certificate.String())) - - for i, rcMsg := range certificate.RoundChangeMessages { - c.logger.Debug("BuildPrePrepareMessage", "RC msg index", i, "RC msg length", len(rcMsg.String())) - } - } - if len(rawProposal) == 0 { c.logger.Error("can not build pre-prepare message, since proposal is empty") diff --git a/gasprice/gasprice_test.go b/gasprice/gasprice_test.go index 21b23792d2..38293b9954 100644 --- a/gasprice/gasprice_test.go +++ b/gasprice/gasprice_test.go @@ -18,6 +18,8 @@ import ( func TestGasHelper_MaxPriorityFeePerGas(t *testing.T) { t.Parallel() + defaultGasPrice := DefaultGasHelperConfig.LastPrice + var cases = []struct { Name string Expected *big.Int @@ -118,7 +120,7 @@ func TestGasHelper_MaxPriorityFeePerGas(t *testing.T) { { Name: "Number of blocks in chain smaller than numOfBlocksToCheck", Expected: DefaultGasHelperConfig.LastPrice.Mul( - DefaultGasHelperConfig.LastPrice, big.NewInt(2)), // at least two times of default last price + defaultGasPrice, big.NewInt(2)), // at least two times of default last price GetBackend: func() Blockchain { backend := createTestBlocks(t, 10) createTestTxs(t, backend, 3, 200) @@ -129,7 +131,7 @@ func TestGasHelper_MaxPriorityFeePerGas(t *testing.T) { { Name: "Number of blocks in chain higher than numOfBlocksToCheck", Expected: DefaultGasHelperConfig.LastPrice.Mul( - DefaultGasHelperConfig.LastPrice, big.NewInt(2)), // at least two times of default last price + defaultGasPrice, big.NewInt(2)), // at least two times of default last price GetBackend: func() Blockchain { backend := createTestBlocks(t, 30) createTestTxs(t, backend, 3, 200) @@ -140,7 +142,7 @@ func TestGasHelper_MaxPriorityFeePerGas(t *testing.T) { { Name: "Not enough transactions in first 20 blocks, so read some more blocks", Expected: DefaultGasHelperConfig.LastPrice.Mul( - DefaultGasHelperConfig.LastPrice, big.NewInt(2)), // at least two times of default last price + defaultGasPrice, big.NewInt(2)), // at least two times of default last price GetBackend: func() Blockchain { backend := createTestBlocks(t, 50) createTestTxs(t, backend, 1, 200) diff --git a/network/gossip_test.go b/network/gossip_test.go index 0885ee1264..5ab303ae21 100644 --- a/network/gossip_test.go +++ b/network/gossip_test.go @@ -31,7 +31,7 @@ func WaitForSubscribers(ctx context.Context, srv *Server, topic string, expected } func TestSimpleGossip(t *testing.T) { - numServers := 9 + numServers := 8 sentMessage := fmt.Sprintf("%d", time.Now().UTC().Unix()) servers, createErr := createServers(numServers, nil)