Skip to content

Commit d0b4b43

Browse files
committed
guard dials
1 parent f1a63a4 commit d0b4b43

File tree

1 file changed

+4
-1
lines changed

1 file changed

+4
-1
lines changed

connector.go

+4-1
Original file line numberDiff line numberDiff line change
@@ -37,7 +37,10 @@ func (c Connector) Connect(ctx context.Context) (driver.Conn, error) {
3737

3838
// Connect to Server
3939
// TODO: needs RegisterDialContext
40-
if dial, ok := dials[mc.cfg.Net]; ok {
40+
dialsLock.RLock()
41+
dial, ok := dials[mc.cfg.Net]
42+
dialsLock.RUnlock()
43+
if ok {
4144
mc.netConn, err = dial(mc.cfg.Addr)
4245
} else {
4346
nd := net.Dialer{Timeout: mc.cfg.Timeout}

0 commit comments

Comments
 (0)