Fantom-foundation/go-lachesis

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

Open

func (_Contract *ContractSession) Delegations(arg0 common.Address, arg1 *big.Int) (struct {
    CreatedEpoch     *big.Int
    CreatedTime      *big.Int
    DeactivatedEpoch *big.Int
    DeactivatedTime  *big.Int

• Read up
  Read up

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

Open

func (_Contract *ContractCallerSession) Delegations(arg0 common.Address, arg1 *big.Int) (struct {
    CreatedEpoch     *big.Int
    CreatedTime      *big.Int
    DeactivatedEpoch *big.Int
    DeactivatedTime  *big.Int

• Read up
  Read up

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

Open

func (_Contract *ContractCallerSession) Delegations(arg0 common.Address, arg1 *big.Int) (struct {
    CreatedEpoch     *big.Int
    CreatedTime      *big.Int
    DeactivatedEpoch *big.Int
    DeactivatedTime  *big.Int

• Read up
  Read up

Method rows.Optimize has 62 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func (rr *rows) Optimize() {

    for curr, row := range rr.rows {
    REFS:
        for iRef, ref := range row.Refs {

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

Open

func (s *Store) DelSfcStaker(stakerID idx.StakerID) {
    s.mutex.Stakers.Lock()
    defer s.mutex.Stakers.Unlock()

    err := s.table.Stakers.Delete(stakerID.Bytes())

• Read up
  Read up

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

Open

func (s *Store) DelSfcDelegation(id sfctype.DelegationID) {
    s.mutex.Delegations.Lock()
    defer s.mutex.Delegations.Unlock()

    err := s.table.Delegations.Delete(id.Bytes())

• Read up
  Read up

Method TxPool.truncatePending has 61 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func (pool *TxPool) truncatePending() {
    pending := uint64(0)
    for _, list := range pool.pending {
        pending += uint64(list.Len())
    }

Method iterator.Next has 61 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func (it *iterator) Next() bool {
    it.lock.Lock()
    defer it.lock.Unlock()

    if it.Error() != nil {

Method ProtocolManager.makeFetcher has 61 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func (pm *ProtocolManager) makeFetcher(checkers *eventcheck.Checkers) (*fetcher.Fetcher, *ordering.EventBuffer) {
    // checkers
    firstCheck := func(e *inter.Event) error {
        if err := checkers.Basiccheck.Validate(e); err != nil {
            return err

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

Open

    go func() {
        for {
            select {
            case l := <-logs:
                api.filtersMu.Lock()

• Read up
  Read up

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

Open

    go func() {
        for {
            select {
            case ph := <-pendingTxs:
                api.filtersMu.Lock()

• Read up
  Read up

Function startNode has 60 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func startNode(ctx *cli.Context, stack *node.Node) {
    debug.Memsize.Add("node", stack)

    // Start up the node itself
    utils.StartNode(stack)

Function importFile has 60 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func importFile(srv *gossip.Service, check bool, fn string) error {
    // Watch for Ctrl-C while the import is running.
    // If a signal is received, the import will stop.
    interrupt := make(chan os.Signal, 1)
    signal.Notify(interrupt, syscall.SIGINT, syscall.SIGTERM)

Method TxPool.add has 59 lines of code (exceeds 50 allowed). Consider refactoring.

Open

func (pool *TxPool) add(tx *types.Transaction, local bool) (replaced bool, err error) {
    // If the transaction is already known, discard it
    hash := tx.Hash()
    if pool.all.Get(hash) != nil {
        log.Trace("Discarding already known transaction", "hash", hash)

Method Service.processEvent has 59 lines of code (exceeds 50 allowed). Consider refactoring.

Open

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

Method Emitter.createEvent has 14 return statements (exceeds 4 allowed).

Open

func (em *Emitter) createEvent(poolTxs map[common.Address]types.Transactions) *inter.Event {
    if em.myStakerID == 0 {
        // not a validator
        return nil
    }

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

Open

func (_Contract *ContractSession) LegacyDelegations(arg0 common.Address) (struct {
    CreatedEpoch     *big.Int
    CreatedTime      *big.Int
    DeactivatedEpoch *big.Int
    DeactivatedTime  *big.Int

• Read up
  Read up

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

Open

func (_Contract *ContractCallerSession) Delegations(arg0 common.Address) (struct {
    CreatedEpoch     *big.Int
    CreatedTime      *big.Int
    DeactivatedEpoch *big.Int
    DeactivatedTime  *big.Int

• Read up
  Read up

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

Open

func (_Contract *ContractCallerSession) LegacyDelegations(arg0 common.Address) (struct {
    CreatedEpoch     *big.Int
    CreatedTime      *big.Int
    DeactivatedEpoch *big.Int
    DeactivatedTime  *big.Int

• Read up
  Read up

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

Open

func (_Contract *ContractSession) Delegations(arg0 common.Address) (struct {
    CreatedEpoch     *big.Int
    CreatedTime      *big.Int
    DeactivatedEpoch *big.Int
    DeactivatedTime  *big.Int

• Read up
  Read up