Return if duplicate connect

2024-09-22 03:09:53 +01:00 · 2024-09-22 03:09:53 +01:00 · a455cfb854
commit a455cfb854
parent 1cc2f58ab3
1 changed files with 1 additions and 0 deletions
--- a/internal/storage/gdbm.go
+++ b/internal/storage/gdbm.go
@ -30,6 +30,7 @@ func(tdb *ThreadGdbmDb) Connect(ctx context.Context, connStr string) error {
 	_, ok = dbC[connStr]
 	if ok {
 		logg.WarnCtxf(ctx, "already registered thread gdbm, skipping", "connStr", connStr)
+		return nil
 	}
 	gdb := gdbmdb.NewGdbmDb()
 	err := gdb.Connect(ctx, connStr)