(d time.Duration)
| 316 | } |
| 317 | |
| 318 | func (t *DBTask) OnIterationComplete(d time.Duration) { |
| 319 | t.mu.Lock() |
| 320 | defer t.mu.Unlock() |
| 321 | |
| 322 | if t.Task != nil { |
| 323 | t.Task.PublicState.ExecutedDuration += d |
| 324 | } |
| 325 | } |
| 326 | |
| 327 | func (t *DBTask) ResumeTime() int64 { |
| 328 | t.mu.Lock() |