projects
/
paraslash.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
configure.ac: Add some missing checks.
[paraslash.git]
/
filter_chain.c
diff --git
a/filter_chain.c
b/filter_chain.c
index b39874448668466c6b351871b56b681a25ee58e5..295f2d068a6b15ac32185612feb46999907ff6cb 100644
(file)
--- a/
filter_chain.c
+++ b/
filter_chain.c
@@
-6,6
+6,9
@@
/** \file filter_chain.c common helper functions for filter input/output */
/** \file filter_chain.c common helper functions for filter input/output */
+#include <sys/types.h>
+#include <dirent.h>
+
#include "para.h"
#include "list.h"
#include "sched.h"
#include "para.h"
#include "list.h"
#include "sched.h"
@@
-112,9
+115,10
@@
void filter_pre_select(__a_unused struct sched *s, struct task *t)
size_t *loaded;
int conv, conv_total = 0;
size_t *loaded;
int conv, conv_total = 0;
- t->ret = -E_FC_EOF;
- if (fc->output_eof && *fc->output_eof)
+ if (fc->output_error && *fc->output_error) {
+ t->ret = *fc->output_error;
goto err_out;
goto err_out;
+ }
again:
ib = fc->inbuf;
loaded = fc->in_loaded;
again:
ib = fc->inbuf;
loaded = fc->in_loaded;
@@
-150,7
+154,7
@@
again:
if (conv)
goto again;
t->ret = 1;
if (conv)
goto again;
t->ret = 1;
- if (!*fc->input_e
of
)
+ if (!*fc->input_e
rror
)
return;
if (*fc->out_loaded)
return;
return;
if (*fc->out_loaded)
return;
@@
-158,7
+162,7
@@
again:
return;
t->ret = -E_FC_EOF;
err_out:
return;
t->ret = -E_FC_EOF;
err_out:
- fc->e
of = 1
;
+ fc->e
rror = t->ret
;
}
/**
}
/**