diff --git a/src/connector.c b/src/connector.c index 3107901c..a7b776ab 100644 --- a/src/connector.c +++ b/src/connector.c @@ -864,6 +864,7 @@ retry: } else if (cmdmatch(buf, "reject")) { LOGDEBUG("Connector received reject signal"); cdata->accept = false; + send_proc(ckp->stratifier, "dropall"); } else if (cmdmatch(buf, "stats")) { char *msg; diff --git a/src/stratifier.c b/src/stratifier.c index 243a9df9..5bdb9146 100644 --- a/src/stratifier.c +++ b/src/stratifier.c @@ -1064,7 +1064,7 @@ static void drop_allclients(ckpool_t *ckp) ck_wunlock(&sdata->instance_lock); if (kills) - LOGNOTICE("Dropped %d instances", kills); + LOGNOTICE("Dropped %d instances for dropall request", kills); } static void update_subscribe(ckpool_t *ckp)