diff --git a/pkg/blobserver/s3/slurp b/pkg/blobserver/s3/slurp deleted file mode 100644 index c83c1e74c..000000000 --- a/pkg/blobserver/s3/slurp +++ /dev/null @@ -1,35 +0,0 @@ -func (sto *s3Storage) slurpAll() { - var mu sync.Mutex - var nblobs, nbytes int64 - - errc := make(chan error) - for i := 0; i < 16; i++ { - pfx := fmt.Sprintf("sha1-%x", i) - log.Printf("Doing prefix %q", pfx) - ctx := context.New() - go func() { - err := blobserver.EnumerateAllFrom(ctx, sto, pfx, func(sb blob.SizedRef) error { - if !strings.HasPrefix(sb.Ref.String(), pfx) { - log.Printf("Ref %q doesn't have prefix %q", sb.Ref.String(), pfx) - ctx.Cancel() - return context.ErrCanceled - } - mu.Lock() - nblobs++ - nbytes += int64(sb.Size) - mu.Unlock() - return nil - }) - log.Printf("Enum prefix %q", pfx) - errc <- err - }() - } - var lastErr error - for i := 0; i < 16; i++ { - if err := <-errc; err != nil { - log.Printf("enumerate error: %v", err) - lastErr = err - } - } - log.Printf("Done enumerating all: %d blobs, %d bytes; err=%v", nblobs, nbytes, lastErr) -}