Skip to content

Commit

Permalink
fix(migration): fix unexpected defer unlock
Browse files Browse the repository at this point in the history
  • Loading branch information
d4x1 committed Jun 19, 2024
1 parent a7b1513 commit e2f8891
Showing 1 changed file with 3 additions and 1 deletion.
4 changes: 3 additions & 1 deletion backend/server/services/init.go
Original file line number Diff line number Diff line change
Expand Up @@ -123,11 +123,12 @@ var statusLock sync.Mutex
// This might be called concurrently across multiple API requests
func ExecuteMigration() errors.Error {
statusLock.Lock()
defer statusLock.Unlock()
if serviceStatus == SERVICE_STATUS_MIGRATING {
statusLock.Unlock()
return errors.BadInput.New("already migrating")
}
if serviceStatus == SERVICE_STATUS_READY {
statusLock.Unlock()
return nil
}
serviceStatus = SERVICE_STATUS_MIGRATING
Expand All @@ -146,6 +147,7 @@ func ExecuteMigration() errors.Error {
pipelineServiceInit()
statusLock.Lock()
serviceStatus = SERVICE_STATUS_READY
statusLock.Unlock()
return nil
}

Expand Down

0 comments on commit e2f8891

Please sign in to comment.