Delete connstr in threadgdbm global channel map on close

2024-10-17 12:32:31 +03:00 · 2024-10-17 12:32:31 +03:00 · 54cc33c819
commit 54cc33c819
parent a51f739d06
1 changed files with 1 additions and 0 deletions
--- a/internal/storage/gdbm.go
+++ b/internal/storage/gdbm.go
@ -109,6 +109,7 @@ func(tdb *ThreadGdbmDb) Get(ctx context.Context, key []byte) ([]byte, error) {
 func(tdb *ThreadGdbmDb) Close() error {
 	tdb.reserve()
 	close(dbC[tdb.connStr])
+	delete(dbC, tdb.connStr)
 	err := tdb.db.Close()
 	tdb.db = nil
 	return err