X-Git-Url: http://git.tuebingen.mpg.de/?p=paraslash.git;a=blobdiff_plain;f=recv.c;h=5cd64cc7e6058cd7723c9abf847f36a23c8f0a0b;hp=05f616cd021202a0a373a0bb763b77ce4c98d21d;hb=9609fd30e0d3db45ede3ab5c6bc3a77c15b6aef8;hpb=e7e55d0ad711a46e4768066be197bb41caa5c5eb diff --git a/recv.c b/recv.c index 05f616cd..5cd64cc7 100644 --- a/recv.c +++ b/recv.c @@ -60,7 +60,7 @@ static void *parse_config(int argc, char *argv[], int *receiver_num) } /** - * the main function of para_recv + * The main function of para_recv. * * \param argc number of arguments * \param argv vector of arguments @@ -92,19 +92,21 @@ int main(int argc, char *argv[]) } r = &receivers[receiver_num]; rn.receiver = r; - rn.btrn = btr_new_node("receiver", NULL, NULL, NULL); + rn.btrn = btr_new_node(&(struct btr_node_description) + EMBRACE(.name = r->name)); ret = r->open(&rn); if (ret < 0) goto out; r_opened = 1; - sot.btrn = btr_new_node("stdout", rn.btrn, NULL, NULL); + sot.btrn = btr_new_node(&(struct btr_node_description) + EMBRACE(.parent = rn.btrn, .name = "stdout")); stdout_set_defaults(&sot); register_task(&sot.task); rn.task.pre_select = r->pre_select; rn.task.post_select = r->post_select; - sprintf(rn.task.status, "receiver node"); + sprintf(rn.task.status, "%s", r->name); register_task(&rn.task); ret = schedule(&s);