Merge "stasis: Fix ABI between DEVMODE and non-DEVMODE."
authorFriendly Automation <jenkins2@gerrit.asterisk.org>
Thu, 3 Jan 2019 23:39:22 +0000 (17:39 -0600)
committerGerrit Code Review <gerrit2@gerrit.digium.api>
Thu, 3 Jan 2019 23:39:22 +0000 (17:39 -0600)
1  2 
main/stasis.c

diff --combined main/stasis.c
@@@ -339,14 -339,14 +339,14 @@@ static AST_VECTOR(, struct stasis_messa
  
  /*! \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 */
@@@ -436,10 -436,11 +436,11 @@@ struct stasis_topic *stasis_topic_creat
        res |= AST_VECTOR_INIT(&topic->upstream_topics, 0);
  #ifdef AST_DEVMODE
        topic->statistics = stasis_topic_statistics_create(name);
-       if (!topic->name || !topic->statistics || res) {
+       if (!topic->name || !topic->statistics || res)
  #else
-       if (!topic->name || res) {
+       if (!topic->name || res)
  #endif
+       {
                ao2_ref(topic, -1);
                return NULL;
        }
@@@ -461,26 -462,26 +462,26 @@@ size_t stasis_topic_subscribers(const s
  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 -562,7 +562,7 @@@ static void subscription_invoke(struct 
        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
@@@ -640,7 -641,6 +641,6 @@@ static struct stasis_subscription_stati
  }
  #endif
  
- #ifdef AST_DEVMODE
  struct stasis_subscription *internal_stasis_subscribe(
        struct stasis_topic *topic,
        stasis_subscription_cb callback,
        const char *file,
        int lineno,
        const char *func)
- #else
- struct stasis_subscription *internal_stasis_subscribe(
-       struct stasis_topic *topic,
-       stasis_subscription_cb callback,
-       void *data,
-       int needs_mailbox,
-       int use_thread_pool)
- #endif
  {
        struct stasis_subscription *sub;
  
        return sub;
  }
  
- #ifdef AST_DEVMODE
  struct stasis_subscription *__stasis_subscribe(
        struct stasis_topic *topic,
        stasis_subscription_cb callback,
  {
        return internal_stasis_subscribe(topic, callback, data, 1, 0, file, lineno, func);
  }
- #else
- struct stasis_subscription *stasis_subscribe(
-       struct stasis_topic *topic,
-       stasis_subscription_cb callback,
-       void *data)
- {
-       return internal_stasis_subscribe(topic, callback, data, 1, 0);
- }
- #endif
  
- #ifdef AST_DEVMODE
  struct stasis_subscription *__stasis_subscribe_pool(
        struct stasis_topic *topic,
        stasis_subscription_cb callback,
  {
        return internal_stasis_subscribe(topic, callback, data, 1, 1, file, lineno, func);
  }
- #else
- struct stasis_subscription *stasis_subscribe_pool(
-       struct stasis_topic *topic,
-       stasis_subscription_cb callback,
-       void *data)
- {
-       return internal_stasis_subscribe(topic, callback, data, 1, 1);
- }
- #endif
  
  static int sub_cleanup(void *data)
  {
@@@ -1243,7 -1215,7 +1215,7 @@@ static void publish_msg(struct stasis_t
        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);