diff --git a/cmd/flags/prover.go b/cmd/flags/prover.go index 8cd2ecac1..409111149 100644 --- a/cmd/flags/prover.go +++ b/cmd/flags/prover.go @@ -53,16 +53,6 @@ var ( "`lowerBound-upperBound` (e.g. `30m-1h`), testing purposes only", Category: proverCategory, } - ProverIdx = cli.UintFlag{ - Name: "proverIdx", - Value: 0, - Category: proverCategory, - } - TotalProvers = cli.UintFlag{ - Name: "totalProvers", - Value: 0, - Category: proverCategory, - } ) // All prover flags. @@ -74,6 +64,4 @@ var ProverFlags = MergeFlags(CommonFlags, []cli.Flag{ &MaxConcurrentProvingJobs, &Dummy, &RandomDummyProofDelay, - &ProverIdx, - &TotalProvers, }) diff --git a/prover/config.go b/prover/config.go index b09e2dd42..92554da8d 100644 --- a/prover/config.go +++ b/prover/config.go @@ -27,8 +27,6 @@ type Config struct { Dummy bool RandomDummyProofDelayLowerBound *time.Duration RandomDummyProofDelayUpperBound *time.Duration - Idx uint - Total uint } // NewConfigFromCliContext creates a new config instance from command line flags. @@ -87,7 +85,5 @@ func NewConfigFromCliContext(c *cli.Context) (*Config, error) { Dummy: c.Bool(flags.Dummy.Name), RandomDummyProofDelayLowerBound: randomDummyProofDelayLowerBound, RandomDummyProofDelayUpperBound: randomDummyProofDelayUpperBound, - Idx: c.Uint(flags.ProverIdx.Name), - Total: c.Uint(flags.TotalProvers.Name), }, nil } diff --git a/prover/prover.go b/prover/prover.go index 883b7dcfb..5dbd71414 100644 --- a/prover/prover.go +++ b/prover/prover.go @@ -95,7 +95,7 @@ func InitFromConfig(ctx context.Context, p *Prover, cfg *Config) (err error) { } p.protocolConfigs = &protocolConfigs - log.Info("Protocol configs", "configs", p.protocolConfigs, "totalProver", p.cfg.Total, "proverIdx", p.cfg.Idx) + log.Info("Protocol configs", "configs") p.submitProofTxMutex = &sync.Mutex{} p.txListValidator = txListValidator.NewTxListValidator( @@ -268,19 +268,6 @@ func (p *Prover) onBlockProposed( handleBlockProposedEvent := func() error { defer func() { <-p.proposeConcurrencyGuard }() - log.Info( - "Check proposed block", - "totalProver", p.cfg.Total, - "proverIdx", p.cfg.Idx, - ) - - if p.cfg.Total > 0 { - if event.Id.Uint64()%uint64(p.cfg.Total) != uint64(p.cfg.Idx) { - log.Info("Ignore proposed block", "blockID", event.Id, "idx", p.cfg.Idx, "total", p.cfg.Total) - return nil - } - } - // Check whether the block has been verified. isVerified, err := p.isBlockVerified(event.Id) if err != nil {