kenmirrors/asterisk
1
0
Fork 0
mirror of https://github.com/asterisk/asterisk.git synced 2025-10-12 07:35:18 +00:00
Code Issues Packages Projects Releases Wiki Activity

Merge "taskprocessor: Add high water mark warnings" into 13

Browse Source
This commit is contained in:
Joshua Colp
2015-11-11 07:10:22 -06:00
committed by Gerrit Code Review
parent 3e0f161761 6ff48319d9
commit 18e61a6442
1 changed files with 11 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
main/taskprocessor.c
View File

@@ -83,6 +83,8 @@ struct ast_taskprocessor {
pthread_t thread; pthread_t thread;
/*! Indicates if the taskprocessor is currently executing a task */ /*! Indicates if the taskprocessor is currently executing a task */
unsigned int executing:1; unsigned int executing:1;
/*! Indicates that a high water warning has been issued on this task processor */
unsigned int high_water_warned:1;
}; };
/*! /*!
@@ -714,6 +716,8 @@ void *ast_taskprocessor_unreference(struct ast_taskprocessor *tps)
return NULL; return NULL;
} }
#define HIGH_WATER_LEVEL 100
/* push the task into the taskprocessor queue */ /* push the task into the taskprocessor queue */
static int taskprocessor_push(struct ast_taskprocessor *tps, struct tps_task *t) static int taskprocessor_push(struct ast_taskprocessor *tps, struct tps_task *t)
{ {
@@ -733,6 +737,13 @@ static int taskprocessor_push(struct ast_taskprocessor *tps, struct tps_task *t)
ao2_lock(tps); ao2_lock(tps);
AST_LIST_INSERT_TAIL(&tps->tps_queue, t, list); AST_LIST_INSERT_TAIL(&tps->tps_queue, t, list);
previous_size = tps->tps_queue_size++; previous_size = tps->tps_queue_size++;
if (previous_size >= HIGH_WATER_LEVEL && !tps->high_water_warned) {
ast_log(LOG_WARNING, "The '%s' task processor queue reached %d scheduled tasks.\n",
tps->name, previous_size);
tps->high_water_warned = 1;
}
/* The currently executing task counts as still in queue */ /* The currently executing task counts as still in queue */
was_empty = tps->executing ? 0 : previous_size == 0; was_empty = tps->executing ? 0 : previous_size == 0;
ao2_unlock(tps); ao2_unlock(tps);