| 1235 | } |
| 1236 | |
| 1237 | static void flushStreams( sync_common_t * common ) |
| 1238 | { |
| 1239 | int ii; |
| 1240 | |
| 1241 | // Make sure all streams are complete |
| 1242 | for (ii = 0; ii < common->stream_count; ii++) |
| 1243 | { |
| 1244 | sync_stream_t * stream = &common->streams[ii]; |
| 1245 | if (!stream->done && !stream->flush) |
| 1246 | { |
| 1247 | return; |
| 1248 | } |
| 1249 | } |
| 1250 | |
| 1251 | if (!common->found_first_pts) |
| 1252 | { |
| 1253 | checkFirstPts(common); |
| 1254 | } |
| 1255 | |
| 1256 | common->flush = 1; |
| 1257 | while (OutputBuffer(common)); |
| 1258 | |
| 1259 | // Flush all streams |
| 1260 | for (ii = 0; ii < common->stream_count; ii++) |
| 1261 | { |
| 1262 | sync_stream_t * stream = &common->streams[ii]; |
| 1263 | streamFlush(stream); |
| 1264 | } |
| 1265 | } |
| 1266 | |
| 1267 | static void flushStreamsLock( sync_common_t * common ) |
| 1268 | { |
no test coverage detected