resp close

Author: reallovelei

examples/circuitbreaker/consumer/main.go

@@ -75,8 +75,11 @@ func (svr *PolarisConsumer) runWebServer() {
 
 			start := time.Now()
 			resp, err := http.Get(fmt.Sprintf("http://%s:%d/echo", instance.GetHost(), instance.GetPort()))
+			if resp != nil {
+				defer resp.Body.Close()
+			}
+
 			if err != nil || resp.StatusCode != http.StatusOK {
-				resp.Body.Close()
 				delay := time.Now().Sub(start)
 				callRet := &polaris.ServiceCallResult{}
 				callRet.CalledInstance = instance
@@ -98,8 +101,6 @@ func (svr *PolarisConsumer) runWebServer() {
 				continue
 			}
 
-			defer resp.Body.Close()
-
 			data, err := ioutil.ReadAll(resp.Body)
 			if err != nil {
 				log.Printf("[error] read resp from %s:%d fail : %s", instance.GetHost(), instance.GetPort(), err)