Skip to content
Snippets Groups Projects
Verified Commit 527975cd authored by Volker Schukai's avatar Volker Schukai :alien:
Browse files

fix: race

parent d7b8d8e5
No related branches found
No related tags found
No related merge requests found
......@@ -19,6 +19,8 @@ func TestWriteToDB3(t *testing.T) {
t.Fatalf("a error occurred while opening the database: %v", err)
}
db.Logger = db.Logger.LogMode(4)
manager := NewManager()
manager.SetDB(db)
err = manager.AddWorker(NewLocalWorker(1))
......@@ -35,6 +37,15 @@ func TestWriteToDB3(t *testing.T) {
time.Sleep(1 * time.Second)
// test is job in database
var tmpJob1 JobPersistence
r := db.First(&tmpJob1, "id = ?", "job2")
assert.Nil(t, r.Error)
assert.Equal(t, JobID("job2"), tmpJob1.ID)
time.Sleep(1 * time.Second)
err = manager.DeleteJob(job.GetID())
assert.Nil(t, err)
......
......@@ -7,6 +7,7 @@ import (
"gorm.io/driver/sqlite"
"gorm.io/gorm"
"testing"
"time"
)
func TestWriteToDB5(t *testing.T) {
......@@ -35,6 +36,8 @@ func TestWriteToDB5(t *testing.T) {
sameIDJob := NewJob[CounterResult]("jobSameID", runner)
time.Sleep(500 * time.Millisecond)
// Trying to save a job with the same ID should do nothing
mgr.mu.Lock()
mgr.jobSyncer.AddJob(sameIDJob)
......
......@@ -389,7 +389,6 @@ func (m *Manager) RemoveWorker(worker Worker) error {
// Start starts the manager
func (m *Manager) Start() error {
//var err error
m.mu.Lock()
defer m.mu.Unlock()
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment