--- sio_fd.c 2002/11/05 16:18:46 1.6
+++ sio_fd.c 2002/11/14 15:56:10 1.7
@@ -7,7 +7,6 @@
#include "al.h"
#include "sio.h"
-#include "sio_module.h"
typedef struct {
char *mem;
@@ -143,15 +142,15 @@
actual = read(my->fd, buf->mem, buf->size);
if (actual < 0) {
al_append_bytes(al, &my->eof, sizeof(my->eof), my->error_label);
- return SIO_DOWNSTREAM;
+ return SIO_SCHED_DOWN;
} else if (actual == 0) {
al_append_bytes(al, &my->error, sizeof(my->error), my->eof_label);
- return SIO_DOWNSTREAM;
+ return SIO_SCHED_DOWN;
}
al_append_bytes(al, buf->mem, actual, my->data_label);
- return SIO_DOWNSTREAM;
+ return SIO_SCHED_DOWN;
}
static
@@ -186,13 +185,13 @@
arc = al_traverse_cb(al, 0, n, AL_FORWARD, my->data_label,
fd_output_chunk, u);
if (arc != AL_OK)
- return SIO_DOWNSTREAM;
+ return SIO_SCHED_DOWN;
arc = al_splice(al, 0, al_bytes(al), NULL, NULL);
if (arc != AL_OK)
- return SIO_DOWNSTREAM;
+ return SIO_SCHED_DOWN;
- return SIO_DOWNSTREAM;
+ return SIO_SCHED_DOWN;
}
sio_module_t sio_module_fd = {
|
