diff --git a/main/stasis.c b/main/stasis.c index 3216e217399fb05457c787197e743d8438b58c6a..91813e807d12f2c4bf7c72b8a3f10e8564b07f59 100644 --- a/main/stasis.c +++ b/main/stasis.c @@ -339,14 +339,14 @@ static AST_VECTOR(, struct stasis_message_type_statistics) message_type_statisti /*! \internal */ struct stasis_topic_statistics { + /*! \brief Highest time spent dispatching messages to subscribers */ + long highest_time_dispatched; + /*! \brief Lowest time spent dispatching messages to subscribers */ + long lowest_time_dispatched; /*! \brief The number of messages that were not dispatched to any subscriber */ int messages_not_dispatched; /*! \brief The number of messages that were dispatched to at least 1 subscriber */ int messages_dispatched; - /*! \brief Highest time spent dispatching messages to subscribers */ - int64_t highest_time_dispatched; - /*! \brief Lowest time spent dispatching messages to subscribers */ - int64_t lowest_time_dispatched; /*! \brief The number of subscribers to this topic */ int subscriber_count; /*! \brief Name of the topic */ @@ -461,26 +461,26 @@ size_t stasis_topic_subscribers(const struct stasis_topic *topic) struct stasis_subscription_statistics { /*! \brief The filename where the subscription originates */ const char *file; - /*! \brief The line number where the subscription originates */ - int lineno; /*! \brief The function where the subscription originates */ const char *func; + /*! \brief Name of the topic we subscribed to */ + char *topic; + /*! \brief The message type that currently took the longest to process */ + struct stasis_message_type *highest_time_message_type; + /*! \brief Highest time spent invoking a message */ + long highest_time_invoked; + /*! \brief Lowest time spent invoking a message */ + long lowest_time_invoked; /*! \brief The number of messages that were filtered out */ int messages_dropped; /*! \brief The number of messages that passed filtering */ int messages_passed; - /*! \brief Highest time spent invoking a message */ - int64_t highest_time_invoked; - /*! \brief The message type that currently took the longest to process */ - struct stasis_message_type *highest_time_message_type; - /*! \brief Lowest time spent invoking a message */ - int64_t lowest_time_invoked; /*! \brief Using a mailbox to queue messages */ int uses_mailbox; /*! \brief Using stasis threadpool for handling messages */ int uses_threadpool; - /*! \brief Name of the topic we subscribed to */ - char *topic; + /*! \brief The line number where the subscription originates */ + int lineno; /*! \brief Unique ID of the subscription */ char uniqueid[0]; }; @@ -561,7 +561,7 @@ static void subscription_invoke(struct stasis_subscription *sub, int message_type_id = stasis_message_type_id(stasis_subscription_change_type()); #ifdef AST_DEVMODE struct timeval start; - int elapsed; + long elapsed; start = ast_tvnow(); #endif @@ -1243,7 +1243,7 @@ static void publish_msg(struct stasis_topic *topic, int message_type_id = stasis_message_type_id(stasis_message_type(message)); struct stasis_message_type_statistics *statistics; struct timeval start; - int elapsed; + long elapsed; #endif ast_assert(topic != NULL);