taskpool: Fix some references to threadpool that should be taskpool.

Resolves: #1478

diff --git a/include/asterisk/stasis.h b/include/asterisk/stasis.h
index 5cc71f2e23260a2dc8a5e75d4c10701d0c053bca..b63cd297a92104de99cb2a3aac1515bec9516ffb 100644 (file)
--- a/include/asterisk/stasis.h
+++ b/include/asterisk/stasis.h
@@ -649,7 +649,7 @@ struct stasis_subscription *__stasis_subscribe(struct stasis_topic *topic,
 #define stasis_subscribe(topic, callback, data) __stasis_subscribe(topic, callback, data, __FILE__, __LINE__, __PRETTY_FUNCTION__)
 
 /*!
- * \brief Create a subscription whose callbacks occur on a thread pool
+ * \brief Create a subscription whose callbacks occur on a task pool
  *
  * In addition to being AO2 managed memory (requiring an ao2_cleanup() to free
  * up this reference), the subscription must be explicitly unsubscribed from its
@@ -659,7 +659,7 @@ struct stasis_subscription *__stasis_subscribe(struct stasis_topic *topic,
  * always happen on the same thread. The invocation order of different subscriptions
  * is unspecified.
  *
- * Unlike \ref stasis_subscribe, this function will explicitly use a threadpool to
+ * Unlike \ref stasis_subscribe, this function will explicitly use a taskpool to
  * dispatch items to its \c callback. This form of subscription should be used
  * when many subscriptions may be made to the specified \c topic.
  *

diff --git a/include/asterisk/stasis_internal.h b/include/asterisk/stasis_internal.h
index 678812e48ea16e9190518e9079107139ff586b9e..b2a26c8cdcaf22cf7834889945211e9bda7c2aae 100644 (file)
--- a/include/asterisk/stasis_internal.h
+++ b/include/asterisk/stasis_internal.h
@@ -54,7 +54,7 @@
  * \param needs_mailbox Determines whether or not the subscription requires a mailbox.
  *  Subscriptions with mailboxes will be delivered on some non-publisher thread;
  *  subscriptions without mailboxes will be delivered on the publisher thread.
- * \param use_thread_pool Use the thread pool for the subscription. This is only
+ * \param use_task_pool Use the task pool for the subscription. This is only
  *  relevant if \c needs_mailbox is non-zero.
  * \param file, lineno, func
  * \return New \ref stasis_subscription object.
@@ -66,7 +66,7 @@ struct stasis_subscription *internal_stasis_subscribe(
        stasis_subscription_cb callback,
        void *data,
        int needs_mailbox,
-       int use_thread_pool,
+       int use_task_pool,
        const char *file,
        int lineno,
        const char *func);

diff --git a/include/asterisk/stasis_message_router.h b/include/asterisk/stasis_message_router.h
index c0821b601cbdbbe17b1341442e3afc4b734ee0c1..b76be9b474654325814bc23c4bed4ee7dd4b7382 100644 (file)
--- a/include/asterisk/stasis_message_router.h
+++ b/include/asterisk/stasis_message_router.h
@@ -63,7 +63,7 @@ struct stasis_message_router *__stasis_message_router_create(
  * \brief Create a new message router object.
  *
  * The subscription created for this message router will dispatch
- * callbacks on a thread pool.
+ * callbacks on a task pool.
  *
  * \param topic Topic to subscribe route to.
  *

diff --git a/main/stasis_message_router.c b/main/stasis_message_router.c
index ff7472e334c6fa113f1a54e463910fb5537be5e4..ec35e4cc1b2c80b6793770c7bb0a29301909d2a1 100644 (file)
--- a/main/stasis_message_router.c
+++ b/main/stasis_message_router.c
@@ -203,7 +203,7 @@ static void router_dispatch(void *data,
 }
 
 static struct stasis_message_router *stasis_message_router_create_internal(
-       struct stasis_topic *topic, int use_thread_pool, const char *file, int lineno,
+       struct stasis_topic *topic, int use_task_pool, const char *file, int lineno,
        const char *func)
 {
        int res;
@@ -223,7 +223,7 @@ static struct stasis_message_router *stasis_message_router_create_internal(
                return NULL;
        }
 
-       if (use_thread_pool) {
+       if (use_task_pool) {
                router->subscription = __stasis_subscribe_pool(topic, router_dispatch, router, file, lineno, func);
        } else {
                router->subscription = __stasis_subscribe(topic, router_dispatch, router, file, lineno, func);

diff --git a/tests/test_stasis.c b/tests/test_stasis.c
index 71026a6cced3cc6e7d0dc8be64316f8ba71badda..2b8e1ea4135afae33176d2c496c138ad61e08452 100644 (file)
--- a/tests/test_stasis.c
+++ b/tests/test_stasis.c
@@ -382,8 +382,8 @@ AST_TEST_DEFINE(subscription_pool_messages)
        case TEST_INIT:
                info->name = __func__;
                info->category = test_category;
-               info->summary = "Test subscribe/unsubscribe messages using a threadpool subscription";
-               info->description = "Test subscribe/unsubscribe messages using a threadpool subscription";
+               info->summary = "Test subscribe/unsubscribe messages using a taskpool subscription";
+               info->description = "Test subscribe/unsubscribe messages using a taskpool subscription";
                return AST_TEST_NOT_RUN;
        case TEST_EXECUTE:
                break;
@@ -530,10 +530,10 @@ AST_TEST_DEFINE(publish_pool)
        case TEST_INIT:
                info->name = __func__;
                info->category = test_category;
-               info->summary = "Test publishing with a threadpool";
+               info->summary = "Test publishing with a taskpool";
                info->description = "Test publishing to a subscriber whose\n"
                        "subscription dictates messages are received through a\n"
-                       "threadpool.";
+                       "taskpool.";
                return AST_TEST_NOT_RUN;
        case TEST_EXECUTE:
                break;
@@ -793,7 +793,7 @@ AST_TEST_DEFINE(subscription_interleaving)
                        "and publishes messages alternately between the children.\n"
                        "It verifies that the messages are received in the expected\n"
                        "order, for different subscription types: one with a dedicated\n"
-                       "thread, the other on the Stasis threadpool.";
+                       "thread, the other on the Stasis taskpool.";
                return AST_TEST_NOT_RUN;
        case TEST_EXECUTE:
                break;
@@ -1619,10 +1619,10 @@ AST_TEST_DEFINE(router_pool)
        case TEST_INIT:
                info->name = __func__;
                info->category = test_category;
-               info->summary = "Test message routing via threadpool";
+               info->summary = "Test message routing via taskpool";
                info->description = "Test simple message routing when\n"
                        "the subscriptions dictate usage of the Stasis\n"
-                       "threadpool.";
+                       "taskpool.";
                return AST_TEST_NOT_RUN;
        case TEST_EXECUTE:
                break;