Rooba
/
perkeep
mirror of https://github.com/perkeep/perkeep.git
1
1
Fork 0
Code Issues Packages Projects Releases Wiki Activity

sync: add forgotten channel close. 

Change-Id: Ie6d14b0bad1229fc775dc9a0afda349ee163cbda
This commit is contained in:
Brad Fitzpatrick 2013-11-23 11:20:08 -08:00
parent 62fbbb61a0
commit 3ccdb025c0
1 changed files with 1 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
pkg/server/sync.go
View File

@ -285,6 +285,7 @@ func blobserverEnumerator(src blobserver.BlobEnumerator) func(chan<- blob.SizedR
}
func (sh *SyncHandler) enumerateQueuedBlobs(dst chan<- blob.SizedRef, intr <-chan struct{}) error {
defer close(dst)
it := sh.queue.Find("")
for it.Next() {
br, ok := blob.Parse(it.Key())