From ce9d58da8c0bcc2f85bfad81229dabd56557ca31 Mon Sep 17 00:00:00 2001 From: Jeff Ortel Date: Tue, 20 Aug 2024 15:24:18 -0700 Subject: [PATCH] checkpoint Signed-off-by: Jeff Ortel --- database/db_test.go | 12 +++++++----- 1 file changed, 7 insertions(+), 5 deletions(-) diff --git a/database/db_test.go b/database/db_test.go index b39992f4..09adf765 100644 --- a/database/db_test.go +++ b/database/db_test.go @@ -5,6 +5,7 @@ import ( "fmt" "os" "testing" + "time" "github.com/konveyor/tackle2-hub/model" "k8s.io/utils/env" @@ -13,8 +14,11 @@ import ( var N, _ = env.GetInt("TEST_CONCURRENT", 10) func TestConcurrent(t *testing.T) { - Settings.DB.Path = "/tmp/concurrent.db" - _ = os.Remove(Settings.DB.Path) + pid := os.Getpid() + Settings.DB.Path = fmt.Sprintf("/tmp/concurrent-%d.db", pid) + defer func() { + _ = os.Remove(Settings.DB.Path) + }() db, err := Open(true) if err != nil { panic(err) @@ -32,14 +36,12 @@ func TestConcurrent(t *testing.T) { panic(uErr) } for i := 0; i < 10; i++ { - fmt.Printf("(%.4d) BEGIN: %.4d/%.4d\n", id, n, i) tx := db.Begin() - fmt.Printf("(%.4d) FIRST: %.4d/%.4d\n", id, n, i) + time.Sleep(time.Millisecond * time.Duration(n)) uErr = tx.First(m).Error if uErr != nil { panic(uErr) } - fmt.Printf("(%.4d) SAVE: %.4d/%.4d\n", id, n, i) uErr = tx.Save(m).Error if uErr != nil { panic(uErr)