INNER CODE UNIT · Go

ticker

lucagrulla/cw · coordinator.go:24

	ticker := time.NewTicker(250 * time.Millisecond)
	go func() {
		for range ticker.C {
			if f.targets == nil {
				f.log.Println("coordinator: ring buffer is empty, exiting scheduler.")
				return
			}
			f.Lock()
			x := f.targets.Value.(chan<- time.Time)
			x <- time.Now()
			f.targets = f.targets.Next()
			f.Unlock()
		}
	}()
}

func (f *tailCoordinator) remove(c chan<- time.Time) {
	f.RLock()

View source record →