From 513b594dbcbabe77444ca31e4ca9af734c8eed86 Mon Sep 17 00:00:00 2001
From: Brad Fitzpatrick <brad@danga.com>
Date: Sun, 22 May 2011 21:23:23 -0700
Subject: [PATCH] replica: notify blob hub

---
 lib/go/camli/blobserver/replica/replica.go | 1 +
 1 file changed, 1 insertion(+)

diff --git a/lib/go/camli/blobserver/replica/replica.go b/lib/go/camli/blobserver/replica/replica.go
index f4689bd05..5de609fc8 100644
--- a/lib/go/camli/blobserver/replica/replica.go
+++ b/lib/go/camli/blobserver/replica/replica.go
@@ -177,6 +177,7 @@ func (sto *replicaStorage) ReceiveBlob(b *blobref.BlobRef, source io.Reader) (xx
 		case res.err == nil && res.sb.Size == size:
 			nSuccess++
 			if nSuccess == sto.minWritesForSuccess {
+				sto.GetBlobHub().NotifyBlobReceived(b)
 				return res.sb, nil
 			}
 		case res.err == nil: