From 14239a5c2352f7ec3e40ce8a0a4460ca8e67672e Mon Sep 17 00:00:00 2001
From: Brad Fitzpatrick <brad@danga.com>
Date: Thu, 7 Feb 2013 21:02:42 -0800
Subject: [PATCH] index: cap reindex parallelism

Change-Id: Iaf8a54a547e7d74f9b3702901180b2253aef58aa
---
 pkg/index/receive.go | 8 ++++++++
 1 file changed, 8 insertions(+)

diff --git a/pkg/index/receive.go b/pkg/index/receive.go
index faf24b255..ed92c630c 100644
--- a/pkg/index/receive.go
+++ b/pkg/index/receive.go
@@ -29,6 +29,7 @@ import (
 	"io/ioutil"
 	"log"
 	"strings"
+	"sync"
 
 	"camlistore.org/pkg/blobref"
 	"camlistore.org/pkg/blobserver"
@@ -42,7 +43,14 @@ func (ix *Index) GetBlobHub() blobserver.BlobHub {
 	return ix.SimpleBlobHubPartitionMap.GetBlobHub()
 }
 
+var reindexMu sync.Mutex
+
 func (ix *Index) reindex(br *blobref.BlobRef) {
+	// TODO: cap how many of these can be going at once, probably more than 1,
+	// and be more efficient than just blocking goroutines. For now, this:
+	reindexMu.Lock()
+	defer reindexMu.Unlock()
+
 	bs := ix.BlobSource
 	if bs == nil {
 		log.Printf("index: can't re-index %v: no BlobSource", br)