Create unbuffered Tumble entry point for LogDog.

tumble/process.go

 // Copyright 2015 The LUCI Authors. All rights reserved.
 // Use of this source code is governed under the Apache License, Version 2.0
 // that can be found in the LICENSE file.
 
 package tumble
 
 import (
         "bytes"
         "fmt"
         "math"
@@ skipping 339 matching lines @@
                 deletedMuts = 0
                 processedMuts = 0
 
                 iterMuts := muts
                 iterMutKeys := mutKeys
 
                 for i := 0; i < len(iterMuts); i++ {
                         m := iterMuts[i]
 
                         logging.Fields{"m": m}.Infof(c, "running RollForward")
-                        shards, newMuts, newMutKeys, err := enterTransactionInternal(c, cfg, overrideRoot{m, root}, uint64(i))
+                        shards, newMuts, newMutKeys, err := enterTransactionMutation(c, cfg, overrideRoot{m, root}, uint64(i))
                         if err != nil {
                                 l.Errorf("Executing decoded gob(%T) failed: %q: %+v", m, err, m)
                                 continue
                         }
                         processedMuts++
                         for j, nm := range newMuts {
                                 if nm.Root(c).HasAncestor(root) {
                                         runNow := !cfg.DelayedMutations
                                         if !runNow {
                                                 dm, isDelayedMutation := nm.(DelayedMutation)
@@ skipping 41 matching lines @@
                 for _, k := range toDel {
                         banSet.Add(k.Encode())
                 }
                 if err := ds.Delete(c, toDel); err != nil {
                         l.Warningf("error deleting finished mutations: %s", err)
                 }
         }
 
         return nil
 }