This is better handled by the wng event handler.
s->receiver_node = NULL;
set_restart_barrier(s->format, NULL);
}
-static void close_writer(int slot_num)
-{
- struct slot_info *s = &slot[slot_num];
- if (s->wng) {
- PARA_INFO_LOG("slot %d: closing writer node group\n",
- slot_num);
- wng_close(s->wng);
- s->wng = NULL;
- }
- if (s->fc)
- *s->fc->output_eof = 1; /* FIXME */
-}
-
static void kill_all_decoders(void)
{
int i;
- FOR_EACH_SLOT(i)
- close_writer(i);
+ FOR_EACH_SLOT(i) {
+ struct slot_info *s = &slot[i];
+ if (s->receiver_node)
+ s->receiver_node->eof = 1;
+ }
}
static void check_sigchld(void)