mirror/dolt
1
0
Fork 0
mirror of https://github.com/dolthub/dolt.git synced 2026-05-07 19:30:22 -05:00
Code Issues Packages Projects Releases 161 Wiki Activity

go: sqle/binlogreplication: Add some waits for more reliable observations of IO_error results.

Browse Source
This commit is contained in:
Aaron Son
2025-02-04 11:21:40 -08:00
parent b4b6d7110a
commit 6d9555093d
1 changed files with 5 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
go/libraries/doltcore/sqle/binlogreplication/binlog_primary_test.go
+5 -2
View File
@@ -53,6 +53,7 @@ func TestBinlogPrimary_BinlogNotEnabled(t *testing.T) {
h.requirePrimaryResults("SHOW BINARY LOGS", [][]any{})
h.startReplicationAndCreateTestDb(h.doltPort)
time.Sleep(1 * time.Second)
status := h.queryReplicaStatus()
require.Equal(t, "13120", status["Last_IO_Errno"])
require.Contains(t, status["Last_IO_Error"],
@@ -71,7 +72,7 @@ func TestBinlogPrimary_GtidModeNotEnabled(t *testing.T) {
h.requirePrimaryResults("SHOW BINARY LOGS", [][]any{{"binlog-main.000001", "151", "No"}})
h.startReplication(h.doltPort)
time.Sleep(500 * time.Millisecond)
time.Sleep(1 * time.Second)
status := h.queryReplicaStatus()
require.Equal(t, "13117", status["Last_IO_Errno"])
require.Contains(t, status["Last_IO_Error"],
@@ -90,7 +91,7 @@ func TestBinlogPrimary_EnforceGtidConsistencyNotEnabled(t *testing.T) {
h.requirePrimaryResults("SHOW BINARY LOGS", [][]any{{"binlog-main.000001", "151", "No"}})
h.startReplication(h.doltPort)
time.Sleep(500 * time.Millisecond)
time.Sleep(1 * time.Second)
status := h.queryReplicaStatus()
require.Equal(t, "13114", status["Last_IO_Errno"])
require.Contains(t, status["Last_IO_Error"],
@@ -257,6 +258,7 @@ func TestBinlogPrimary_AutoPurging(t *testing.T) {
// Verify the replica reports an error about the GTIDs not being available
h.startReplicationAndCreateTestDb(h.doltPort)
time.Sleep(1 * time.Second)
status := h.queryReplicaStatus()
require.Equal(t, "13114", status["Last_IO_Errno"])
require.Contains(t, status["Last_IO_Error"],
@@ -394,6 +396,7 @@ func TestBinlogPrimary_Heartbeats(t *testing.T) {
[][]any{{fmt.Sprintf("%d", maxInsertValue)}})
// Make sure no errors have occurred
time.Sleep(1 * time.Second)
status := h.queryReplicaStatus()
require.Equal(t, "", status["Last_SQL_Error"])
require.Equal(t, "", status["Last_IO_Error"])