aergoio/aergo

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

Open

func (mr *MockNetworkTransportMockRecorder) ClosePeerConnection(arg0 interface{}) *gomock.Call {
    mr.mock.ctrl.T.Helper()
    return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "ClosePeerConnection", reflect.TypeOf((*MockNetworkTransport)(nil).ClosePeerConnection), arg0)
}

• Read up
  Read up

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

Open

func (mr *MockWaitingPeerManagerMockRecorder) OnDiscoveredPeers(metas interface{}) *gomock.Call {
    mr.mock.ctrl.T.Helper()
    return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "OnDiscoveredPeers", reflect.TypeOf((*MockWaitingPeerManager)(nil).OnDiscoveredPeers), metas)
}

• Read up
  Read up

Method V033Handshaker.checkRemoteStatus has 6 return statements (exceeds 4 allowed).

Open

func (h *V033Handshaker) checkRemoteStatus(remotePeerStatus *types.Status) error {
    // v030 checking
    // check if chainID is same or not
    remoteChainID := types.NewChainID()
    err := remoteChainID.Read(remotePeerStatus.ChainID)

Method Cluster.isAllMembersEqual has 6 return statements (exceeds 4 allowed).

Open

func (cl *Cluster) isAllMembersEqual(members []*consensus.Member, RemovedMembers []*consensus.Member) bool {
    membersEqual := func(x []*consensus.Member, y []*consensus.Member) bool {
        if len(x) != len(y) {
            return false
        }

Method V200Handshaker.DoForInbound has 6 return statements (exceeds 4 allowed).

Open

func (h *V200Handshaker) DoForInbound(ctx context.Context) (*p2pcommon.HandshakeResult, error) {
    h.logger.Debug().Stringer(p2putil.LogPeerID, types.LogPeerShort(h.peerID)).Msg("Starting versioned handshake for inbound peer connection")

    // inbound: receive, check and send
    remotePeerStatus, err := h.receiveRemoteStatus(ctx)

Method V033Handshaker.DoForInbound has 6 return statements (exceeds 4 allowed).

Open

func (h *V033Handshaker) DoForInbound(ctx context.Context) (*p2pcommon.HandshakeResult, error) {
    h.logger.Debug().Stringer(p2putil.LogPeerID, types.LogPeerShort(h.peerID)).Msg("Starting versioned handshake for inbound peer connection")

    // inbound: receive, check and send
    remotePeerStatus, err := h.receiveRemoteStatus(ctx)

Method V200Handshaker.receiveRemoteStatus has 6 return statements (exceeds 4 allowed).

Open

func (h *V200Handshaker) receiveRemoteStatus(ctx context.Context) (*types.Status, error) {
    // and wait to response status
    data, err := h.msgRW.ReadMsg()
    if err != nil {
        h.sendGoAway("malformed message")

Method V032Handshaker.DoForOutbound has 6 return statements (exceeds 4 allowed).

Open

func (h *V032Handshaker) DoForOutbound(ctx context.Context) (*p2pcommon.HandshakeResult, error) {
    h.logger.Debug().Stringer(p2putil.LogPeerID, types.LogPeerShort(h.peerID)).Msg("Starting versioned handshake for outbound peer connection")

    bestBlock, err := h.actor.GetChainAccessor().GetBestBlock()
    if err != nil {

Function GetClusterInfo has 6 return statements (exceeds 4 allowed).

Open

func GetClusterInfo(hs *component.ComponentHub, bestHash []byte) (*Cluster, *types.HardStateInfo, error) {
    logger.Info().Msg("try getclusterinfo to p2p")

    replyC := make(chan *message.GetClusterRsp)
    hs.Tell(message.P2PSvc, &message.GetCluster{BestBlockHash: bestHash, ReplyC: replyC})

Method V030Handshaker.DoForInbound has 6 return statements (exceeds 4 allowed).

Open

func (h *V030Handshaker) DoForInbound(ctx context.Context) (*p2pcommon.HandshakeResult, error) {
    h.logger.Debug().Stringer(p2putil.LogPeerID, types.LogPeerShort(h.peerID)).Msg("Starting versioned handshake for inbound peer connection")

    // inbound: receive, check and send
    remotePeerStatus, err := h.receiveRemoteStatus(ctx)

Method V033Handshaker.DoForOutbound has 6 return statements (exceeds 4 allowed).

Open

func (h *V033Handshaker) DoForOutbound(ctx context.Context) (*p2pcommon.HandshakeResult, error) {
    h.logger.Debug().Stringer(p2putil.LogPeerID, types.LogPeerShort(h.peerID)).Msg("Starting versioned handshake for outbound peer connection")

    // find my best block
    bestBlock, err := h.actor.GetChainAccessor().GetBestBlock()

Method V030Handshaker.DoForOutbound has 6 return statements (exceeds 4 allowed).

Open

func (h *V030Handshaker) DoForOutbound(ctx context.Context) (*p2pcommon.HandshakeResult, error) {
    h.logger.Debug().Stringer(p2putil.LogPeerID, types.LogPeerShort(h.peerID)).Msg("Starting versioned handshake for outbound peer connection")
    bestBlock, err := h.actor.GetChainAccessor().GetBestBlock()
    if err != nil {
        return nil, err

Method GetTxsReceiver.handleInWaiting has 6 return statements (exceeds 4 allowed).

Open

func (br *GetTxsReceiver) handleInWaiting(msg p2pcommon.Message, msgBody p2pcommon.MessageBody) {
    // consuming request id when timeout, no more resp expected (i.e. hasNext == false ) or malformed body.
    // timeout
    if br.timeout.Before(time.Now()) {
        // silently ignore already status job

Method AergoRPCService.ImportAccount has 6 return statements (exceeds 4 allowed).

Open

func (rpc *AergoRPCService) ImportAccount(ctx context.Context, in *types.ImportFormat) (*types.Account, error) {
    if err := rpc.checkAuth(ctx, WriteBlockChain); err != nil {
        return nil, err
    }
    msg := &message.ImportAccount{OldPass: in.Oldpass, NewPass: in.Newpass}

Method AergoRPCService.checkAuth has 6 return statements (exceeds 4 allowed).

Open

func (rpc *AergoRPCService) checkAuth(ctx context.Context, auth Authentication) error {
    rpc.clientAuthLock.RLock()
    defer rpc.clientAuthLock.RUnlock()

    if !rpc.clientAuthOn || len(rpc.clientAuth) == 0 {

Method V200Handshaker.DoForOutbound has 6 return statements (exceeds 4 allowed).

Open

func (h *V200Handshaker) DoForOutbound(ctx context.Context) (*p2pcommon.HandshakeResult, error) {
    h.logger.Debug().Stringer(p2putil.LogPeerID, types.LogPeerShort(h.peerID)).Msg("Starting versioned handshake for outbound peer connection")

    // find my best block
    bestBlock, err := h.is.GetChainAccessor().GetBestBlock()

Method WalDB.convertWalToRaft has 6 return statements (exceeds 4 allowed).

Open

func (wal *WalDB) convertWalToRaft(walEntry *consensus.WalEntry) (*raftpb.Entry, error) {
    var raftEntry = &raftpb.Entry{Term: walEntry.Term, Index: walEntry.Index}

    getDataFromWalEntry := func(walEntry *consensus.WalEntry) ([]byte, error) {
        if walEntry.Type != consensus.EntryBlock {

Method V030ReadWriter.ReadMsg has 6 return statements (exceeds 4 allowed).

Open

func (rw *V030ReadWriter) ReadMsg() (p2pcommon.Message, error) {
    readN := 0
    // fill data
    read, err := rw.readToLen(rw.readBuf[:], msgHeaderLength)
    if err != nil {

Method raftServer.publishSnapshot has 6 return statements (exceeds 4 allowed).

Open

func (rs *raftServer) publishSnapshot(snapshotToSave raftpb.Snapshot) error {
    updateProgress := func() error {
        var snapdata = &consensus.SnapshotData{}

        err := snapdata.Decode(snapshotToSave.Data)

Method ChainSnapshotter.requestSync has 6 return statements (exceeds 4 allowed).

Open

func (chainsnap *ChainSnapshotter) requestSync(snap *consensus.ChainSnapshot) error {

    var leader uint64
    getSyncLeader := func() (types.PeerID, error) {
        var peerID types.PeerID