X-Git-Url: http://git.tuebingen.mpg.de/?a=blobdiff_plain;f=compress_filter.c;h=a6a001919acc5038039d5de0b0590a265052e978;hb=be5daec66f163725489f42d512659a8af5c3fd59;hp=7bd3027105f95ba4ab1f3adf5d89ec2ad9722755;hpb=610cb53b94af8e95326cd44b7845f35cffdb6bf3;p=paraslash.git diff --git a/compress_filter.c b/compress_filter.c index 7bd30271..a6a00191 100644 --- a/compress_filter.c +++ b/compress_filter.c @@ -37,7 +37,7 @@ static void compress_close(struct filter_node *fn) free(fn->private_data); } -static int compress_post_select(__a_unused struct sched *s, void *context) +static int compress_post_monitor(__a_unused struct sched *s, void *context) { struct filter_node *fn = context; struct private_compress_data *pcd = fn->private_data; @@ -116,7 +116,7 @@ err: static void compress_open(struct filter_node *fn) { - struct private_compress_data *pcd = para_calloc(sizeof(*pcd)); + struct private_compress_data *pcd = zalloc(sizeof(*pcd)); uint32_t inertia = U32_OPTVAL(INERTIA, fn->lpr); uint32_t aggressiveness = U32_OPTVAL(AGGRESSIVENESS, fn->lpr); @@ -162,6 +162,6 @@ const struct filter lsg_filter_cmd_com_compress_user_data = { .setup = compress_setup, .open = compress_open, .close = compress_close, - .pre_select = generic_filter_pre_select, - .post_select = compress_post_select, + .pre_monitor = generic_filter_pre_monitor, + .post_monitor = compress_post_monitor, };