Separate sequencing and integration for MySQL storage

transparency-dev · Oct 25, 2024 · c933ae1 · c933ae1
1 parent 0c3daf4
commit c933ae1
Show file tree

Hide file tree

Showing 4 changed files with 281 additions and 83 deletions.
diff --git a/integration/integration_test.go b/integration/integration_test.go
@@ -146,15 +146,21 @@ func TestLiveLogIntegration(t *testing.T) {
 	}
 
 	// Step 3 - Validate checkpoint size increment.
-	checkpoint, _, _, err = client.FetchCheckpoint(ctx, logRead, noteVerifier, noteVerifier.Name())
-	if err != nil {
-		t.Errorf("client.FetchCheckpoint: %v", err)
-	}
-	if checkpoint == nil {
-		t.Fatal("checkpoint not found")
+	var gotIncrease uint64
+	for gotIncrease != uint64(*testEntrySize) {
+		checkpoint, _, _, err = client.FetchCheckpoint(ctx, logRead, noteVerifier, noteVerifier.Name())
+		if err != nil {
+			t.Errorf("client.FetchCheckpoint: %v", err)
+		}
+		if checkpoint == nil {
+			t.Fatal("checkpoint not found")
+		}
+		t.Logf("checkpoint final size: %d", checkpoint.Size)
+		gotIncrease = checkpoint.Size - checkpointInitSize
+
+		time.Sleep(100 * time.Millisecond)
 	}
-	t.Logf("checkpoint final size: %d", checkpoint.Size)
-	gotIncrease := checkpoint.Size - checkpointInitSize
+
 	if gotIncrease != uint64(*testEntrySize) {
 		t.Errorf("checkpoint size increase got: %d, want: %d", gotIncrease, *testEntrySize)
 	}