mirror of https://github.com/perkeep/perkeep.git
replica: notify blob hub
This commit is contained in:
parent
ccf33926c8
commit
513b594dbc
|
@ -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:
|
||||
|
|
Loading…
Reference in New Issue