Add return to response error check condition.

BBVA · Dec 18, 2018 · 5b7dcb1 · 5b7dcb1
1 parent 10ae548
commit 5b7dcb1
Show file tree

Hide file tree

Showing 3 changed files with 5 additions and 1 deletion.
diff --git a/gossip/auditor/auditor.go b/gossip/auditor/auditor.go
@@ -161,9 +161,11 @@ func (t MembershipTask) Do() {
 }
 
 func (t MembershipTask) sendAlert(msg string) {
-	resp, err := http.Post(fmt.Sprintf("%s/alert", t.pubUrl), "application/json", bytes.NewBufferString(msg))
+	resp, err := http.Post(fmt.Sprintf("%s/alert", t.pubUrl), "application/json",
+		bytes.NewBufferString(msg))
 	if err != nil {
 		log.Infof("Error saving batch in alertStore: %v", err)
+		return
 	}
 	defer resp.Body.Close()
 	_, err = io.Copy(ioutil.Discard, resp.Body)

diff --git a/gossip/monitor/monitor.go b/gossip/monitor/monitor.go
@@ -137,6 +137,7 @@ func (m Monitor) sendAlert(msg string) {
 		bytes.NewBufferString(msg))
 	if err != nil {
 		log.Infof("Error saving batch in alertStore: %v", err)
+		return
 	}
 	defer resp.Body.Close()
 	_, err = io.Copy(ioutil.Discard, resp.Body)

diff --git a/gossip/publisher/publisher.go b/gossip/publisher/publisher.go
@@ -132,6 +132,7 @@ func (p Publisher) executeTask(task PublishTask) {
 		"application/json", bytes.NewBuffer(buf))
 	if err != nil {
 		log.Infof("Error saving batch in snapStore: %v\n", err)
+		return
 	}
 	defer resp.Body.Close()
 	_, err = io.Copy(ioutil.Discard, resp.Body)