summaryrefslogtreecommitdiff
path: root/main/taskprocessor.c
diff options
context:
space:
mode:
authorRichard Mudgett <rmudgett@digium.com>2016-01-18 19:44:24 -0600
committerRichard Mudgett <rmudgett@digium.com>2016-01-19 16:48:59 -0600
commitc9f7269b2eab5e575ea1a85ee8a7883a568a92ac (patch)
tree8bf2d5cd8bca453f87adf11cf992be724a2e2fb3 /main/taskprocessor.c
parenta4dcbdf50ff2f0d3928d926c99567e1837ca58b5 (diff)
taskprocessor.c: Increase CLI "core ping taskprocessor" timeout.
Change-Id: I4892d6acbb580d6c207d006341eaf5e0f8f2a029
Diffstat (limited to 'main/taskprocessor.c')
-rw-r--r--main/taskprocessor.c12
1 files changed, 11 insertions, 1 deletions
diff --git a/main/taskprocessor.c b/main/taskprocessor.c
index 5f2f8de44..a45be1a17 100644
--- a/main/taskprocessor.c
+++ b/main/taskprocessor.c
@@ -394,9 +394,18 @@ static char *cli_tps_ping(struct ast_cli_entry *e, int cmd, struct ast_cli_args
return CLI_SUCCESS;
}
ast_cli(a->fd, "\npinging %s ...", name);
- when = ast_tvadd((begin = ast_tvnow()), ast_samp2tv(1000, 1000));
+
+ /*
+ * Wait up to 5 seconds for a ping reply.
+ *
+ * On a very busy system it could take awhile to get a
+ * ping response from some taskprocessors.
+ */
+ begin = ast_tvnow();
+ when = ast_tvadd(begin, ast_samp2tv(5000, 1000));
ts.tv_sec = when.tv_sec;
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);
@@ -406,6 +415,7 @@ static char *cli_tps_ping(struct ast_cli_entry *e, int cmd, struct ast_cli_args
}
ast_cond_timedwait(&cli_ping_cond, &cli_ping_cond_lock, &ts);
ast_mutex_unlock(&cli_ping_cond_lock);
+
end = ast_tvnow();
delta = ast_tvsub(end, begin);
ast_cli(a->fd, "\n\t%24s ping time: %.1ld.%.6ld sec\n\n", name, (long)delta.tv_sec, (long int)delta.tv_usec);