Node: Remove unnecessary debug logging (#3149)
Change-Id: Id56d0863a0c2bfcf428ee836ae924f286f11661e
This commit is contained in:
parent
375dd08a3f
commit
589c2e53b7
|
@ -292,12 +292,10 @@ func (acct *Accountant) publishTransferAlreadyLocked(pe *pendingEntry) {
|
||||||
|
|
||||||
// addPendingTransferAlreadyLocked adds a pending transfer to both the map and the database. It assumes the caller holds the lock.
|
// addPendingTransferAlreadyLocked adds a pending transfer to both the map and the database. It assumes the caller holds the lock.
|
||||||
func (acct *Accountant) addPendingTransferAlreadyLocked(pe *pendingEntry) error {
|
func (acct *Accountant) addPendingTransferAlreadyLocked(pe *pendingEntry) error {
|
||||||
acct.logger.Info("writing transfer to database", zap.String("msgId", pe.msgId))
|
|
||||||
pe.setUpdTime()
|
pe.setUpdTime()
|
||||||
if err := acct.db.AcctStorePendingTransfer(pe.msg); err != nil {
|
if err := acct.db.AcctStorePendingTransfer(pe.msg); err != nil {
|
||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
acct.logger.Info("wrote message to database", zap.String("msgId", pe.msgId))
|
|
||||||
|
|
||||||
acct.pendingTransfers[pe.msgId] = pe
|
acct.pendingTransfers[pe.msgId] = pe
|
||||||
transfersOutstanding.Set(float64(len(acct.pendingTransfers)))
|
transfersOutstanding.Set(float64(len(acct.pendingTransfers)))
|
||||||
|
|
|
@ -393,7 +393,6 @@ func (gov *ChainGovernor) ProcessMsgForTime(msg *common.MessagePublication, now
|
||||||
|
|
||||||
if enqueueIt {
|
if enqueueIt {
|
||||||
dbData := db.PendingTransfer{ReleaseTime: releaseTime, Msg: *msg}
|
dbData := db.PendingTransfer{ReleaseTime: releaseTime, Msg: *msg}
|
||||||
gov.logger.Info("writing pending transfer to database", zap.String("msgId", msg.MessageIDString()))
|
|
||||||
err = gov.db.StorePendingMsg(&dbData)
|
err = gov.db.StorePendingMsg(&dbData)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
gov.logger.Error("failed to store pending vaa",
|
gov.logger.Error("failed to store pending vaa",
|
||||||
|
@ -404,7 +403,6 @@ func (gov *ChainGovernor) ProcessMsgForTime(msg *common.MessagePublication, now
|
||||||
)
|
)
|
||||||
return false, err
|
return false, err
|
||||||
}
|
}
|
||||||
gov.logger.Info("wrote pending transfer to database", zap.String("msgId", msg.MessageIDString()))
|
|
||||||
|
|
||||||
ce.pending = append(ce.pending, &pendingEntry{token: token, amount: payload.Amount, hash: hash, dbData: dbData})
|
ce.pending = append(ce.pending, &pendingEntry{token: token, amount: payload.Amount, hash: hash, dbData: dbData})
|
||||||
gov.msgsSeen[hash] = transferEnqueued
|
gov.msgsSeen[hash] = transferEnqueued
|
||||||
|
|
Loading…
Reference in New Issue