-
Notifications
You must be signed in to change notification settings - Fork 206
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Fix direct connections processor #4390
Conversation
Codecov Report
@@ Coverage Diff @@
## rc/2022-july #4390 +/- ##
================================================
+ Coverage 73.78% 73.82% +0.03%
================================================
Files 675 675
Lines 86837 86853 +16
================================================
+ Hits 64072 64116 +44
+ Misses 17968 17939 -29
- Partials 4797 4798 +1
Help us with your feedback. Take ten seconds to tell us how you rate us. Have a feature suggestion? Share it here. |
@@ -92,9 +98,22 @@ func (dcp *directConnectionsProcessor) startProcessLoop(ctx context.Context) { | |||
} | |||
|
|||
func (dcp *directConnectionsProcessor) sendMessageToNewConnections() { | |||
if dcp.isCurrentNodeValidator() { | |||
log.Debug("directConnectionsProcessor.sendMessageToNewConnections current node is validator, will not send send messages to connected peers") |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
double send in the message.
also is this method called for each connection? I think there will be too many logs for this.
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
No, it will be logged once every 1 minute, as it is configured now
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
fixed message
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
System test passed.
Description of the reasoning behind the pull request (what feature was missing / how the problem was manifesting itself / what was the motive behind the refactoring)
Proposed Changes
Testing procedure
*:DEBUG,heartbeat/processor:TRACE
. If ran with this branch the sending will be done only on new connected peers.