From cea87d344c4894bd25b5edf60ebb457ec5fb4bd3 Mon Sep 17 00:00:00 2001
From: bruce-riley <96066700+bruce-riley@users.noreply.github.com>
Date: Thu, 10 Nov 2022 12:41:47 -0600
Subject: [PATCH] Node: Increase bigtable writer channel size (#1889)

* Node: Increase bigtable writer channel

Change-Id: I981e80b771a68aee744ff5109be2d299004fd1a9

* Change message wording

Change-Id: I4af6dbc3b77c6133c8a129e0b20b6aebbbe39ab3
---
 node/pkg/reporter/attestation_events.go | 8 ++++----
 1 file changed, 4 insertions(+), 4 deletions(-)

diff --git a/node/pkg/reporter/attestation_events.go b/node/pkg/reporter/attestation_events.go
index 79f12445f..e44b7299c 100644
--- a/node/pkg/reporter/attestation_events.go
+++ b/node/pkg/reporter/attestation_events.go
@@ -65,8 +65,8 @@ func (re *AttestationEventReporter) Subscribe() *activeSubscription {
 	clientId := re.getUniqueClientId()
 	re.logger.Debug("Subscribe for client", zap.Int("clientId", clientId))
 	channels := &lifecycleEventChannels{
-		MessagePublicationC: make(chan *MessagePublication, 50),
-		VAAQuorumC:          make(chan *vaa.VAA, 50),
+		MessagePublicationC: make(chan *MessagePublication, 500),
+		VAAQuorumC:          make(chan *vaa.VAA, 500),
 	}
 	re.subs[clientId] = channels
 	sub := &activeSubscription{ClientId: clientId, Channels: channels}
@@ -91,7 +91,7 @@ func (re *AttestationEventReporter) ReportMessagePublication(msg *MessagePublica
 		case sub.MessagePublicationC <- msg:
 			re.logger.Debug("published MessagePublication to client", zap.Int("client", client))
 		default:
-			re.logger.Error("buffer overrun when attempting to publish message", zap.Int("client", client))
+			re.logger.Error("channel overflow when attempting to publish MessagePublication to client", zap.Int("client", client))
 		}
 	}
 }
@@ -106,7 +106,7 @@ func (re *AttestationEventReporter) ReportVAAQuorum(msg *vaa.VAA) {
 		case sub.VAAQuorumC <- msg:
 			re.logger.Debug("published VAAQuorum to client", zap.Int("client", client))
 		default:
-			re.logger.Error("buffer overrun when attempting to publish message", zap.Int("client", client))
+			re.logger.Error("channel overflow when attempting to publish VAAQuorum to client", zap.Int("client", client))
 
 		}
 	}