#include "error.h"
#include "stdout.h"
-struct gengetopt_args_info conf;
+struct recv_args_info conf;
INIT_RECV_ERRLISTS;
{
int i;
- if (cmdline_parser(argc, argv, &conf))
+ if (recv_cmdline_parser(argc, argv, &conf))
return NULL;
if (conf.list_receivers_given) {
printf("available receivers: ");
void rn_event_handler(struct task *t)
{
+ struct receiver_node *rn = t->private_data;
PARA_NOTICE_LOG("%s\n", PARA_STRERROR(-t->ret));
+ rn->eof = 1;
unregister_task(t);
}
struct stdout_task sot;
struct sched s;
- init_sched();
s.default_timeout.tv_sec = 1;
s.default_timeout.tv_usec = 0;
rn.task.pre_select = r->pre_select;
rn.task.post_select = r->post_select;
rn.task.event_handler = rn_event_handler;
- rn.task.flags = 0;
sprintf(rn.task.status, "receiver node");
register_task(&rn.task);