Fantom-foundation/go-lachesis

Method Service.processEvent has 6 return statements (exceeds 4 allowed).

Open

func (s *Service) processEvent(realEngine Consensus, e *inter.Event) error {
    // s.engineMu is locked here
    if s.stopped {
        return errStopped
    }

Method PeerPacksDownloader.binarySearchReq has 6 return statements (exceeds 4 allowed).

Open

func (d *PeerPacksDownloader) binarySearchReq() (requestIndex idx.Pack, requestFull bool, syncedUp bool) {
    it := d.packInfos.Iterator()
    var prevIdx *idx.Pack

    for it.End(); it.Prev(); {

Similar blocks of code found in 2 locations. Consider refactoring.

Open

func (s *PublicBlockChainAPI) GetUncleCountByBlockNumber(ctx context.Context, blockNr rpc.BlockNumber) *hexutil.Uint {
    if block, _ := s.b.BlockByNumber(ctx, blockNr); block != nil {
        n := hexutil.Uint(len(noUncles))
        return &n
    }

• Read up
  Read up

Similar blocks of code found in 2 locations. Consider refactoring.

Open

func (s *PublicBlockChainAPI) GetUncleCountByBlockHash(ctx context.Context, blockHash common.Hash) *hexutil.Uint {
    if block, _ := s.b.BlockByHash(ctx, blockHash); block != nil {
        n := hexutil.Uint(len(noUncles))
        return &n
    }

• Read up
  Read up

Similar blocks of code found in 2 locations. Consider refactoring.

Open

func (p *peer) AsyncSendTransactions(txs []*types.Transaction) {
    select {
    case p.queuedTxs <- txs:
        // Mark all the transactions as known, but ensure we don't overflow our limits
        for _, tx := range txs {

• Read up
  Read up

Similar blocks of code found in 2 locations. Consider refactoring.

Open

func (h *HandlerT) GoTrace(file string, nsec uint) error {
    if err := h.StartGoTrace(file); err != nil {
        return err
    }
    time.Sleep(time.Duration(nsec) * time.Second)

• Read up
  Read up

Similar blocks of code found in 2 locations. Consider refactoring.

Open

func (b HighestBeforeTime) Get(i idx.Validator) inter.Timestamp {
    for int(i) >= b.Size() {
        return 0
    }
    return inter.Timestamp(binary.LittleEndian.Uint64(b[i*8 : (i+1)*8]))

• Read up
  Read up

Similar blocks of code found in 2 locations. Consider refactoring.

Open

func (b LowestAfterSeq) Get(i idx.Validator) idx.Event {
    for int(i) >= b.Size() {
        return 0
    }
    return idx.Event(binary.LittleEndian.Uint32(b[i*4 : (i+1)*4]))

• Read up
  Read up

Similar blocks of code found in 2 locations. Consider refactoring.

Open

func (h *HandlerT) CpuProfile(file string, nsec uint) error {
    if err := h.StartCPUProfile(file); err != nil {
        return err
    }
    time.Sleep(time.Duration(nsec) * time.Second)

• Read up
  Read up

Similar blocks of code found in 2 locations. Consider refactoring.

Open

func (p *peer) AsyncSendEvents(events inter.Events) {
    select {
    case p.queuedProps <- events:
        // Mark all the event hash as known, but ensure we don't overflow our limits
        for _, event := range events {

• Read up
  Read up

Function DoEstimateGas has 5 arguments (exceeds 4 allowed). Consider refactoring.

Open

func DoEstimateGas(ctx context.Context, b Backend, args CallArgs, blockNrOrHash rpc.BlockNumberOrHash, gasCap uint64) (hexutil.Uint64, error) {

Method ContractFilterer.WatchCreatedWithdrawRequest has 5 arguments (exceeds 4 allowed). Consider refactoring.

Open

func (_Contract *ContractFilterer) WatchCreatedWithdrawRequest(opts *bind.WatchOpts, sink chan<- *ContractCreatedWithdrawRequest, auth []common.Address, receiver []common.Address, stakerID []*big.Int) (event.Subscription, error) {

Function NewBlock has 5 arguments (exceeds 4 allowed). Consider refactoring.

Open

func NewBlock(index idx.Block, time Timestamp, atropos hash.Event, prevHash hash.Event, events hash.Events) *Block {

Method ContractCaller.CalcDelegationEpochReward has 5 arguments (exceeds 4 allowed). Consider refactoring.

Open

func (_Contract *ContractCaller) CalcDelegationEpochReward(opts *bind.CallOpts, stakerID *big.Int, epoch *big.Int, delegationAmount *big.Int, commission *big.Int) (*big.Int, error) {

Function GenerateChain has 5 arguments (exceeds 4 allowed). Consider refactoring.

Open

func GenerateChain(config *params.ChainConfig, parent *EvmBlock, db ethdb.Database, n int, gen func(int, *BlockGen)) ([]*EvmBlock, []types.Receipts, DummyChain) {

Method ContractFilterer.WatchPartialWithdrawnByRequest has 5 arguments (exceeds 4 allowed). Consider refactoring.

Open

func (_Contract *ContractFilterer) WatchPartialWithdrawnByRequest(opts *bind.WatchOpts, sink chan<- *ContractPartialWithdrawnByRequest, auth []common.Address, receiver []common.Address, stakerID []*big.Int) (event.Subscription, error) {

Method PublicDebugAPI.BlocksTTF has 5 arguments (exceeds 4 allowed). Consider refactoring.

Open

func (s *PublicDebugAPI) BlocksTTF(ctx context.Context, untilBlock rpc.BlockNumber, maxBlocks hexutil.Uint64, mode string, verbosity hexutil.Uint64) (map[string]interface{}, error) {

Method Oracle.getBlockPrices has 5 arguments (exceeds 4 allowed). Consider refactoring.

Open

func (gpo *Oracle) getBlockPrices(ctx context.Context, blockNum uint64, limit int, result chan getBlockPricesResult, quit chan struct{}) {

Function ForEachRandEvent has 5 arguments (exceeds 4 allowed). Consider refactoring.

Open

    nodes []idx.StakerID,
    eventCount int,
    parentCount int,
    r *rand.Rand,
    callback ForEachEvent,

Method ContractFilterer.WatchUpdatedDelegation has 5 arguments (exceeds 4 allowed). Consider refactoring.

Open

func (_Contract *ContractFilterer) WatchUpdatedDelegation(opts *bind.WatchOpts, sink chan<- *ContractUpdatedDelegation, delegator []common.Address, oldStakerID []*big.Int, newStakerID []*big.Int) (event.Subscription, error) {