Lines Matching defs:cat
79 ConcatContext *cat = ctx->priv;
85 nb_str = cat->nb_streams[type];
106 for (seg = 0; seg < cat->nb_segments; seg++) {
124 ConcatContext *cat = ctx->priv;
135 for (seg = 1; seg < cat->nb_segments; seg++) {
154 if (!cat->unsafe)
164 ConcatContext *cat = ctx->priv;
168 struct concat_in *in = &cat->in[in_no];
183 buf->pts += cat->delta_ts;
190 ConcatContext *cat = ctx->priv;
193 if (in_no < cat->cur_idx) {
197 } else if (in_no >= cat->cur_idx + ctx->nb_outputs) {
198 ff_bufqueue_add(ctx, &cat->in[in_no].queue, buf);
230 ConcatContext *cat = ctx->priv;
232 cat->in[in_no].eof = 1;
233 cat->nb_in_active--;
235 ctx->input_pads[in_no].name, cat->nb_in_active);
240 ConcatContext *cat = ctx->priv;
241 unsigned i = cat->cur_idx;
245 pts = cat->in[i++].pts;
247 pts = FFMAX(pts, cat->in[i].pts);
248 cat->delta_ts += pts;
255 ConcatContext *cat = ctx->priv;
257 int64_t base_pts = cat->in[in_no].pts + cat->delta_ts - seg_delta;
266 nb_samples = av_rescale_q(seg_delta - cat->in[in_no].pts,
289 ConcatContext *cat = ctx->priv;
294 cat->cur_idx += ctx->nb_outputs;
295 cat->nb_in_active = ctx->nb_outputs;
297 cat->delta_ts);
299 if (cat->cur_idx < ctx->nb_inputs) {
301 str = cat->nb_streams[AVMEDIA_TYPE_VIDEO];
302 str_max = str + cat->nb_streams[AVMEDIA_TYPE_AUDIO];
304 ret = send_silence(ctx, cat->cur_idx - ctx->nb_outputs + str, str,
311 str_max = cat->cur_idx + ctx->nb_outputs;
312 for (str = cat->cur_idx; str < str_max; str++) {
313 while (cat->in[str].queue.available) {
314 ret = push_frame(ctx, str, ff_bufqueue_get(&cat->in[str].queue));
326 ConcatContext *cat = ctx->priv;
328 unsigned in_no = out_no + cat->cur_idx;
335 if (!cat->in[in_no].eof) {
343 str_max = cat->cur_idx + ctx->nb_outputs - 1;
344 for (str = cat->cur_idx; cat->nb_in_active;
345 str = str == str_max ? cat->cur_idx : str + 1) {
346 if (cat->in[str].eof)
363 ConcatContext *cat = ctx->priv;
367 for (seg = 0; seg < cat->nb_segments; seg++) {
369 for (str = 0; str < cat->nb_streams[type]; str++) {
383 for (str = 0; str < cat->nb_streams[type]; str++) {
394 cat->in = av_calloc(ctx->nb_inputs, sizeof(*cat->in));
395 if (!cat->in)
397 cat->nb_in_active = ctx->nb_outputs;
403 ConcatContext *cat = ctx->priv;
408 ff_bufqueue_discard_all(&cat->in[i].queue);
412 av_free(cat->in);