|
|
|
@ -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);
|
|
|
|
|