Delete connstr in threadgdbm global channel map on close

This commit is contained in:
Carlosokumu 2024-10-07 23:33:09 +03:00
parent 5de82fd08a
commit e1f3ab78f1
Signed by: carlos
GPG Key ID: 7BD6BC8160A5C953

View File

@ -109,6 +109,7 @@ func(tdb *ThreadGdbmDb) Get(ctx context.Context, key []byte) ([]byte, error) {
func(tdb *ThreadGdbmDb) Close() error { func(tdb *ThreadGdbmDb) Close() error {
tdb.reserve() tdb.reserve()
close(dbC[tdb.connStr]) close(dbC[tdb.connStr])
delete(dbC, tdb.connStr)
err := tdb.db.Close() err := tdb.db.Close()
tdb.db = nil tdb.db = nil
return err return err