extra logging for flake analysis

test/e2e/tests/chaos.go

@@ -210,17 +210,38 @@ func (t *StorageMigratorChaosTest) Test(done <-chan struct{}) {
 		if err != nil {
 			util.Failf("%v", err)
 		}
+		done := true
 		for _, ss := range l.Items {
 			if len(ss.Status.PersistedStorageVersionHashes) == 1 && ss.Status.PersistedStorageVersionHashes[0] == ss.Status.CurrentStorageVersionHash {
 				continue
 			}
-			util.Logf("resource %v has persisted hashes %v, and current hash %s",
+			done = false
+			util.Logf("%v resource %v has persisted hashes %v, and current hash %s",
+				ss.Status.LastHeartbeatTime,
 				ss.Spec.Resource,
 				ss.Status.PersistedStorageVersionHashes,
 				ss.Status.CurrentStorageVersionHash)
-			return false, nil
+			//return false, nil
 		}
-		return true, nil
+		listOfMigrations, err := t.migrationClient.MigrationV1alpha1().StorageVersionMigrations().List(metav1.ListOptions{})
+		if err != nil {
+			util.Logf("unable to get list of storage version migrations: %s", err)
+		} else {
+			for _, migration := range listOfMigrations.Items {
+				util.Logf("\t%-64s %-9s %s %s",
+					migration.Name, migration.Spec.Resource.Version,
+					func() string {
+						var s string
+						for _, condition := range migration.Status.Conditions {
+							s = fmt.Sprint("%s, %s: %s", s, condition.Type, condition.Status)
+						}
+						return s
+					}(),
+					migration.Spec.ContinueToken)
+			}
+		}
+		//return true, nil
+		return done, nil
 	})
 	if err != nil {
 		util.Failf("%v", err)