cascade/ipfs-cluster
5
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

State: Log pin listing progress every 500k pins.

Browse Source
This commit is contained in:
Hector Sanjuan 2021-12-17 11:35:21 +01:00
parent 3e32a40abf
commit 9b61a007e9
1 changed files with 8 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
state/dsstate/datastore.go
View File

@ -140,6 +140,7 @@ func (st *State) List(ctx context.Context) ([]*api.Pin, error) {
var pins []*api.Pin var pins []*api.Pin
total := 0
for r := range results.Next() { for r := range results.Next() {
if r.Error != nil { if r.Error != nil {
logger.Errorf("error in query result: %s", r.Error) logger.Errorf("error in query result: %s", r.Error)
@ -158,8 +159,15 @@ func (st *State) List(ctx context.Context) ([]*api.Pin, error) {
continue continue
} }
if total > 0 && total%500000 == 0 {
logger.Infof("Full pinset listing in progress: %d pins so far", total)
}
total++
pins = append(pins, p) pins = append(pins, p)
} }
if total >= 500000 {
logger.Infof("Full pinset listing finished: %d pins", total)
}
return pins, nil return pins, nil
} }