Skip to content

Conversation

Niranjan-Formant
Copy link
Contributor

No description provided.

tags: Dict,
):

self.ingestion_analytics.log_received_message(topic)
Copy link
Collaborator

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Lets log the received message from the ROS code that actually receives the ROS message BasicSubscriberCoodinater i think

):

self.ingestion_analytics.log_received_message(topic)
self.ingestion_analytics.log_sent_message(formant_stream)
Copy link
Collaborator

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Let's only log a sent message directly after the fclient._post_<type> calls to ensure its actually sent

Comment on lines 32 to 34
def remove_sent_message(self, stream):
if stream in self.sent_messages_count and self.sent_messages_count[stream] > 0:
self.sent_messages_count[stream] -= 1
Copy link
Collaborator

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

we should never need this


def reporting_loop(self):
while self.enabled:
self.report()
Copy link
Collaborator

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

lets clear them out after we print

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

Successfully merging this pull request may close these issues.

3 participants