-
Notifications
You must be signed in to change notification settings - Fork 791
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
[10792] Collection of data and notification to listeners PUBLICATION_THROUGHPUT #1955
[10792] Collection of data and notification to listeners PUBLICATION_THROUGHPUT #1955
Conversation
18e937b
to
8bd4036
Compare
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.
LGTM. Only a suggestion to clarify the documentation
@@ -172,6 +172,13 @@ class StatisticsWriterImpl | |||
/// Notify listeners of DATA / DATA_FRAG counts | |||
void on_data_sent(); | |||
|
|||
/** | |||
* @brief Reports throughtput based on last added sample to history |
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.
* @brief Reports throughtput based on last added sample to history | |
* @brief Reports publication throughtput based on last added sample to writer's history |
@@ -78,6 +78,15 @@ class StatisticsWriterImpl | |||
{ | |||
} | |||
|
|||
/** | |||
* @brief Reports throughtput based on last added sample to history |
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.
* @brief Reports throughtput based on last added sample to history | |
* @brief Reports publication throughtput based on last added sample to writer's history |
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.
👌
It was decided to retake the concept of reporting rate instead of the number of bytes. The change simplifies things and if in the future the amount of bytes is necessary we can extend the idl.
The callback will return bytes/second ( payload size / time span since the last callback). We only need to keep the
timestamp of the last callback and initialize it on construction (creation is the first callback).