Skip to content
Snippets Groups Projects
Commit e89d2691 authored by Joshua Colp's avatar Joshua Colp Committed by Gerrit Code Review
Browse files

Merge topic 'update_taskprocessor_commands'

* changes:
  taskprocessor.c: Fix CLI "core show taskprocessors" unref.
  taskprocessor.c: Add CLI "core ping taskprocessor" missing unlock.
parents e57defa8 7d86979e
Branches
Tags
No related merge requests found
......@@ -399,6 +399,7 @@ static char *cli_tps_ping(struct ast_cli_entry *e, int cmd, struct ast_cli_args
ts.tv_nsec = when.tv_usec * 1000;
ast_mutex_lock(&cli_ping_cond_lock);
if (ast_taskprocessor_push(tps, tps_ping_handler, 0) < 0) {
ast_mutex_unlock(&cli_ping_cond_lock);
ast_cli(a->fd, "\nping failed: could not push task to %s\n\n", name);
ao2_ref(tps, -1);
return CLI_FAILURE;
......@@ -444,7 +445,7 @@ static char *cli_tps_report(struct ast_cli_entry *e, int cmd, struct ast_cli_arg
maxqsize = p->stats->max_qsize;
processed = p->stats->_tasks_processed_count;
ast_cli(a->fd, "\n%24s %17lu %12lu %12lu", name, processed, qsize, maxqsize);
ao2_ref(p, -1);
ast_taskprocessor_unreference(p);
}
ao2_iterator_destroy(&i);
tcount = ao2_container_count(tps_singletons);
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment