Skip to content
Snippets Groups Projects
Commit 5665aa36 authored by Russell Bryant's avatar Russell Bryant
Browse files

Minor tweaks to comment blocks and includes.

Fix the copyright lines, tweak doxygen formatting, and remove some unnecessary
includes.


git-svn-id: https://origsvn.digium.com/svn/asterisk/trunk@248226 65c4cc65-6c06-0410-ace0-fbb531ad65f3
parent 29c57c6d
No related branches found
No related tags found
No related merge requests found
/* /*
* Asterisk -- An open source telephony toolkit. * Asterisk -- An open source telephony toolkit.
* *
* Copyright (C) 2007-2008, Dwayne M. Hubbard * Copyright (C) 2007-2008, Digium, Inc.
* *
* Dwayne M. Hubbard <dhubbard@digium.com> * Dwayne M. Hubbard <dhubbard@digium.com>
* *
...@@ -15,14 +15,6 @@ ...@@ -15,14 +15,6 @@
* the GNU General Public License Version 2. See the LICENSE file * the GNU General Public License Version 2. See the LICENSE file
* at the top of the source tree. * at the top of the source tree.
*/ */
#include "asterisk.h"
#include "asterisk/lock.h"
#include "asterisk/linkedlists.h"
#include "asterisk/utils.h"
#include "asterisk/options.h"
#ifndef __taskprocessor_h__
#define __taskprocessor_h__
/*! /*!
* \file taskprocessor.h * \file taskprocessor.h
...@@ -47,14 +39,20 @@ ...@@ -47,14 +39,20 @@
* to be processed in the taskprocessor queue when the taskprocessor reference count reaches zero * to be processed in the taskprocessor queue when the taskprocessor reference count reaches zero
* will be purged and released from the taskprocessor queue without being processed. * will be purged and released from the taskprocessor queue without being processed.
*/ */
#ifndef __AST_TASKPROCESSOR_H__
#define __AST_TASKPROCESSOR_H__
struct ast_taskprocessor; struct ast_taskprocessor;
/*! \brief ast_tps_options for specification of taskprocessor options /*!
* \brief ast_tps_options for specification of taskprocessor options
* *
* Specify whether a taskprocessor should be created via ast_taskprocessor_get() if the taskprocessor * Specify whether a taskprocessor should be created via ast_taskprocessor_get() if the taskprocessor
* does not already exist. The default behavior is to create a taskprocessor if it does not already exist * does not already exist. The default behavior is to create a taskprocessor if it does not already exist
* and provide its reference to the calling function. To only return a reference to a taskprocessor if * and provide its reference to the calling function. To only return a reference to a taskprocessor if
* and only if it exists, use the TPS_REF_IF_EXISTS option in ast_taskprocessor_get(). */ * and only if it exists, use the TPS_REF_IF_EXISTS option in ast_taskprocessor_get().
*/
enum ast_tps_options { enum ast_tps_options {
/*! \brief return a reference to a taskprocessor, create one if it does not exist */ /*! \brief return a reference to a taskprocessor, create one if it does not exist */
TPS_REF_DEFAULT = 0, TPS_REF_DEFAULT = 0,
...@@ -62,7 +60,8 @@ enum ast_tps_options { ...@@ -62,7 +60,8 @@ enum ast_tps_options {
TPS_REF_IF_EXISTS = (1 << 0), TPS_REF_IF_EXISTS = (1 << 0),
}; };
/*! \brief Get a reference to a taskprocessor with the specified name and create the taskprocessor if necessary /*!
* \brief Get a reference to a taskprocessor with the specified name and create the taskprocessor if necessary
* *
* The default behavior of instantiating a taskprocessor if one does not already exist can be * The default behavior of instantiating a taskprocessor if one does not already exist can be
* disabled by specifying the TPS_REF_IF_EXISTS ast_tps_options as the second argument to ast_taskprocessor_get(). * disabled by specifying the TPS_REF_IF_EXISTS ast_tps_options as the second argument to ast_taskprocessor_get().
...@@ -75,7 +74,8 @@ enum ast_tps_options { ...@@ -75,7 +74,8 @@ enum ast_tps_options {
*/ */
struct ast_taskprocessor *ast_taskprocessor_get(const char *name, enum ast_tps_options create); struct ast_taskprocessor *ast_taskprocessor_get(const char *name, enum ast_tps_options create);
/*! \brief Unreference the specified taskprocessor and its reference count will decrement. /*!
* \brief Unreference the specified taskprocessor and its reference count will decrement.
* *
* Taskprocessors use astobj2 and will unlink from the taskprocessor singleton container and destroy * Taskprocessors use astobj2 and will unlink from the taskprocessor singleton container and destroy
* themself when the taskprocessor reference count reaches zero. * themself when the taskprocessor reference count reaches zero.
...@@ -85,18 +85,21 @@ struct ast_taskprocessor *ast_taskprocessor_get(const char *name, enum ast_tps_o ...@@ -85,18 +85,21 @@ struct ast_taskprocessor *ast_taskprocessor_get(const char *name, enum ast_tps_o
*/ */
void *ast_taskprocessor_unreference(struct ast_taskprocessor *tps); void *ast_taskprocessor_unreference(struct ast_taskprocessor *tps);
/*! \brief Push a task into the specified taskprocessor queue and signal the taskprocessor thread /*!
* \brief Push a task into the specified taskprocessor queue and signal the taskprocessor thread
* \param tps The taskprocessor structure * \param tps The taskprocessor structure
* \param task_exe The task handling function to push into the taskprocessor queue * \param task_exe The task handling function to push into the taskprocessor queue
* \param datap The data to be used by the task handling function * \param datap The data to be used by the task handling function
* \return zero on success, -1 on failure * \retval 0 success
* \retval -1 failure
* \since 1.6.1 * \since 1.6.1
*/ */
int ast_taskprocessor_push(struct ast_taskprocessor *tps, int (*task_exe)(void *datap), void *datap); int ast_taskprocessor_push(struct ast_taskprocessor *tps, int (*task_exe)(void *datap), void *datap);
/*! \brief Return the name of the taskprocessor singleton /*!
* \brief Return the name of the taskprocessor singleton
* \since 1.6.1 * \since 1.6.1
*/ */
const char *ast_taskprocessor_name(struct ast_taskprocessor *tps); const char *ast_taskprocessor_name(struct ast_taskprocessor *tps);
#endif
#endif /* __AST_TASKPROCESSOR_H__ */
/* /*
* Asterisk -- An open source telephony toolkit. * Asterisk -- An open source telephony toolkit.
* *
* Copyright (C) 2007-2008, Dwayne M. Hubbard * Copyright (C) 2007-2008, Digium, Inc.
* *
* Dwayne M. Hubbard <dhubbard@digium.com> * Dwayne M. Hubbard <dhubbard@digium.com>
* *
...@@ -15,8 +15,9 @@ ...@@ -15,8 +15,9 @@
* the GNU General Public License Version 2. See the LICENSE file * the GNU General Public License Version 2. See the LICENSE file
* at the top of the source tree. * at the top of the source tree.
*/ */
/*! \file
* /*!
* \file
* \brief Maintain a container of uniquely-named taskprocessor threads that can be shared across modules. * \brief Maintain a container of uniquely-named taskprocessor threads that can be shared across modules.
* *
* \author Dwayne Hubbard <dhubbard@digium.com> * \author Dwayne Hubbard <dhubbard@digium.com>
...@@ -26,9 +27,6 @@ ...@@ -26,9 +27,6 @@
ASTERISK_FILE_VERSION(__FILE__, "$Revision$") ASTERISK_FILE_VERSION(__FILE__, "$Revision$")
#include <signal.h>
#include <sys/time.h>
#include "asterisk/_private.h" #include "asterisk/_private.h"
#include "asterisk/module.h" #include "asterisk/module.h"
#include "asterisk/time.h" #include "asterisk/time.h"
...@@ -37,11 +35,13 @@ ASTERISK_FILE_VERSION(__FILE__, "$Revision$") ...@@ -37,11 +35,13 @@ ASTERISK_FILE_VERSION(__FILE__, "$Revision$")
#include "asterisk/taskprocessor.h" #include "asterisk/taskprocessor.h"
/*! \brief tps_task structure is queued to a taskprocessor /*!
* \brief tps_task structure is queued to a taskprocessor
* *
* tps_tasks are processed in FIFO order and freed by the taskprocessing * tps_tasks are processed in FIFO order and freed by the taskprocessing
* thread after the task handler returns. The callback function that is assigned * thread after the task handler returns. The callback function that is assigned
* to the execute() function pointer is responsible for releasing datap resources if necessary. */ * to the execute() function pointer is responsible for releasing datap resources if necessary.
*/
struct tps_task { struct tps_task {
/*! \brief The execute() task callback function pointer */ /*! \brief The execute() task callback function pointer */
int (*execute)(void *datap); int (*execute)(void *datap);
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment