1 files changed, 114 insertions, 0 deletions
diff --git a/flx/input.c b/flx/input.c
new file mode 100644
index 0000000..182fa83
--- /dev/null
+++ b/flx/input.c
@@ -0,0 +1,114 @@
+#include <string.h>
+#include "utils.h"
+#include "source_type.h"
+#include "input.h"
+#include "flx_fcntl.h"
+
+
+/* get data from current input and return the number of data readed 
+ */
+int input_read(t_db_input *in, void *tree) {
+    t_device *current;
+    int      nb = 0;
+
+    /* look for pointer initializing */
+    while (!in->eof && in->inputs) {
+	/* get current pointer to input driver */
+	current = SIMPLE_LIST_PTR(in->inputs);
+	
+	/* run read function associated with current source */
+	if (current->opened->read) {
+	    if (!(nb = current->opened->read(current->env, tree))) {
+		if (current->opened->close)
+		    current->env = current->opened->close(current->env);
+		current->opened = NULL;
+		FREE(current);
+		SIMPLE_LIST_POP(in->inputs);
+		in->eof = (in->inputs == NULL);
+	    }
+	    else {
+		return (nb);
+	    }
+	}
+    }
+    return (nb);
+}
+
+int input_add(t_db_input *in, char *src, t_source_type *sourcestype) {
+    char         tmp[BUFFER_LENGTH], *ptmp, *otmp = NULL;
+    int          sel;
+    t_device     *new;
+    
+    strcpy(tmp, src);
+    if ((ptmp = backslashed_strchr(tmp, ':'))) {
+	*ptmp++ = 0;
+	
+	/* look for options */
+	if ((otmp = strchr(tmp, '+'))) *otmp++ = 0;
+	
+	/* find corresponding source */
+	for (sel = 0; sourcestype[sel].name; sel++)
+	    if (!strcmp(tmp, sourcestype[sel].name)) break;
+	if (!sourcestype[sel].name) {
+	    /* not found, error */
+	    error("can't find source type %s (%s:%s)\n", tmp, tmp, ptmp); 
+	    return (0);
+	}
+    }
+    else {
+	sel = 0;
+	ptmp = tmp;
+    }
+    
+    /* allocate memory for new device */
+    new = MALLOC(sizeof(*new));
+    new->opened = &sourcestype[sel];
+    /* call of device initialize specific function */
+    if (new->opened->open) {
+	if (!(new->env = new->opened->open(ptmp, otmp))) {
+	    error("can't open '%s'", src);
+	    FREE(new);
+	    return (0);
+	}
+	if (new->opened->fcntl) {
+	    if (in->inputs) {
+		Sorted &= ~INPUT_SORTED;
+	    }
+	    else {
+		Sorted &=  (~INPUT_SORTED|
+			    ((new->opened->fcntl(new->env, IS_SORTED) ? INPUT_SORTED : 0))); 
+	    }
+	}
+    }
+    else
+	new->env = NULL;
+    /* add in current driver list */
+    SIMPLE_LIST_FILE(in->inputs, new);
+    in->eof = 0;
+    return (1);
+}
+
+
+inline int input_eof(t_db_input *in) {
+    return (in->eof);
+}
+
+t_db_input *input_alloc() {
+    t_db_input *in;
+
+    in = MALLOC(sizeof(t_db_input));
+    bzero(in, sizeof(t_db_input));
+    return (in);
+}
+
+t_db_input *input_free(t_db_input *old) {
+    t_device *current;
+    
+    while (old->inputs) {
+	current = SIMPLE_LIST_POP(old->inputs);
+	current->opened->close(current->env);
+	FREE(current);
+    }
+    FREE(old);
+    return (NULL);
+}