From 973571c70c5a0f63ecf4e7edc060738c757c255a Mon Sep 17 00:00:00 2001 From: Con Kolivas Date: Sat, 2 Aug 2014 12:47:22 +1000 Subject: [PATCH] Only show queueing message to ckdb once and display resumed message --- src/stratifier.c | 10 +++++++++- 1 file changed, 9 insertions(+), 1 deletion(-) diff --git a/src/stratifier.c b/src/stratifier.c index f3bd2b75..297f5f51 100644 --- a/src/stratifier.c +++ b/src/stratifier.c @@ -2130,17 +2130,25 @@ out: static void ckdbq_process(ckpool_t *ckp, ckdb_msg_t *data) { + static bool failed = false; bool logged = false; char *buf = NULL; while (!buf) { buf = json_ckdb_call(ckp, ckdb_ids[data->idtype], data->val, logged); if (unlikely(!buf)) { - LOGWARNING("Failed to talk to ckdb, queueing messages"); + if (!failed) { + failed = true; + LOGWARNING("Failed to talk to ckdb, queueing messages"); + } sleep(5); } logged = true; } + if (failed) { + failed = false; + LOGWARNING("Successfully resumed talking to ckdb"); + } LOGINFO("Got %s ckdb response: %s", ckdb_ids[data->idtype], buf); free(buf); }