| 1222 | } |
| 1223 | |
| 1224 | static void streamFlush( sync_stream_t * stream ) |
| 1225 | { |
| 1226 | while (hb_list_count(stream->in_queue) > 0) |
| 1227 | { |
| 1228 | hb_buffer_t * buf; |
| 1229 | |
| 1230 | buf = hb_list_item(stream->in_queue, 0); |
| 1231 | hb_list_rem(stream->in_queue, buf); |
| 1232 | hb_buffer_close(&buf); |
| 1233 | } |
| 1234 | fifo_push(stream->fifo_out, hb_buffer_eof_init()); |
| 1235 | } |
| 1236 | |
| 1237 | static void flushStreams( sync_common_t * common ) |
| 1238 | { |
no test coverage detected