fix keepalive response
This commit is contained in:
@@ -485,8 +485,10 @@ func (rc *RecConn) connect() {
|
|||||||
rc.dialErr = err
|
rc.dialErr = err
|
||||||
rc.isConnected = err == nil
|
rc.isConnected = err == nil
|
||||||
rc.httpResp = httpResp
|
rc.httpResp = httpResp
|
||||||
rc.keepAliveResponse = new(keepAliveResponse)
|
if rc.keepAliveResponse == nil {
|
||||||
rc.keepAliveResponse.allowDataResponse = rc.AllowKeepAliveDataResponse
|
rc.keepAliveResponse = new(keepAliveResponse)
|
||||||
|
rc.keepAliveResponse.allowDataResponse = rc.AllowKeepAliveDataResponse
|
||||||
|
}
|
||||||
rc.mu.Unlock()
|
rc.mu.Unlock()
|
||||||
|
|
||||||
if err == nil {
|
if err == nil {
|
||||||
|
|||||||
Reference in New Issue
Block a user