register_task(&sit.task);
p->inbuf = sit.buf;
p->in_loaded = &sit.loaded;
- p->in_eof = &sit.eof;
+ p->in_error = &sit.error;
return;
}
stdout_set_defaults(&sot);
sot.buf = p->buf;
sot.loaded = &p->loaded;
- sot.input_eof = &p->eof;
+ sot.input_error = &p->eof;
register_task(&sot.task);
}
if (ret < 0) /* can not use PARA_LOG here */
exit(EXIT_FAILURE);
pcd->task.event_handler = client_event_handler;
- ret = sched(&s);
+ ret = schedule(&s);
if (ret < 0)
PARA_ERROR_LOG("%s\n", PARA_STRERROR(-ret));
client_close(pcd);