X-Git-Url: http://git.tuebingen.mpg.de/?p=paraslash.git;a=blobdiff_plain;f=filter_chain.c;h=4797b256caf9d6af2c868ee232f733aad19ec18f;hp=17f67058df88c9e128b7afdb5a2a3c0f801e90ad;hb=a95093cd8b62d411b9448aa77768774e1bdd81e5;hpb=b23afbb1d859a79a2682a80420a7f3c693b210e6 diff --git a/filter_chain.c b/filter_chain.c index 17f67058..4797b256 100644 --- a/filter_chain.c +++ b/filter_chain.c @@ -122,7 +122,7 @@ void filter_pre_select(__a_unused struct sched *s, struct task *t) int conv, conv_total = 0; t->ret = -E_FC_EOF; - if (*fc->output_eof) + if (fc->output_eof && *fc->output_eof) goto err_out; again: ib = fc->inbuf; @@ -150,8 +150,8 @@ again: loaded = &fn->loaded; } conv_total += conv; - PARA_INFO_LOG("eof (in/out/fc): %d/%d/%d out_loaded: %d, conv: %d, conv_total: %d\n", *fc->input_eof, - *fc->output_eof, fc->eof, *fc->out_loaded, conv, conv_total); +// PARA_INFO_LOG("eof (in/out/fc): %d/%d/%d out_loaded: %d, conv: %d, conv_total: %d\n", *fc->input_eof, +// *fc->output_eof, fc->eof, *fc->out_loaded, conv, conv_total); if (conv) goto again; t->ret = 1;