threadpool: Whitespace and comment corrections.

git-svn-id: https://origsvn.digium.com/svn/asterisk/trunk@382294 65c4cc65-6c06-0410-ace0-fbb531ad65f3

diff --git a/include/asterisk/threadpool.h b/include/asterisk/threadpool.h
index 1509317..8907626 100644 (file)
--- a/include/asterisk/threadpool.h
+++ b/include/asterisk/threadpool.h
@@ -103,6 +103,9 @@ struct ast_threadpool_options {
         *
         * When the threadpool's size increases, it can never increase
         * beyond this number of threads.
+        *
+        * Zero is a valid value if the threadpool does not have a
+        * maximum size.
         */
        int max_size;
 };
@@ -132,7 +135,7 @@ void *ast_threadpool_listener_get_user_data(const struct ast_threadpool_listener
  * \brief Create a new threadpool
  *
  * This function creates a threadpool. Tasks may be pushed onto this thread pool
- * in and will be automatically acted upon by threads within the pool.
+ * and will be automatically acted upon by threads within the pool.
  *
  * Only a single threadpool with a given name may exist. This function will fail
  * if a threadpool with the given name already exists.

diff --git a/main/threadpool.c b/main/threadpool.c
index ab390e9..68d84af 100644 (file)
--- a/main/threadpool.c
+++ b/main/threadpool.c
@@ -94,7 +94,7 @@ struct ast_threadpool {
         * that the threadpool had its state change.
         */
        struct ast_taskprocessor *control_tps;
-       /*! True if the threadpool is in the processof shutting down */
+       /*! True if the threadpool is in the process of shutting down */
        int shutting_down;
        /*! Threadpool-specific options */
        struct ast_threadpool_options options;
@@ -1127,28 +1127,30 @@ static struct serializer *serializer_create(struct ast_threadpool *pool)
 
 static int execute_tasks(void *data)
 {
-       struct ast_taskprocessor *tps = data;
+       struct ast_taskprocessor *tps = data;
 
-       while (ast_taskprocessor_execute(tps)) {
-              /* No-op */
-       }
+       while (ast_taskprocessor_execute(tps)) {
+               /* No-op */
+       }
 
-       ast_taskprocessor_unreference(tps);
-       return 0;
+       ast_taskprocessor_unreference(tps);
+       return 0;
 }
 
-static void serializer_task_pushed(struct ast_taskprocessor_listener *listener, int was_empty) {
-       if (was_empty) {
-              struct serializer *ser = ast_taskprocessor_listener_get_user_data(listener);
-              struct ast_taskprocessor *tps = ast_taskprocessor_listener_get_tps(listener);
-              ast_threadpool_push(ser->pool, execute_tasks, tps);
-       }
-};
+static void serializer_task_pushed(struct ast_taskprocessor_listener *listener, int was_empty)
+{
+       if (was_empty) {
+               struct serializer *ser = ast_taskprocessor_listener_get_user_data(listener);
+               struct ast_taskprocessor *tps = ast_taskprocessor_listener_get_tps(listener);
+
+               ast_threadpool_push(ser->pool, execute_tasks, tps);
+       }
+}
 
 static int serializer_start(struct ast_taskprocessor_listener *listener)
 {
-       /* No-op */
-       return 0;
+       /* No-op */
+       return 0;
 }
 
 static void serializer_shutdown(struct ast_taskprocessor_listener *listener)
@@ -1158,9 +1160,9 @@ static void serializer_shutdown(struct ast_taskprocessor_listener *listener)
 }
 
 static struct ast_taskprocessor_listener_callbacks serializer_tps_listener_callbacks = {
-       .task_pushed = serializer_task_pushed,
-       .start = serializer_start,
-       .shutdown = serializer_shutdown,
+       .task_pushed = serializer_task_pushed,
+       .start = serializer_start,
+       .shutdown = serializer_shutdown,
 };
 
 struct ast_taskprocessor *ast_threadpool_serializer(const char *name, struct ast_threadpool *pool)