@@ -103,7 +103,7 @@ func (d *Dialer) GetDialFunc(useEnv bool) (dialFunc fasthttp.DialFunc, err error
103103 case "socks5" , "socks5h" :
104104 proxyDialer , err = proxy .FromURL (proxyURL , d )
105105 if err != nil {
106- return
106+ return nil , err
107107 }
108108 case "http" :
109109 proxyAddr , auth := addrAndAuth (proxyURL )
@@ -128,7 +128,7 @@ func (d *Dialer) GetDialFunc(useEnv bool) (dialFunc fasthttp.DialFunc, err error
128128 reqURL := & url.URL {Host : addr , Scheme : scheme }
129129 proxyURL , err = proxyFunc (reqURL )
130130 if err != nil {
131- return
131+ return nil , err
132132 }
133133 if proxyURL == nil {
134134 // dial directly
@@ -138,7 +138,7 @@ func (d *Dialer) GetDialFunc(useEnv bool) (dialFunc fasthttp.DialFunc, err error
138138 case "socks5" , "socks5h" :
139139 proxyDialer , err = proxy .FromURL (proxyURL , d )
140140 if err != nil {
141- return
141+ return nil , err
142142 }
143143 case "http" :
144144 proxyAddr , auth := addrAndAuth (proxyURL )
@@ -167,7 +167,7 @@ func (d *Dialer) Dial(network, addr string) (conn net.Conn, err error) {
167167 return d .TCPDialer .DialDualStack (addr )
168168 }
169169 err = errors .New ("dont support the network: " + network )
170- return
170+ return nil , err
171171}
172172
173173func (d * Dialer ) connectTimeout () time.Duration {
@@ -193,7 +193,7 @@ func (d DialerFunc) Dial(network, addr string) (net.Conn, error) {
193193func httpProxyDial (dialer proxy.Dialer , network , addr , proxyAddr , auth string ) (conn net.Conn , err error ) {
194194 conn , err = dialer .Dial (network , proxyAddr )
195195 if err != nil {
196- return
196+ return nil , err
197197 }
198198 var connectTimeout time.Duration
199199 hp , ok := dialer .(httpProxyDialer )
@@ -218,21 +218,21 @@ func httpProxyDial(dialer proxy.Dialer, network, addr, proxyAddr, auth string) (
218218 _ , err = conn .Write ([]byte (req ))
219219 if err != nil {
220220 _ = conn .Close ()
221- return
221+ return nil , err
222222 }
223223 res := fasthttp .AcquireResponse ()
224224 defer fasthttp .ReleaseResponse (res )
225225 res .SkipBody = true
226226 if err = res .Read (bufio .NewReaderSize (conn , 1024 )); err != nil {
227227 _ = conn .Close ()
228- return
228+ return nil , err
229229 }
230230 if res .Header .StatusCode () != 200 {
231231 _ = conn .Close ()
232232 err = fmt .Errorf ("could not connect to proxyAddr: %s status code: %d" , proxyAddr , res .Header .StatusCode ())
233- return
233+ return nil , err
234234 }
235- return
235+ return conn , err
236236}
237237
238238// Cache authentication information for HTTP proxies.
@@ -244,7 +244,7 @@ type proxyInfo struct {
244244func addrAndAuth (pu * url.URL ) (proxyAddr , auth string ) {
245245 if pu .User == nil {
246246 proxyAddr = pu .Host + pu .Path
247- return
247+ return proxyAddr , auth
248248 }
249249 var info * proxyInfo
250250 v , ok := authCache .Load (pu )
0 commit comments