debug

swarm/network/stream/syncer_test.go

@@ -107,10 +107,15 @@ func testSyncBetweenNodes(t *testing.T, nodes, conns, chunkCount int, skipCheck
 		dbs[i] = storage.NewDBAPI(sim.Stores[i].(*storage.LocalStore))
 	}
 	totalHashes := 0
-	for i := 1; i < nodes; i++ {
+	hashCounts := make([]int, nodes)
+	for i := nodes - 1; i >= 0; i-- {
+		if i < nodes-1 {
+			hashCounts[i] = hashCounts[i+1]
+		}
 		dbs[i].Iterator(0, math.MaxUint64, po, func(key storage.Key, index uint64) bool {
 			hashes[i] = append(hashes[i], key)
 			totalHashes++
+			hashCounts[i]++
 			return true
 		})
 	}
@@ -160,29 +165,34 @@ func testSyncBetweenNodes(t *testing.T, nodes, conns, chunkCount int, skipCheck
 		default:
 		}
 
-		var found int
+		var pass bool
-		for i, n := range hashes {
+		var i int
-			for _, key := range n {
+		log.Error("staring dbs check")
-				chunk, err := dbs[0].Get(key)
+		for i = nodes - 1; i >= 0; i-- {
+			nodeHashCount := hashCounts[i]
+			nodeHashFound := 0
+			for j := i; j < nodes; j++ {
+				nodeHashes := hashes[j]
+				for _, key := range nodeHashes {
+					chunk, err := dbs[i].Get(key)
 					if err == storage.ErrFetching {
 						<-chunk.ReqC
-					found++
+						nodeHashFound++
 					} else if err == nil {
-					found++
+						nodeHashFound++
+					} else {
+						log.Error("not found", "index", i, "origin", j, "key", key.Hex(), "err", err)
 					}
-
+				}
-				log.Error("staring dbs check", "key", key)
+			}
-				for j := i; j > 0; j-- {
+			log.Error("sync check", "node", sim.IDs[i], "index", i, "bin", po, "found", nodeHashFound, "total", nodeHashCount)
-					_, err := dbs[j].Get(key)
+			pass = nodeHashFound == nodeHashCount
-					if err != nil {
+			if !pass {
-						log.Error("get from node", "node", sim.IDs[j], "nodeID", j, "key", key.Hex(), "err", err)
 				break
 			}
 		}
-			}
+		// log.Error("sync check", "bin", po, "found", found, "total", totalHashes)
-		}
+		// pass := found == totalHashes
-		log.Error("sync check", "bin", po, "found", found, "total", totalHashes)
-		pass := found == totalHashes
 		if !pass {
 			return false, nil
 		}