Skip to content

Commit dff412a

Browse files
committed
fix(pkg/dabase): return error when attempting to access deleted database
Signed-off-by: Stefano Scafiti <[email protected]>
1 parent d47d3ef commit dff412a

File tree

1 file changed

+8
-3
lines changed

1 file changed

+8
-3
lines changed

pkg/database/db_manager.go

Lines changed: 8 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -266,10 +266,15 @@ func (m *DBManager) Has(name string) bool {
266266
}
267267

268268
func (m *DBManager) HasIndex(idx int) bool {
269-
m.dbMutex.RLock()
270-
defer m.dbMutex.RUnlock()
269+
db, exists := m.getDB(idx)
270+
if !exists {
271+
return false
272+
}
273+
274+
db.mtx.Lock()
275+
defer db.mtx.Unlock()
271276

272-
return idx >= 0 && idx < len(m.databases)
277+
return !db.deleted
273278
}
274279

275280
func (m *DBManager) GetIndexByName(name string) int {

0 commit comments

Comments
 (0)