cerc-io/lotus
10
0
Fork 0
Code Issues Pull Requests Packages Projects Releases 27 Wiki Activity

Disable exclusion of miner-associated addresses

Browse Source
This commit is contained in:
Peter Rabbitson 2020-09-27 20:44:50 +02:00
parent fb3bcc4ce5
commit e4c1f090af
1 changed files with 22 additions and 18 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

40
cmd/lotus-shed/dealtracker.go
View File

@ -26,6 +26,8 @@ var resolvedWallets = new(sync.Map)
func init() { func init() {
for _, a := range []string{ for _, a := range []string{
"t0100", // client for genesis miner "t0100", // client for genesis miner
"t0101", // client for genesis miner
"t0102", // client for genesis miner
"t0112", // client for genesis miner "t0112", // client for genesis miner
"t0113", // client for genesis miner "t0113", // client for genesis miner
"t0114", // client for genesis miner "t0114", // client for genesis miner
@ -201,25 +203,27 @@ func (dss *dealStatsServer) filteredDealList() (int64, map[string]dealInfo) {
return 0, nil return 0, nil
} }
// Exclude any address associated with a miner // Disabled as per @pooja's request
miners, err := dss.api.StateListMiners(ctx, head.Key()) //
if err != nil { // // Exclude any address associated with a miner
log.Warnf("failed to get miner list: %s", err) // miners, err := dss.api.StateListMiners(ctx, head.Key())
return 0, nil // if err != nil {
} // log.Warnf("failed to get miner list: %s", err)
for _, m := range miners { // return 0, nil
info, err := dss.api.StateMinerInfo(ctx, m, head.Key()) // }
if err != nil { // for _, m := range miners {
log.Warnf("failed to get info for known miner '%s': %s", m, err) // info, err := dss.api.StateMinerInfo(ctx, m, head.Key())
continue // if err != nil {
} // log.Warnf("failed to get info for known miner '%s': %s", m, err)
// continue
// }
knownFiltered.Store(info.Owner, true) // knownFiltered.Store(info.Owner, true)
knownFiltered.Store(info.Worker, true) // knownFiltered.Store(info.Worker, true)
for _, a := range info.ControlAddresses { // for _, a := range info.ControlAddresses {
knownFiltered.Store(a, true) // knownFiltered.Store(a, true)
} // }
} // }
deals, err := dss.api.StateMarketDeals(ctx, head.Key()) deals, err := dss.api.StateMarketDeals(ctx, head.Key())
if err != nil { if err != nil {