Skip to content

Commit 7bd246e

Browse files
committed
staticaddr: deposit recover within a wait group
1 parent a3fb0a3 commit 7bd246e

File tree

1 file changed

+9
-1
lines changed

1 file changed

+9
-1
lines changed

staticaddr/deposit/manager.go

Lines changed: 9 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -177,7 +177,10 @@ func (m *Manager) recoverDeposits(ctx context.Context) error {
177177
return err
178178
}
179179

180-
var wg sync.WaitGroup
180+
var (
181+
wg sync.WaitGroup
182+
numRecoveredDeposits int
183+
)
181184
for i, d := range deposits {
182185
m.deposits[d.OutPoint] = deposits[i]
183186

@@ -210,9 +213,14 @@ func (m *Manager) recoverDeposits(ctx context.Context) error {
210213
m.mu.Lock()
211214
m.activeDeposits[d.OutPoint] = fsm
212215
m.mu.Unlock()
216+
217+
numRecoveredDeposits++
213218
}
214219
wg.Wait()
215220

221+
log.Infof("Recovered %d deposits from the database",
222+
numRecoveredDeposits)
223+
216224
return nil
217225
}
218226

0 commit comments

Comments
 (0)