()
| 638 | } |
| 639 | |
| 640 | func (mctx *MigrationContext) MarkPointOfInterest() int64 { |
| 641 | mctx.pointOfInterestTimeMutex.Lock() |
| 642 | defer mctx.pointOfInterestTimeMutex.Unlock() |
| 643 | |
| 644 | mctx.pointOfInterestTime = time.Now() |
| 645 | return atomic.LoadInt64(&mctx.Iteration) |
| 646 | } |
| 647 | |
| 648 | func (mctx *MigrationContext) TimeSincePointOfInterest() time.Duration { |
| 649 | mctx.pointOfInterestTimeMutex.Lock() |
no outgoing calls
no test coverage detected