mirror/dolt
1
0
Fork 0
mirror of https://github.com/dolthub/dolt.git synced 2025-12-30 16:12:39 -06:00
Code Issues Packages Projects Releases 114 Wiki Activity

integration-tests/go-sql-server-driver: Attempt to SIGQUIT a hung call dolt_gc in CI.

Browse Source
This commit is contained in:
Aaron Son
2025-07-08 11:02:42 -07:00
parent d0f60bd0db
commit 22c07436ef
1 changed files with 24 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

28
integration-tests/go-sql-server-driver/auto_gc_test.go
View File

@@ -23,7 +23,10 @@ import (
"path/filepath"
"strconv"
"strings"
"sync"
"syscall"
"testing"
"time"
"github.com/stretchr/testify/assert"
"github.com/stretchr/testify/require"
@@ -45,6 +48,7 @@ func TestAutoGC(t *testing.T) {
name string
}{{true, "Archive"}, {false, "NoArchive"}} {
t.Run(sa.name, func(t *testing.T) {
t.Parallel()
t.Run("CommitEvery16", func(t *testing.T) {
t.Parallel()
var s AutoGCTest
@@ -80,9 +84,8 @@ func TestAutoGC(t *testing.T) {
s.EnableRemotesAPI = true
s.Archive = sa.archive
enabled_16, final_16 = runAutoGCTest(t, &s, numStatements, 2)
// XXX: Reenable these after tuning to be more reliable.
// assert.Contains(t, string(s.PrimaryServer.Output.Bytes()), "Successfully completed auto GC")
// assert.Contains(t, string(s.StandbyServer.Output.Bytes()), "Successfully completed auto GC")
assert.Contains(t, string(s.PrimaryServer.Output.Bytes()), "Successfully completed auto GC")
assert.Contains(t, string(s.StandbyServer.Output.Bytes()), "Successfully completed auto GC")
assert.NotContains(t, string(s.PrimaryServer.Output.Bytes()), "dangling references requested during GC")
assert.NotContains(t, string(s.StandbyServer.Output.Bytes()), "dangling references requested during GC")
})
@@ -389,7 +392,24 @@ func runAutoGCTest(t *testing.T, s *AutoGCTest, numStatements int, commitEvery i
require.NoError(t, err)
conn, err := s.PrimaryDB.Conn(ctx)
require.NoError(t, err)
_, err = conn.ExecContext(ctx, "call dolt_gc('--full')")
done := make(chan struct{})
var wg sync.WaitGroup
wg.Add(2)
go func() {
defer close(done)
defer wg.Done()
_, err = conn.ExecContext(ctx, "call dolt_gc('--full')")
}()
go func() {
defer wg.Done()
select {
case <-done:
case <-time.After(1*time.Minute):
s.PrimaryServer.Cmd.Process.Signal(syscall.SIGQUIT)
}
}()
wg.Wait()
require.NoError(t, err)
require.NoError(t, conn.Close())
after, err := GetRepoSize(s.PrimaryDir)