()
| 325 | } |
| 326 | |
| 327 | func (t *DBTask) ResumeTime() int64 { |
| 328 | t.mu.Lock() |
| 329 | defer t.mu.Unlock() |
| 330 | |
| 331 | if t.Task != nil { |
| 332 | return t.Task.PublicState.ResumeTime |
| 333 | } |
| 334 | return 0 |
| 335 | } |
| 336 | |
| 337 | func (t *DBTask) OnSuspend(time int64) { |
| 338 | t.mu.Lock() |