|
@@ -199,7 +199,6 @@ func (s *Session) dial(host *HostInfo, cfg *ConnConfig, errorHandler ConnErrorHa
|
|
|
r: bufio.NewReader(conn),
|
|
r: bufio.NewReader(conn),
|
|
|
cfg: cfg,
|
|
cfg: cfg,
|
|
|
calls: make(map[int]*callReq),
|
|
calls: make(map[int]*callReq),
|
|
|
- timeout: cfg.Timeout,
|
|
|
|
|
version: uint8(cfg.ProtoVersion),
|
|
version: uint8(cfg.ProtoVersion),
|
|
|
addr: conn.RemoteAddr().String(),
|
|
addr: conn.RemoteAddr().String(),
|
|
|
errorHandler: errorHandler,
|
|
errorHandler: errorHandler,
|
|
@@ -232,11 +231,14 @@ func (s *Session) dial(host *HostInfo, cfg *ConnConfig, errorHandler ConnErrorHa
|
|
|
conn: c,
|
|
conn: c,
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
|
|
+ c.timeout = cfg.ConnectTimeout
|
|
|
if err := startup.setupConn(ctx); err != nil {
|
|
if err := startup.setupConn(ctx); err != nil {
|
|
|
c.close()
|
|
c.close()
|
|
|
return nil, err
|
|
return nil, err
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
|
|
+ c.timeout = cfg.Timeout
|
|
|
|
|
+
|
|
|
// dont coalesce startup frames
|
|
// dont coalesce startup frames
|
|
|
if s.cfg.WriteCoalesceWaitTime > 0 {
|
|
if s.cfg.WriteCoalesceWaitTime > 0 {
|
|
|
c.w = newWriteCoalescer(c.w, s.cfg.WriteCoalesceWaitTime, c.quit)
|
|
c.w = newWriteCoalescer(c.w, s.cfg.WriteCoalesceWaitTime, c.quit)
|