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

fix: make sure we start the publish timer before recording the time

Browse Source 
Otherwise, our nice and deterministic test may keep repeatedly setting
the time to _right_ before the timer fires.
This commit is contained in:
Steven Allen 2021-08-24 11:05:51 -07:00
parent 16f8a35e76
commit add699d238
1 changed files with 5 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
markets/storageadapter/dealpublisher.go
View File

@ -228,11 +228,15 @@ func (p *DealPublisher) waitForMoreDeals() {
// Set a timeout to wait for more deals to arrive // Set a timeout to wait for more deals to arrive
log.Infof("waiting publish deals queue period of %s before publishing", p.publishPeriod) log.Infof("waiting publish deals queue period of %s before publishing", p.publishPeriod)
ctx, cancel := context.WithCancel(p.ctx) ctx, cancel := context.WithCancel(p.ctx)
// Create the timer _before_ taking the current time so publishPeriod+timeout is always >=
// the actual timer timeout.
timer := build.Clock.Timer(p.publishPeriod)
p.publishPeriodStart = build.Clock.Now() p.publishPeriodStart = build.Clock.Now()
p.cancelWaitForMoreDeals = cancel p.cancelWaitForMoreDeals = cancel
go func() { go func() {
timer := build.Clock.Timer(p.publishPeriod)
select { select {
case <-ctx.Done(): case <-ctx.Done():
timer.Stop() timer.Stop()