@@ -430,12 +430,12 @@ func runPeerListUpdater() (err error) {
430430 if _ , err = getPeers (dbID , privKey ); err != nil {
431431 log .WithField ("db" , dbID ).
432432 WithError (err ).
433- Warning ("update peers failed" )
433+ Debug ("update peers failed" )
434434
435435 // TODO(xq262144), better rpc remote error judgement
436436 if strings .Contains (err .Error (), bp .ErrNoSuchDatabase .Error ()) {
437437 log .WithField ("db" , dbID ).
438- Warning ("database no longer exists, stopped peers update" )
438+ Warning ("database no longer exists, stopping peers update" )
439439 peerList .Delete (dbID )
440440 }
441441 }
@@ -493,14 +493,13 @@ func getPeers(dbID proto.DatabaseID, privKey *asymmetric.PrivateKey) (peers *pro
493493 profileReq .DBID = dbID
494494 err = rpc .RequestBP (route .MCCQuerySQLChainProfile .String (), profileReq , profileResp )
495495 if err != nil {
496- log . WithError ( err ). Warning ( "get sqlchain profile failed in getPeers" )
496+ err = errors . Wrap ( err , "get sqlchain profile failed in getPeers" )
497497 return
498498 }
499499
500500 nodeIDs := make ([]proto.NodeID , len (profileResp .Profile .Miners ))
501501 if len (profileResp .Profile .Miners ) <= 0 {
502- err = ErrInvalidProfile
503- log .WithError (err ).Warning ("unexpected error in getPeers" )
502+ err = errors .Wrap (ErrInvalidProfile , "unexpected error in getPeers" )
504503 return
505504 }
506505 for i , mi := range profileResp .Profile .Miners {
@@ -514,7 +513,7 @@ func getPeers(dbID proto.DatabaseID, privKey *asymmetric.PrivateKey) (peers *pro
514513 }
515514 err = peers .Sign (privKey )
516515 if err != nil {
517- log . WithError ( err ). Warning ( "sign peers failed in getPeers" )
516+ err = errors . Wrap ( err , "sign peers failed in getPeers" )
518517 return
519518 }
520519
0 commit comments