+ return 1;
+err:
+ PARA_ERROR_LOG("%s\n", PARA_STRERROR(-ret));
+ tv_add(now, &restart_delay, &afi[format].restart_barrier);
+ return ret;
+}
+
+static int receiver_running(int format)
+{
+ int i;
+
+ FOR_EACH_SLOT(i) {
+ struct slot_info *s = &slot[i];
+ if (s->format == format && s->receiver_node
+ && !s->receiver_node->eof)
+ return 1;
+ }
+ return 0;