removed go routine for dial
This commit is contained in:
@@ -247,7 +247,7 @@ func (rc *RecConn) Dial(urlStr string, reqHeader http.Header) {
|
|||||||
rc.setDefaultDialer()
|
rc.setDefaultDialer()
|
||||||
|
|
||||||
// Connect
|
// Connect
|
||||||
go rc.connect()
|
rc.connect()
|
||||||
|
|
||||||
// wait on first attempt
|
// wait on first attempt
|
||||||
time.Sleep(rc.HandshakeTimeout)
|
time.Sleep(rc.HandshakeTimeout)
|
||||||
@@ -280,9 +280,7 @@ func (rc *RecConn) connect() {
|
|||||||
|
|
||||||
for {
|
for {
|
||||||
nextItvl := b.Duration()
|
nextItvl := b.Duration()
|
||||||
rc.mu.Lock()
|
|
||||||
wsConn, httpResp, err := rc.dialer.Dial(rc.url, rc.reqHeader)
|
wsConn, httpResp, err := rc.dialer.Dial(rc.url, rc.reqHeader)
|
||||||
rc.mu.Unlock()
|
|
||||||
|
|
||||||
rc.mu.Lock()
|
rc.mu.Lock()
|
||||||
rc.Conn = wsConn
|
rc.Conn = wsConn
|
||||||
|
|||||||
Reference in New Issue
Block a user