-
Notifications
You must be signed in to change notification settings - Fork 83
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
connection: Separate out lastActivity into recv and send activity #770
Conversation
Codecov Report
@@ Coverage Diff @@
## dev #770 +/- ##
==========================================
+ Coverage 88.22% 88.39% +0.16%
==========================================
Files 41 41
Lines 4145 4161 +16
==========================================
+ Hits 3657 3678 +21
+ Misses 371 366 -5
Partials 117 117
Continue to review full report at Codecov.
|
30e81f2
to
8cd9d4e
Compare
8cd9d4e
to
6489da6
Compare
connection.go
Outdated
func (c *Connection) updateLastActivitySend(frame *Frame) { | ||
// Pings are ignored for last activity. | ||
switch frame.Header.messageType { | ||
case messageTypeCallReq, messageTypeCallReqContinue, messageTypeCallRes, messageTypeCallResContinue, messageTypeError: |
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.
since we consider the same frames in both cases, can we move that into a separate private function
6489da6
to
7e52273
Compare
err restarted |
7e52273
to
a933e2a
Compare
`lastActivity` recorded when the last receive or send activity occurred over its connection. Separate this out into `lastActivityRecv` and `lastActivitySend` to observe the last receives or sends allowing monitoring of the elapsed time between reading from the recv buffer and writing to the send buffer. This will provide information on how stalled either buffer is.
a933e2a
to
9c849e1
Compare
lastActivity
recorded when the last receive or send activity occurred overits connection. Separate this out into
lastActivityRecv
andlastActivitySend
to observe the last receives or sends allowing monitoring ofthe elapsed time between reading from the recv buffer and writing to the send
buffer. This will provide information on how stalled either buffer is.