X-Git-Url: http://git.onelab.eu/?a=blobdiff_plain;ds=sidebyside;f=drl%2Fulogd_DRL.c;h=bc82995b243f874cbb31b57fb365361f7e2dd20c;hb=d21104e4fb6400d420027b865833cae78697cda3;hp=b87b96eef4e37e8a5e715061d457ee0f83ec77bd;hpb=a3ef11b996352e66f4031c684c7dcda536bc3bf1;p=distributedratelimiting.git diff --git a/drl/ulogd_DRL.c b/drl/ulogd_DRL.c index b87b96e..bc82995 100644 --- a/drl/ulogd_DRL.c +++ b/drl/ulogd_DRL.c @@ -521,7 +521,7 @@ static identity_t *new_identity(ident_config *config) { memset(comm_nodes, 0, config->peer_count * sizeof(remote_node_t)); ident->id = config->id; - ident->limit = (uint32_t) (((double) config->limit * 1000000.0) / 8.0); + ident->limit = (uint32_t) (((double) config->limit * 1000.0) / 8.0); ident->fixed_ewma_weight = config->fixed_ewma_weight; ident->intervals = config->intervals; ident->ewma_weight = pow(ident->fixed_ewma_weight, @@ -1279,6 +1279,8 @@ static int init_drl(void) { if (parse_drl_config(drl_configfile.u.string, &configs)) { /* Parse error occured. Return non-zero to notify init_drl(). */ + printlog(LOG_CRITICAL, "Failed to parse the DRL configuration file (%s).\n", + drl_configfile.u.string); return false; } @@ -1286,11 +1288,14 @@ static int init_drl(void) { if (validate_configs(configs, &limiter.stable_instance)) { /* Clean up everything. */ free_failed_config(configs, &limiter.stable_instance); + printlog(LOG_CRITICAL, "Invalid DRL configuration file (%s).\n", + drl_configfile.u.string); return false; } if (init_identities(configs, &limiter.stable_instance)) { free_failed_config(configs, &limiter.stable_instance); + printlog(LOG_CRITICAL, "Failed to initialize identities.\n"); return false; } @@ -1305,11 +1310,13 @@ static int init_drl(void) { case POLICY_FPS: if (assign_htb_hierarchy(&limiter.stable_instance)) { free_instance(&limiter.stable_instance); + printlog(LOG_CRITICAL, "Failed to assign HTB hierarchy.\n"); return false; } if (create_htb_hierarchy(&limiter.stable_instance)) { free_instance(&limiter.stable_instance); + printlog(LOG_CRITICAL, "Failed to create HTB hierarchy.\n"); return false; } break; @@ -1317,6 +1324,7 @@ static int init_drl(void) { case POLICY_GRD: if (setup_tc_grd(&limiter.stable_instance)) { free_instance(&limiter.stable_instance); + printlog(LOG_CRITICAL, "Failed to initialize tc calls for GRD.\n"); return false; } break;