cascade/ipfs-cluster
5
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

diagnosing test fail

Browse Source 
License: MIT
Signed-off-by: Wyatt Daviau <wdaviau@cs.stanford.edu>
This commit is contained in:
Wyatt Daviau 2018-03-12 11:48:31 -04:00 committed by Hector Sanjuan
parent 6b8bcdfbc3
commit ada2ac4b50
1 changed files with 8 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
importer/import_test.go
View File

@ -57,11 +57,12 @@ func TestToChannel(t *testing.T) {
go func() { // listen on printChan so progress can be made
for {
_, ok := <-printChan
obj, ok := <-printChan
if !ok {
// channel closed, safe to exit
return
}
fmt.Printf("PrintObj -- Name: %s, Hash: %s \n", obj.Name, obj.Hash)
}
}()
@ -78,6 +79,12 @@ func TestToChannel(t *testing.T) {
check := make(map[string]struct{})
for obj := range outChan {
if len(obj.Data) > 500 {
fmt.Printf("Long OutObj -- Hash: %s \n", obj.Cid)
} else {
fmt.Printf("Short OutObj -- Hash: %s, Data: %s \n", obj.Cid, obj.Data)
}
cid := obj.Cid
if _, ok := check[cid]; ok {
t.Fatalf("Duplicate cid %s", cid)