.

wcfs/internal/zdata/δftail_test.go

@@ -240,30 +240,35 @@ func TestΔFtailRandom(t *testing.T) {
 		return vv[i:i+1]
 	}
 
-	for i := 0; i < n; i++ {
-		nδblkTab  := rng.Intn(10)	// XXX -> to maxBlk ?
-		nδdataTab := rng.Intn(len(vv))
-
-		δblkTab  := map[int64]string{}
-		δdataTab := setStr{}
-
-		blkv := rng.Perm(100)		// XXX = maxBlk ?
-		for j := 0; j < nδblkTab; j++ {
-			blk  := blkv[j]
-			zblk := randv()
-			δblkTab[int64(blk)] = zblk
-		}
-
-		vv_ := rng.Perm(len(vv))
-		for j := 0; j < nδdataTab; j++ {
-			k := vv_[j]
-			v := vv[k:k+1]
-			δdataTab.Add(v)
-		}
+	testq := make(chan ΔFTestEntry)
+	go func() {
+		defer close(testq)
+		for i := 0; i < n; i++ {
+			nδblkTab  := rng.Intn(10)	// XXX -> to maxBlk ?
+			nδdataTab := rng.Intn(len(vv))
+
+			δblkTab  := map[int64]string{}
+			δdataTab := setStr{}
+
+			blkv := rng.Perm(100)		// XXX = maxBlk ?
+			for j := 0; j < nδblkTab; j++ {
+				blk  := blkv[j]
+				zblk := randv()
+				δblkTab[int64(blk)] = zblk
+			}
 
+			vv_ := rng.Perm(len(vv))
+			for j := 0; j < nδdataTab; j++ {
+				k := vv_[j]
+				v := vv[k:k+1]
+				δdataTab.Add(v)
+			}
 
+			testq <- ΔFTestEntry{δblkTab, δdataTab}
+		}
+	}()
 
-	}
+	testΔFtail(t, testq)
 }