Make para_recv use the new scheduler.
[paraslash.git] / write.c
diff --git a/write.c b/write.c
index 3e5a97e..5bcd1f6 100644 (file)
--- a/write.c
+++ b/write.c
@@ -157,7 +157,7 @@ out:
        return NULL;
 }
 
-static void idt_error_handler(struct task *t)
+static void idt_event_handler(struct task *t)
 {
        int ret;
 
@@ -174,7 +174,7 @@ static void idt_error_handler(struct task *t)
        }
 }
 
-static void cwt_error_handler(struct task *t)
+static void cwt_event_handler(struct task *t)
 {
        if (t->ret != -E_NO_WAV_HEADER && t->ret != -E_WAV_HEADER_SUCCESS) {
                PARA_ERROR_LOG("%s\n", PARA_STRERROR(-t->ret));
@@ -188,18 +188,18 @@ static void cwt_error_handler(struct task *t)
        }
        idt.task.pre_select = initial_delay_pre_select;
        idt.task.private_data = &idt;
-       idt.task.error_handler = idt_error_handler;
+       idt.task.event_handler = idt_event_handler;
        sprintf(idt.task.status, "initial_delay");
        register_task(&idt.task);
 }
 
-static void stdin_error_handler(struct task *t)
+static void stdin_event_handler(struct task *t)
 {
        unregister_task(t);
        if (t->ret != -E_STDIN_EOF)
                PARA_ERROR_LOG("%s\n", PARA_STRERROR(-t->ret));
        else
-               PARA_ERROR_LOG("%s\n", PARA_STRERROR(-t->ret));
+               PARA_INFO_LOG("%s\n", PARA_STRERROR(-t->ret));
 }
 
 int main(int argc, char *argv[])
@@ -219,14 +219,14 @@ int main(int argc, char *argv[])
        sit.loaded = 0,
        sit.task.pre_select = stdin_pre_select;
        sit.task.post_select = stdin_post_select;
-       sit.task.error_handler = stdin_error_handler;
+       sit.task.event_handler = stdin_event_handler;
        sit.task.private_data = &sit;
        sprintf(sit.task.status, "stdin reader");
        register_task(&sit.task);
 
        cwt.task.pre_select = check_wav_pre_select;
        cwt.task.private_data = &cwt;
-       cwt.task.error_handler = cwt_error_handler;
+       cwt.task.event_handler = cwt_event_handler;
        cwt.buf = sit.buf;
        cwt.loaded = &sit.loaded;
        cwt.eof = &sit.eof;