Method runLocal

internal/server/source_manager.go:178–214

(ctx context.Context)

}

func (s *sourceManager) runLocal(ctx context.Context) {
	if s.isPaused() {
		s.setStatus("PAUSED")
	} else {
		s.setStatus("IDLE")
	}

	for {
		select {
		case <-s.closed:
			return

		case <-s.snapshotRequests:
			if s.isPaused() {
				s.setStatus("PAUSED")

				continue
			}

			s.setStatus("PENDING")

			userLog(ctx).Debugw("snapshotting", "source", s.src)

			if err := s.server.runSnapshotTask(ctx, s.src, s.snapshotInternal); err != nil {
				userLog(ctx).Errorf("snapshot error: %v", err)

				s.backoffBeforeNextSnapshot()
			} else {
				s.refreshStatus(ctx)
			}

			s.server.refreshScheduler("snapshot finished")

			s.setStatus("IDLE")
		}
	}
}

func (s *sourceManager) backoffBeforeNextSnapshot() {
	if _, ok := s.getNextSnapshotTime(); !ok {