-#if 0
-static void rn_event_handler(struct task *t)
-{
- struct receiver_node *rn = t->private_data;
- int i;
-
- PARA_NOTICE_LOG("%s\n", para_strerror(-t->ret));
- unregister_task(t);
- rn->error = t->ret;
- /* set restart barrier */
- FOR_EACH_SLOT(i) {
- struct timeval restart_delay = {0, 10 * 1000};
- if (slot[i].receiver_node != rn)
- continue;
- if (rn->error != -E_RECV_EOF)
- /* don't reconnect immediately on errors */
- restart_delay.tv_sec = 5;
- tv_add(now, &restart_delay, &afi[slot[i].format].restart_barrier);
- }
-}
-#endif
-