From 3b67f629a46a49b9c35344fd3f03b02f86f239f0 Mon Sep 17 00:00:00 2001
From: Krishna Srinivas <634494+krishnasrinivas@users.noreply.github.com>
Date: Mon, 9 Dec 2019 05:29:37 -0800
Subject: [PATCH] Retry peer notification of events (#8621)

---
 cmd/peer-rest-client.go | 15 +++++++++++++++
 1 file changed, 15 insertions(+)

diff --git a/cmd/peer-rest-client.go b/cmd/peer-rest-client.go
index 37085354d..e5719e996 100644
--- a/cmd/peer-rest-client.go
+++ b/cmd/peer-rest-client.go
@@ -294,6 +294,21 @@ func (client *peerRESTClient) ListenBucketNotification(bucket string, eventNames
 
 // SendEvent - calls send event RPC.
 func (client *peerRESTClient) SendEvent(bucket string, targetID, remoteTargetID event.TargetID, eventData event.Event) error {
+	numTries := 10
+	for {
+		err := client.sendEvent(bucket, targetID, remoteTargetID, eventData)
+		if err == nil {
+			return nil
+		}
+		if numTries == 0 {
+			return err
+		}
+		numTries--
+		time.Sleep(5 * time.Second)
+	}
+}
+
+func (client *peerRESTClient) sendEvent(bucket string, targetID, remoteTargetID event.TargetID, eventData event.Event) error {
 	args := sendEventRequest{
 		TargetID: remoteTargetID,
 		Event:    eventData,