X-Git-Url: http://git.onelab.eu/?p=distributedratelimiting.git;a=blobdiff_plain;f=drl%2Fulogd_DRL.c;fp=drl%2Fulogd_DRL.c;h=170ab4375ea7e122ce901ec224882f9ebcd51332;hp=97f24bc7fb97334df7e969d802da649cf09d0e53;hb=3cc87c8471668009b3426013fded8c6ec5a382da;hpb=7df21963a496196ca1d5b874876ddad5472245b2 diff --git a/drl/ulogd_DRL.c b/drl/ulogd_DRL.c index 97f24bc..170ab43 100644 --- a/drl/ulogd_DRL.c +++ b/drl/ulogd_DRL.c @@ -1735,32 +1735,6 @@ static void reconfig() { pthread_rwlock_unlock(&limiter.limiter_lock); } -static ulog_output_t drl_op = { - .name = "drl", - .output = &_output_drl, - .signal = NULL, /* This appears to be broken. Using my own handler. */ - .init = NULL, - .fini = NULL, -}; - -/* Tests the amount of time it takes to call reconfig(). */ -static void time_reconfig(int iterations) { - struct timeval start, end; - int i; - - gettimeofday(&start, NULL); - for (i = 0; i < iterations; ++i) { - reconfig(); - } - gettimeofday(&end, NULL); - - printf("%d reconfigs() took %d seconds and %d microseconds.\n", - iterations, end.tv_sec - start.tv_sec, end.tv_usec - start.tv_usec); - exit(0); - - // Seems to take about 85ms / iteration -} - static int stop_enforcement(drl_instance_t *instance) { char cmd[300]; int i; @@ -1839,13 +1813,9 @@ static void *signal_thread_func(void *args) { break; } } - } -/* register output plugin with ulogd */ -static void _drl_reg_op(void) -{ - ulog_output_t *op = &drl_op; +static int drl_plugin_init() { sigset_t signal_mask; sigemptyset(&signal_mask); @@ -1868,8 +1838,6 @@ static void _drl_reg_op(void) exit(EXIT_FAILURE); } - register_output(op); - /* start up the thread that will periodically estimate the * local rate and set the local limits * see estimate.c @@ -1886,6 +1854,43 @@ static void _drl_reg_op(void) printlog(LOG_CRITICAL, "--Switching enforcement on.--\n"); pthread_rwlock_unlock(&limiter.limiter_lock); } + + return 0; +} + +static ulog_output_t drl_op = { + .name = "drl", + .output = &_output_drl, + .signal = NULL, /* This appears to be broken. Using my own handler. */ + .init = &drl_plugin_init, + .fini = NULL, +}; + +#if 0 +/* Tests the amount of time it takes to call reconfig(). */ +static void time_reconfig(int iterations) { + struct timeval start, end; + int i; + + gettimeofday(&start, NULL); + for (i = 0; i < iterations; ++i) { + reconfig(); + } + gettimeofday(&end, NULL); + + printf("%d reconfigs() took %d seconds and %d microseconds.\n", + iterations, end.tv_sec - start.tv_sec, end.tv_usec - start.tv_usec); + exit(0); + + // Seems to take about 85ms / iteration +} +#endif + +/* register output plugin with ulogd */ +static void _drl_reg_op(void) +{ + ulog_output_t *op = &drl_op; + register_output(op); } void _init(void)