forks/go-ethereum
1
0
Fork 1
mirror of https://github.com/ethereum/go-ethereum.git synced 2026-07-17 18:30:45 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 1

Merge pull request #399 from XinFinOrg/xdp-01

Browse source 
fix: remove unnecessary assignment
This commit is contained in:
Liam 2024-01-22 14:53:13 +08:00 committed by GitHub
commit ddac0a6af7
No known key found for this signature in database
GPG key ID: B5690EEEBB952194
2 changed files with 15 additions and 6 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

17
XDCx/XDCx.go
View file

@ -95,8 +95,14 @@ func NewMongoDBEngine(cfg *Config) *XDCxDAO.MongoDatabase {
} }
func New(cfg *Config) *XDCX { func New(cfg *Config) *XDCX {
tokenDecimalCache, _ := lru.New(defaultCacheLimit) tokenDecimalCache, err := lru.New(defaultCacheLimit)
orderCache, _ := lru.New(tradingstate.OrderCacheLimit) if err != nil {
log.Warn("[XDCx-New] fail to create new lru for token decimal", "error", err)
}
orderCache, err := lru.New(tradingstate.OrderCacheLimit)
if err != nil {
log.Warn("[XDCx-New] fail to create new lru for order", "error", err)
}
XDCX := &XDCX{ XDCX := &XDCX{
orderNonce: make(map[common.Address]*big.Int), orderNonce: make(map[common.Address]*big.Int),
Triegc: prque.New(), Triegc: prque.New(),
@ -121,7 +127,10 @@ func New(cfg *Config) *XDCX {
// Overflow returns an indication if the message queue is full. // Overflow returns an indication if the message queue is full.
func (XDCx *XDCX) Overflow() bool { func (XDCx *XDCX) Overflow() bool {
val, _ := XDCx.settings.Load(overflowIdx) val, ok := XDCx.settings.Load(overflowIdx)
if !ok {
log.Warn("[XDCx-Overflow] fail to load overflow index")
}
return val.(bool) return val.(bool)
} }
@ -639,7 +648,7 @@ func (XDCx *XDCX) RollbackReorgTxMatch(txhash common.Hash) error {
continue continue
} }
orderCacheAtTxHash := c.(map[common.Hash]tradingstate.OrderHistoryItem) orderCacheAtTxHash := c.(map[common.Hash]tradingstate.OrderHistoryItem)
orderHistoryItem, _ := orderCacheAtTxHash[tradingstate.GetOrderHistoryKey(order.BaseToken, order.QuoteToken, order.Hash)] orderHistoryItem := orderCacheAtTxHash[tradingstate.GetOrderHistoryKey(order.BaseToken, order.QuoteToken, order.Hash)]
if (orderHistoryItem == tradingstate.OrderHistoryItem{}) { if (orderHistoryItem == tradingstate.OrderHistoryItem{}) {
log.Debug("XDCx reorg: remove order due to empty orderHistory", "order", tradingstate.ToJSON(order)) log.Debug("XDCx reorg: remove order due to empty orderHistory", "order", tradingstate.ToJSON(order))
if err := db.DeleteObject(order.Hash, &tradingstate.OrderItem{}); err != nil { if err := db.DeleteObject(order.Hash, &tradingstate.OrderItem{}); err != nil {

4
XDCxlending/XDCxlending.go
View file

@ -764,7 +764,7 @@ func (l *Lending) RollbackLendingData(txhash common.Hash) error {
continue continue
} }
cacheAtTxHash := c.(map[common.Hash]lendingstate.LendingItemHistoryItem) cacheAtTxHash := c.(map[common.Hash]lendingstate.LendingItemHistoryItem)
lendingItemHistory, _ := cacheAtTxHash[lendingstate.GetLendingItemHistoryKey(item.LendingToken, item.CollateralToken, item.Hash)] lendingItemHistory := cacheAtTxHash[lendingstate.GetLendingItemHistoryKey(item.LendingToken, item.CollateralToken, item.Hash)]
if (lendingItemHistory == lendingstate.LendingItemHistoryItem{}) { if (lendingItemHistory == lendingstate.LendingItemHistoryItem{}) {
log.Debug("XDCxlending reorg: remove item due to empty lendingItemHistory", "item", lendingstate.ToJSON(item)) log.Debug("XDCxlending reorg: remove item due to empty lendingItemHistory", "item", lendingstate.ToJSON(item))
if err := db.DeleteObject(item.Hash, &lendingstate.LendingItem{}); err != nil { if err := db.DeleteObject(item.Hash, &lendingstate.LendingItem{}); err != nil {
@ -797,7 +797,7 @@ func (l *Lending) RollbackLendingData(txhash common.Hash) error {
continue continue
} }
cacheAtTxHash := c.(map[common.Hash]lendingstate.LendingTradeHistoryItem) cacheAtTxHash := c.(map[common.Hash]lendingstate.LendingTradeHistoryItem)
lendingTradeHistoryItem, _ := cacheAtTxHash[trade.Hash] lendingTradeHistoryItem := cacheAtTxHash[trade.Hash]
if (lendingTradeHistoryItem == lendingstate.LendingTradeHistoryItem{}) { if (lendingTradeHistoryItem == lendingstate.LendingTradeHistoryItem{}) {
log.Debug("XDCxlending reorg: remove trade due to empty LendingTradeHistory", "trade", lendingstate.ToJSON(trade)) log.Debug("XDCxlending reorg: remove trade due to empty LendingTradeHistory", "trade", lendingstate.ToJSON(trade))
if err := db.DeleteObject(trade.Hash, &lendingstate.LendingTrade{}); err != nil { if err := db.DeleteObject(trade.Hash, &lendingstate.LendingTrade{}); err != nil {