Adaptive sync draft

Signed-off-by: Marek Siarkowicz <siarkowicz@google.com>

server/storage/mvcc/watchable_store.go

@@ -220,24 +220,8 @@ func (s *watchableStore) syncWatchersLoop() {
 	defer delayTicker.Stop()
 
 	for {
-		s.mu.RLock()
-		st := time.Now()
-		lastUnsyncedWatchers := s.unsynced.size()
-		s.mu.RUnlock()
-
-		unsyncedWatchers := 0
-		if lastUnsyncedWatchers > 0 {
-			unsyncedWatchers = s.syncWatchers()
-		}
-		syncDuration := time.Since(st)
-
+		s.syncWatchers()
 		delayTicker.Reset(waitDuration)
-		// more work pending?
-		if unsyncedWatchers != 0 && lastUnsyncedWatchers > unsyncedWatchers {
-			// be fair to other store operations by yielding time taken
-			delayTicker.Reset(syncDuration)
-		}
-
 		select {
 		case <-delayTicker.C:
 		case <-s.stopc: