diff --git a/daemon/cli.c b/daemon/cli.c index 2d9ee46a9..b34dff3cd 100644 --- a/daemon/cli.c +++ b/daemon/cli.c @@ -296,7 +296,7 @@ RTPE_CONFIG_BOOL_PARAMS RTPE_CONFIG_ENUM_PARAMS #undef X -#define X(s) cw->cw_printf(cw, #s " = %" PRIu64" \n", initial_rtpe_config.s); +#define X(s) cw->cw_printf(cw, #s " = %" PRIu64"\n", initial_rtpe_config.s); RTPE_CONFIG_UINT64_PARAMS #undef X @@ -307,12 +307,12 @@ RTPE_CONFIG_UINT64_PARAMS for (__auto_type s = initial_rtpe_config.interfaces.head; s ; s = s->next) { ifa = s->data; - cw->cw_printf(cw,"interface[%d] = %s\\%s \n", count, ifa->name.s, sockaddr_print_buf(&(ifa->local_address.addr))); + cw->cw_printf(cw, "interface[%d] = %s\\%s\n", count, ifa->name.s, sockaddr_print_buf(&(ifa->local_address.addr))); ++count; } count=0; for (__auto_type s = initial_rtpe_config.redis_subscribed_keyspaces.head; s ; s = s->next) { - cw->cw_printf(cw,"keyspace[%d] = %d \n", count, GPOINTER_TO_UINT(s->data)); + cw->cw_printf(cw, "keyspace[%d] = %d\n", count, GPOINTER_TO_UINT(s->data)); ++count; } @@ -348,7 +348,7 @@ RTPE_CONFIG_BOOL_PARAMS RTPE_CONFIG_ENUM_PARAMS #undef X -#define X(s) cw->cw_printf(cw, #s " = %" PRIu64" \n", rtpe_config.s); +#define X(s) cw->cw_printf(cw, #s " = %" PRIu64"\n", rtpe_config.s); RTPE_CONFIG_UINT64_PARAMS #undef X @@ -359,12 +359,12 @@ RTPE_CONFIG_UINT64_PARAMS for (__auto_type c = rtpe_config.interfaces.head; c ; c = c->next) { ifa = c->data; - cw->cw_printf(cw,"interface[%d] = %s\\%s \n", count, ifa->name.s, sockaddr_print_buf(&(ifa->local_address.addr))); + cw->cw_printf(cw, "interface[%d] = %s\\%s\n", count, ifa->name.s, sockaddr_print_buf(&(ifa->local_address.addr))); ++count; } count=0; for (__auto_type c = rtpe_config.redis_subscribed_keyspaces.head; c ; c = c->next) { - cw->cw_printf(cw,"keyspace[%d] = %d \n", count, GPOINTER_TO_UINT(c->data)); + cw->cw_printf(cw, "keyspace[%d] = %d\n", count, GPOINTER_TO_UINT(c->data)); ++count; } @@ -786,7 +786,7 @@ static void cli_incoming_set_maxopenfiles(str *instr, struct cli_writer *cw) { cw->cw_printf(cw, "Fail setting open_files to %s; errno=%d\n", instr->s, errno); return; } else if (endptr == instr->s) { - cw->cw_printf(cw, "Fail setting open_files to %s; no digists found\n", instr->s); + cw->cw_printf(cw, "Fail setting open_files to %s; no digits found\n", instr->s); return; } else if (open_files_num < min_open_files_num) { cw->cw_printf(cw, "Fail setting open_files to %lu; can't set it under %lu\n", open_files_num, min_open_files_num); @@ -817,7 +817,7 @@ static void cli_incoming_set_maxsessions(str *instr, struct cli_writer *cw) { cw->cw_printf(cw, "Fail setting maxsessions to %s; errno=%d\n", instr->s, errno); return; } else if (endptr == instr->s) { - cw->cw_printf(cw, "Fail setting maxsessions to %s; no digists found\n", instr->s); + cw->cw_printf(cw, "Fail setting maxsessions to %s; no digits found\n", instr->s); return; } else if (maxsessions_num < disabled) { cw->cw_printf(cw, "Fail setting maxsessions to %ld; either positive or -1 values allowed\n", maxsessions_num); @@ -848,7 +848,7 @@ static void cli_incoming_set_maxcpu(str *instr, struct cli_writer *cw) { cw->cw_printf(cw, "Fail setting maxcpu to %s; errno=%d\n", instr->s, errno); return; } else if (endptr == instr->s) { - cw->cw_printf(cw, "Fail setting maxcpu to %s; no digists found\n", instr->s); + cw->cw_printf(cw, "Fail setting maxcpu to %s; no digits found\n", instr->s); return; } else { atomic_set_na(&rtpe_config.cpu_limit, (int) (num * 100)); @@ -873,7 +873,7 @@ static void cli_incoming_set_maxload(str *instr, struct cli_writer *cw) { cw->cw_printf(cw, "Fail setting maxload to %s; errno=%d\n", instr->s, errno); return; } else if (endptr == instr->s) { - cw->cw_printf(cw, "Fail setting maxload to %s; no digists found\n", instr->s); + cw->cw_printf(cw, "Fail setting maxload to %s; no digits found\n", instr->s); return; } else { atomic_set_na(&rtpe_config.load_limit, (int) (num * 100)); @@ -898,7 +898,7 @@ static void cli_incoming_set_maxbw(str *instr, struct cli_writer *cw) { cw->cw_printf(cw, "Fail setting maxbw to %s; errno=%d\n", instr->s, errno); return; } else if (endptr == instr->s) { - cw->cw_printf(cw, "Fail setting maxbw to %s; no digists found\n", instr->s); + cw->cw_printf(cw, "Fail setting maxbw to %s; no digits found\n", instr->s); return; } else { atomic_set_na(&rtpe_config.bw_limit, num); @@ -924,7 +924,7 @@ static void cli_incoming_set_gentimeout(str *instr, struct cli_writer *cw, int * cw->cw_printf(cw, "Fail setting timeout to %s; errno=%d\n", instr->s, errno); return; } else if (endptr == instr->s) { - cw->cw_printf(cw, "Fail setting timeout to %s; no digists found\n", instr->s); + cw->cw_printf(cw, "Fail setting timeout to %s; no digits found\n", instr->s); return; } else { atomic_set_na(conf_timeout, timeout_num); @@ -1055,9 +1055,9 @@ static void cli_incoming_ksadd(str *instr, struct cli_writer *cw) { uint_keyspace_db = strtoul(instr->s, &endptr, 10); if ((errno == ERANGE && (uint_keyspace_db == ULONG_MAX)) || (errno != 0 && uint_keyspace_db == 0)) { - cw->cw_printf(cw, "Fail adding keyspace %s to redis notifications; errono=%d\n", instr->s, errno); + cw->cw_printf(cw, "Fail adding keyspace %s to redis notifications; errno=%d\n", instr->s, errno); } else if (endptr == instr->s) { - cw->cw_printf(cw, "Fail adding keyspace %s to redis notifications; no digists found\n", instr->s); + cw->cw_printf(cw, "Fail adding keyspace %s to redis notifications; no digits found\n", instr->s); } else { rwlock_lock_w(&rtpe_config.keyspaces_lock); if (!g_queue_find(&rtpe_config.redis_subscribed_keyspaces, GUINT_TO_POINTER(uint_keyspace_db))) { @@ -1086,9 +1086,9 @@ static void cli_incoming_ksrm(str *instr, struct cli_writer *cw) { rwlock_lock_w(&rtpe_config.keyspaces_lock); if ((errno == ERANGE && (uint_keyspace_db == ULONG_MAX)) || (errno != 0 && uint_keyspace_db == 0)) { - cw->cw_printf(cw, "Fail removing keyspace %s to redis notifications; errono=%d\n", instr->s, errno); + cw->cw_printf(cw, "Fail removing keyspace %s to redis notifications; errno=%d\n", instr->s, errno); } else if (endptr == instr->s) { - cw->cw_printf(cw, "Fail removing keyspace %s to redis notifications; no digists found\n", instr->s); + cw->cw_printf(cw, "Fail removing keyspace %s to redis notifications; no digits found\n", instr->s); } else if ((l = g_queue_find(&rtpe_config.redis_subscribed_keyspaces, GUINT_TO_POINTER(uint_keyspace_db)))) { // remove this keyspace redis_notify_subscribe_action(rtpe_redis_notify, UNSUBSCRIBE_KEYSPACE, uint_keyspace_db); @@ -1111,7 +1111,7 @@ static void cli_incoming_kslist(str *instr, struct cli_writer *cw) { GList *l; cw->cw_printf(cw, "\nSubscribed-on keyspaces:\n"); - + rwlock_lock_r(&rtpe_config.keyspaces_lock); for (l = rtpe_config.redis_subscribed_keyspaces.head; l; l = l->next) { cw->cw_printf(cw, "%u ", GPOINTER_TO_UINT(l->data)); diff --git a/daemon/main.c b/daemon/main.c index 84b301002..4c770c94c 100644 --- a/daemon/main.c +++ b/daemon/main.c @@ -799,7 +799,7 @@ static void options(int *argc, char ***argv, GHashTable *templates) { if ((errno == ERANGE && (uint_keyspace_db == ULONG_MAX)) || (errno != 0 && uint_keyspace_db == 0)) { - ilog(LOG_ERR, "Fail adding keyspace '" STR_FORMAT "' to redis notifications; errono=%d\n", STR_FMT(&str_keyspace_db), errno); + ilog(LOG_ERR, "Fail adding keyspace '" STR_FORMAT "' to redis notifications; errno=%d\n", STR_FMT(&str_keyspace_db), errno); } else if (endptr == str_keyspace_db.s) { ilog(LOG_ERR, "Fail adding keyspace '" STR_FORMAT "' to redis notifications; no digits found\n", STR_FMT(&str_keyspace_db)); } else {