|  | /* | 
|  | * Copyright (c) 2021, Alliance for Open Media. All rights reserved | 
|  | * | 
|  | * This source code is subject to the terms of the BSD 3-Clause Clear License | 
|  | * and the Alliance for Open Media Patent License 1.0. If the BSD 3-Clause Clear | 
|  | * License was not distributed with this source code in the LICENSE file, you | 
|  | * can obtain it at aomedia.org/license/software-license/bsd-3-c-c/.  If the | 
|  | * Alliance for Open Media Patent License 1.0 was not distributed with this | 
|  | * source code in the PATENTS file, you can obtain it at | 
|  | * aomedia.org/license/patent-license/. | 
|  | */ | 
|  |  | 
|  | #include <stdint.h> | 
|  |  | 
|  | #include "config/aom_config.h" | 
|  | #include "config/aom_scale_rtcd.h" | 
|  |  | 
|  | #include "aom/aom_codec.h" | 
|  | #include "aom/aom_encoder.h" | 
|  |  | 
|  | #include "aom_ports/system_state.h" | 
|  |  | 
|  | #if CONFIG_MISMATCH_DEBUG | 
|  | #include "aom_util/debug_util.h" | 
|  | #endif  // CONFIG_MISMATCH_DEBUG | 
|  |  | 
|  | #include "av1/common/av1_common_int.h" | 
|  | #include "av1/common/reconinter.h" | 
|  |  | 
|  | #include "av1/encoder/encoder.h" | 
|  | #include "av1/encoder/encode_strategy.h" | 
|  | #include "av1/encoder/encodeframe.h" | 
|  | #include "av1/encoder/firstpass.h" | 
|  | #include "av1/encoder/pass2_strategy.h" | 
|  | #include "av1/encoder/temporal_filter.h" | 
|  | #include "av1/encoder/tpl_model.h" | 
|  | #include "av1/encoder/encoder_utils.h" | 
|  |  | 
|  | #if CONFIG_TUNE_VMAF | 
|  | #include "av1/encoder/tune_vmaf.h" | 
|  | #endif | 
|  |  | 
|  | #define TEMPORAL_FILTER_KEY_FRAME 1 | 
|  |  | 
|  | // Get the subgop config corresponding to the current frame within the | 
|  | // gf group | 
|  | const SubGOPStepCfg *get_subgop_step(const GF_GROUP *const gf_group, | 
|  | int index) { | 
|  | const SubGOPCfg *subgop_cfg = gf_group->subgop_cfg; | 
|  | if (subgop_cfg == NULL) return NULL; | 
|  | const int is_first_gop = (gf_group->update_type[0] == KF_UPDATE); | 
|  | const int offset = | 
|  | gf_group->has_overlay_for_key_frame ? 2 : (is_first_gop ? 1 : 0); | 
|  | return &subgop_cfg->step[index - offset]; | 
|  | } | 
|  |  | 
|  | void av1_get_ref_frames_enc(AV1_COMMON *cm, int cur_frame_disp, | 
|  | RefFrameMapPair *ref_frame_map_pairs) { | 
|  | assert(cm->seq_params.explicit_ref_frame_map); | 
|  | // With explicit_ref_frame_map on, an encoder-only ranking scheme can be | 
|  | // implemented here. For now, av1_get_ref_frames is used as a placeholder. | 
|  | av1_get_ref_frames(cm, cur_frame_disp, ref_frame_map_pairs); | 
|  | } | 
|  |  | 
|  | void av1_configure_buffer_updates(AV1_COMP *const cpi, | 
|  | const FRAME_UPDATE_TYPE type) { | 
|  | // NOTE(weitinglin): Should we define another function to take care of | 
|  | // cpi->rc.is_$Source_Type to make this function as it is in the comment? | 
|  |  | 
|  | cpi->rc.is_src_frame_alt_ref = 0; | 
|  |  | 
|  | switch (type) { | 
|  | case OVERLAY_UPDATE: | 
|  | case KFFLT_OVERLAY_UPDATE: | 
|  | case INTNL_OVERLAY_UPDATE: cpi->rc.is_src_frame_alt_ref = 1; break; | 
|  |  | 
|  | case KF_UPDATE: | 
|  | case LF_UPDATE: | 
|  | case GF_UPDATE: | 
|  | case ARF_UPDATE: | 
|  | case KFFLT_UPDATE: | 
|  | case INTNL_ARF_UPDATE: break; | 
|  |  | 
|  | default: assert(0); break; | 
|  | } | 
|  | } | 
|  |  | 
|  | static void set_additional_frame_flags(const AV1_COMMON *const cm, | 
|  | unsigned int *const frame_flags) { | 
|  | if (frame_is_intra_only(cm)) { | 
|  | *frame_flags |= FRAMEFLAGS_INTRAONLY; | 
|  | } | 
|  | if (frame_is_sframe(cm)) { | 
|  | *frame_flags |= FRAMEFLAGS_SWITCH; | 
|  | } | 
|  | if (cm->features.error_resilient_mode) { | 
|  | *frame_flags |= FRAMEFLAGS_ERROR_RESILIENT; | 
|  | } | 
|  | if (cm->film_grain_params.apply_grain) { | 
|  | *frame_flags |= FRAMEFLAGS_HAS_FILM_GRAIN_PARAMS; | 
|  | } | 
|  | } | 
|  |  | 
|  | static INLINE void update_keyframe_counters(AV1_COMP *cpi) { | 
|  | if (cpi->common.show_frame) { | 
|  | cpi->rc.frames_since_key++; | 
|  | cpi->rc.frames_to_key--; | 
|  | } | 
|  | } | 
|  |  | 
|  | static INLINE int is_frame_droppable( | 
|  | const ExtRefreshFrameFlagsInfo *const ext_refresh_frame_flags) { | 
|  | // Droppable frame is only used by external refresh flags. VoD setting won't | 
|  | // trigger its use case. | 
|  | if (ext_refresh_frame_flags->update_pending) | 
|  | return ext_refresh_frame_flags->all_ref_frames == 0; | 
|  | else | 
|  | return 0; | 
|  | } | 
|  |  | 
|  | static INLINE void update_frames_till_gf_update(AV1_COMP *cpi) { | 
|  | // TODO(weitinglin): Updating this counter for is_frame_droppable | 
|  | // is a work-around to handle the condition when a frame is drop. | 
|  | // We should fix the cpi->common.show_frame flag | 
|  | // instead of checking the other condition to update the counter properly. | 
|  | if (cpi->common.show_frame || | 
|  | is_frame_droppable(&cpi->ext_flags.refresh_frame)) { | 
|  | // Decrement count down till next gf | 
|  | if (cpi->rc.frames_till_gf_update_due > 0) | 
|  | cpi->rc.frames_till_gf_update_due--; | 
|  | } | 
|  | } | 
|  |  | 
|  | static INLINE void update_gf_group_index(AV1_COMP *cpi) { | 
|  | // Increment the gf group index ready for the next frame. If this is | 
|  | // a show_existing_frame with a source other than altref, or if it is not | 
|  | // a displayed forward keyframe, the index was incremented when it was | 
|  | // originally encoded. | 
|  | if (!cpi->common.show_existing_frame || cpi->rc.is_src_frame_alt_ref || | 
|  | cpi->common.current_frame.frame_type == KEY_FRAME) { | 
|  | ++cpi->gf_group.index; | 
|  | } | 
|  | } | 
|  |  | 
|  | // Update show_existing_frame flag for frames of type OVERLAY_UPDATE in the | 
|  | // current GF interval | 
|  | static INLINE void set_show_existing_alt_ref(GF_GROUP *const gf_group, | 
|  | int apply_filtering, | 
|  | int enable_overlay, | 
|  | int show_existing_alt_ref) { | 
|  | if (get_frame_update_type(gf_group) != ARF_UPDATE && | 
|  | get_frame_update_type(gf_group) != KFFLT_UPDATE) | 
|  | return; | 
|  | if (!enable_overlay) | 
|  | gf_group->show_existing_alt_ref = 1; | 
|  | else | 
|  | gf_group->show_existing_alt_ref = | 
|  | apply_filtering ? show_existing_alt_ref : 1; | 
|  | } | 
|  |  | 
|  | static void update_rc_counts(AV1_COMP *cpi) { | 
|  | update_keyframe_counters(cpi); | 
|  | update_frames_till_gf_update(cpi); | 
|  | update_gf_group_index(cpi); | 
|  | } | 
|  |  | 
|  | static void set_ext_overrides(AV1_COMMON *const cm, | 
|  | EncodeFrameParams *const frame_params, | 
|  | ExternalFlags *const ext_flags) { | 
|  | // Overrides the defaults with the externally supplied values with | 
|  | // av1_update_reference() and av1_update_entropy() calls | 
|  | // Note: The overrides are valid only for the next frame passed | 
|  | // to av1_encode_lowlevel() | 
|  |  | 
|  | if (ext_flags->use_s_frame) { | 
|  | frame_params->frame_type = S_FRAME; | 
|  | } | 
|  |  | 
|  | if (ext_flags->refresh_frame_context_pending) { | 
|  | cm->features.refresh_frame_context = ext_flags->refresh_frame_context; | 
|  | ext_flags->refresh_frame_context_pending = 0; | 
|  | } | 
|  | cm->features.allow_ref_frame_mvs = ext_flags->use_ref_frame_mvs; | 
|  |  | 
|  | frame_params->error_resilient_mode = ext_flags->use_error_resilient; | 
|  | // A keyframe is already error resilient and keyframes with | 
|  | // error_resilient_mode interferes with the use of show_existing_frame | 
|  | // when forward reference keyframes are enabled. | 
|  | frame_params->error_resilient_mode &= frame_params->frame_type != KEY_FRAME; | 
|  | // For bitstream conformance, s-frames must be error-resilient | 
|  | frame_params->error_resilient_mode |= frame_params->frame_type == S_FRAME; | 
|  | } | 
|  |  | 
|  | #if !CONFIG_PRIMARY_REF_FRAME_OPT | 
|  | static int get_current_frame_ref_type( | 
|  | const AV1_COMP *const cpi, const EncodeFrameParams *const frame_params) { | 
|  | // We choose the reference "type" of this frame from the flags which indicate | 
|  | // which reference frames will be refreshed by it.  More than one  of these | 
|  | // flags may be set, so the order here implies an order of precedence. This is | 
|  | // just used to choose the primary_ref_frame (as the most recent reference | 
|  | // buffer of the same reference-type as the current frame) | 
|  |  | 
|  | (void)frame_params; | 
|  | // TODO(jingning): This table should be a lot simpler with the new | 
|  | // ARF system in place. Keep frame_params for the time being as we are | 
|  | // still evaluating a few design options. | 
|  | switch (cpi->gf_group.layer_depth[cpi->gf_group.index]) { | 
|  | case 0: return 0; | 
|  | case 1: return 1; | 
|  | case MAX_ARF_LAYERS: | 
|  | case MAX_ARF_LAYERS + 1: return 4; | 
|  | default: return 7; | 
|  | } | 
|  | } | 
|  |  | 
|  | static int choose_primary_ref_frame( | 
|  | const AV1_COMP *const cpi, const EncodeFrameParams *const frame_params) { | 
|  | const AV1_COMMON *const cm = &cpi->common; | 
|  |  | 
|  | const int intra_only = frame_params->frame_type == KEY_FRAME || | 
|  | frame_params->frame_type == INTRA_ONLY_FRAME; | 
|  | if (intra_only || frame_params->error_resilient_mode || | 
|  | cpi->ext_flags.use_primary_ref_none) { | 
|  | return PRIMARY_REF_NONE; | 
|  | } | 
|  |  | 
|  | // In large scale case, always use Last frame's frame contexts. | 
|  | // Note(yunqing): In other cases, primary_ref_frame is chosen based on | 
|  | // cpi->gf_group.layer_depth[cpi->gf_group.index], which also controls | 
|  | // frame bit allocation. | 
|  | if (cm->tiles.large_scale) return 0; | 
|  |  | 
|  | // Find the most recent reference frame with the same reference type as the | 
|  | // current frame | 
|  | const int current_ref_type = get_current_frame_ref_type(cpi, frame_params); | 
|  | int wanted_fb = cpi->fb_of_context_type[current_ref_type]; | 
|  |  | 
|  | int primary_ref_frame = PRIMARY_REF_NONE; | 
|  | const int n_refs = cm->ref_frames_info.num_total_refs; | 
|  | for (int ref_frame = 0; ref_frame < n_refs; ref_frame++) { | 
|  | if (get_ref_frame_map_idx(cm, ref_frame) == wanted_fb) { | 
|  | primary_ref_frame = ref_frame; | 
|  | } | 
|  | } | 
|  |  | 
|  | return primary_ref_frame; | 
|  | } | 
|  | #endif  // !CONFIG_PRIMARY_REF_FRAME_OPT | 
|  |  | 
|  | // Map the subgop cfg reference list to actual reference buffers. Disable | 
|  | // any reference frames that are not listed in the sub gop. | 
|  | static void get_gop_cfg_enabled_refs(AV1_COMP *const cpi, int *ref_frame_flags, | 
|  | int order_offset) { | 
|  | GF_GROUP gf_group = cpi->gf_group; | 
|  | // The current display index stored has not yet been updated. We must add | 
|  | // The order offset to get the correct value here. | 
|  | const int cur_frame_disp = | 
|  | cpi->common.current_frame.frame_number + order_offset; | 
|  |  | 
|  | const SubGOPStepCfg *step_gop_cfg = | 
|  | get_subgop_step(&gf_group, gf_group.index); | 
|  | assert(step_gop_cfg != NULL); | 
|  | // No references specified | 
|  | if (step_gop_cfg->num_references < 0) return; | 
|  |  | 
|  | // Mask to indicate whether or not each ref is allowed by the GOP config | 
|  | int ref_frame_used[INTER_REFS_PER_FRAME] = { 0 }; | 
|  | // Structures to hash each reference frame based on its pyramid level. This | 
|  | // will allow us to match the pyramid levels specified in the cfg to the best | 
|  | // reference frame index. | 
|  | int n_references[MAX_ARF_LAYERS + 1] = { 0 }; | 
|  | int references[MAX_ARF_LAYERS + 1][INTER_REFS_PER_FRAME] = { { 0 } }; | 
|  | int disp_orders[MAX_ARF_LAYERS + 1][INTER_REFS_PER_FRAME] = { { 0 } }; | 
|  |  | 
|  | int frame_level = -1; | 
|  | // Loop over each reference frame and hash it based on its pyramid level | 
|  | for (int frame = 0; frame < INTER_REFS_PER_FRAME; frame++) { | 
|  | // Get reference frame buffer | 
|  | const RefCntBuffer *const buf = get_ref_frame_buf(&cpi->common, frame); | 
|  | if (buf == NULL) continue; | 
|  | const int frame_order = (int)buf->display_order_hint; | 
|  | frame_level = buf->pyramid_level; | 
|  |  | 
|  | // Sometimes a frame index is in multiple reference buffers. | 
|  | // Do not add a frame to the pyramid list multiple times. | 
|  | int found = 0; | 
|  | for (int r = 0; r < n_references[frame_level]; r++) { | 
|  | if (frame_order == disp_orders[frame_level][r]) { | 
|  | found = 1; | 
|  | break; | 
|  | } | 
|  | } | 
|  | // If this is an unseen frame, map its display order and ref buffer | 
|  | // index to its level in the pyramid | 
|  | if (!found) { | 
|  | int n_refs = n_references[frame_level]++; | 
|  | disp_orders[frame_level][n_refs] = frame_order; | 
|  | references[frame_level][n_refs] = frame; | 
|  | } | 
|  | } | 
|  |  | 
|  | // For each reference specified in the step_gop_cfg, map it to a reference | 
|  | // buffer based on pyramid level if possible. | 
|  | for (int i = 0; i < step_gop_cfg->num_references; i++) { | 
|  | const int level = step_gop_cfg->references[i]; | 
|  | const int abs_level = abs(level); | 
|  | int best_frame = -1; | 
|  | int best_frame_index = -1; | 
|  | int best_disp_order = INT_MAX; | 
|  | for (int ref = 0; ref < n_references[abs_level]; ref++) { | 
|  | const int disp_order = disp_orders[abs_level][ref]; | 
|  | const int cur_order_diff = cur_frame_disp - disp_order; | 
|  | // This frame has already been used | 
|  | if (disp_order < 0) continue; | 
|  | // This frame is in the wrong direction | 
|  | if ((cur_order_diff < 0) != (level < 0)) continue; | 
|  | // Store this frame if it is the closest in display order to the current | 
|  | // frame so far | 
|  | if (abs(cur_order_diff) < abs(best_disp_order - cur_frame_disp)) { | 
|  | best_frame = references[abs_level][ref]; | 
|  | best_frame_index = ref; | 
|  | best_disp_order = disp_order; | 
|  | } | 
|  | } | 
|  | update_subgop_ref_stats(&cpi->subgop_stats, | 
|  | cpi->oxcf.unit_test_cfg.enable_subgop_stats, i, | 
|  | (best_frame < 0) ? 0 : 1, level, best_disp_order, | 
|  | (int)step_gop_cfg->num_references); | 
|  | if (best_frame == -1) { | 
|  | if (cpi->print_per_frame_stats) { | 
|  | fprintf(stderr, | 
|  | "Warning [Subgop cfg]: " | 
|  | "Level %d ref for frame %d not found\n", | 
|  | level, step_gop_cfg->disp_frame_idx); | 
|  | } | 
|  | } else { | 
|  | ref_frame_used[best_frame] = 1; | 
|  | disp_orders[abs_level][best_frame_index] = -1; | 
|  | } | 
|  | } | 
|  |  | 
|  | // Avoid using references that were not specified by the cfg | 
|  | for (int frame = 0; frame < INTER_REFS_PER_FRAME; frame++) | 
|  | if (!ref_frame_used[frame]) *ref_frame_flags &= ~(1 << (frame)); | 
|  | } | 
|  |  | 
|  | #if !CONFIG_PRIMARY_REF_FRAME_OPT | 
|  | static void update_fb_of_context_type( | 
|  | const AV1_COMP *const cpi, const EncodeFrameParams *const frame_params, | 
|  | int *const fb_of_context_type) { | 
|  | const AV1_COMMON *const cm = &cpi->common; | 
|  | const int current_frame_ref_type = | 
|  | get_current_frame_ref_type(cpi, frame_params); | 
|  |  | 
|  | const int golden_frame = cm->ref_frames_info.past_refs[0]; | 
|  | const int altref_frame = get_furthest_future_ref_index(cm); | 
|  | if (frame_is_intra_only(cm) || cm->features.error_resilient_mode || | 
|  | cpi->ext_flags.use_primary_ref_none) { | 
|  | for (int i = 0; i < REF_FRAMES; i++) { | 
|  | fb_of_context_type[i] = -1; | 
|  | } | 
|  | fb_of_context_type[current_frame_ref_type] = | 
|  | cm->show_frame ? get_ref_frame_map_idx(cm, golden_frame) | 
|  | : get_ref_frame_map_idx(cm, altref_frame); | 
|  | } | 
|  |  | 
|  | if (!encode_show_existing_frame(cm)) { | 
|  | // Refresh fb_of_context_type[]: see encoder.h for explanation | 
|  | if (cm->current_frame.frame_type == KEY_FRAME) { | 
|  | // All ref frames are refreshed, pick one that will live long enough | 
|  | fb_of_context_type[current_frame_ref_type] = 0; | 
|  | } else { | 
|  | // If more than one frame is refreshed, it doesn't matter which one we | 
|  | // pick so pick the first.  LST sometimes doesn't refresh any: this is ok | 
|  |  | 
|  | for (int i = 0; i < REF_FRAMES; i++) { | 
|  | if (cm->current_frame.refresh_frame_flags & (1 << i)) { | 
|  | fb_of_context_type[current_frame_ref_type] = i; | 
|  | break; | 
|  | } | 
|  | } | 
|  | } | 
|  | } | 
|  | } | 
|  | #endif  // !CONFIG_PRIMARY_REF_FRAME_OPT | 
|  |  | 
|  | static void adjust_frame_rate(AV1_COMP *cpi, int64_t ts_start, int64_t ts_end) { | 
|  | TimeStamps *time_stamps = &cpi->time_stamps; | 
|  | int64_t this_duration; | 
|  | int step = 0; | 
|  |  | 
|  | // Clear down mmx registers | 
|  | aom_clear_system_state(); | 
|  |  | 
|  | if (ts_start == time_stamps->first_ever) { | 
|  | this_duration = ts_end - ts_start; | 
|  | step = 1; | 
|  | } else { | 
|  | int64_t last_duration = | 
|  | time_stamps->prev_end_seen - time_stamps->prev_start_seen; | 
|  |  | 
|  | this_duration = ts_end - time_stamps->prev_end_seen; | 
|  |  | 
|  | // do a step update if the duration changes by 10% | 
|  | if (last_duration) | 
|  | step = (int)((this_duration - last_duration) * 10 / last_duration); | 
|  | } | 
|  |  | 
|  | if (this_duration) { | 
|  | if (step) { | 
|  | av1_new_framerate(cpi, 10000000.0 / this_duration); | 
|  | } else { | 
|  | // Average this frame's rate into the last second's average | 
|  | // frame rate. If we haven't seen 1 second yet, then average | 
|  | // over the whole interval seen. | 
|  | const double interval = | 
|  | AOMMIN((double)(ts_end - time_stamps->first_ever), 10000000.0); | 
|  | double avg_duration = 10000000.0 / cpi->framerate; | 
|  | avg_duration *= (interval - avg_duration + this_duration); | 
|  | avg_duration /= interval; | 
|  |  | 
|  | av1_new_framerate(cpi, 10000000.0 / avg_duration); | 
|  | } | 
|  | } | 
|  | time_stamps->prev_start_seen = ts_start; | 
|  | time_stamps->prev_end_seen = ts_end; | 
|  | } | 
|  |  | 
|  | // Determine whether there is a forced keyframe pending in the lookahead buffer | 
|  | int get_forced_keyframe_position(struct lookahead_ctx *lookahead, | 
|  | const int up_to_index, | 
|  | const COMPRESSOR_STAGE compressor_stage) { | 
|  | /* If the forced kf is not available or if the current frame is | 
|  | * forced kf, then return -1. Else return the position of the | 
|  | * forced kf. | 
|  | */ | 
|  | for (int i = 0; i <= up_to_index; i++) { | 
|  | const struct lookahead_entry *e = | 
|  | av1_lookahead_peek(lookahead, i, compressor_stage); | 
|  | if (e == NULL) { | 
|  | // We have reached the end of the lookahead buffer and not early-returned | 
|  | // so there isn't a forced key-frame pending. | 
|  | return -1; | 
|  | } else if (e->flags == AOM_EFLAG_FORCE_KF) { | 
|  | return (i > 0) ? i : -1; | 
|  | } else { | 
|  | continue; | 
|  | } | 
|  | } | 
|  | return -1;  // Never reached | 
|  | } | 
|  |  | 
|  | // Check if we should encode an ARF or internal ARF.  If not, try a LAST | 
|  | // Do some setup associated with the chosen source | 
|  | // temporal_filtered, flush, and frame_update_type are outputs. | 
|  | // Return the frame source, or NULL if we couldn't find one | 
|  | static struct lookahead_entry *choose_frame_source( | 
|  | AV1_COMP *const cpi, int *const flush, struct lookahead_entry **last_source, | 
|  | EncodeFrameParams *const frame_params) { | 
|  | AV1_COMMON *const cm = &cpi->common; | 
|  | const GF_GROUP *const gf_group = &cpi->gf_group; | 
|  | struct lookahead_entry *source = NULL; | 
|  |  | 
|  | // Source index in lookahead buffer. | 
|  | int src_index = gf_group->arf_src_offset[gf_group->index]; | 
|  |  | 
|  | // TODO(Aasaipriya): Forced key frames need to be fixed when rc_mode != AOM_Q | 
|  | if (src_index && | 
|  | (get_forced_keyframe_position(cpi->lookahead, src_index, | 
|  | cpi->compressor_stage) != -1) && | 
|  | cpi->oxcf.rc_cfg.mode != AOM_Q) { | 
|  | src_index = 0; | 
|  | *flush = 1; | 
|  | } | 
|  |  | 
|  | // If the current frame is arf, then we should not pop from the lookahead | 
|  | // buffer. If the current frame is not arf, then pop it. This assumes the | 
|  | // first frame in the GF group is not arf. May need to change if it is not | 
|  | // true. | 
|  | int pop_lookahead = (src_index == 0); | 
|  | // If this is a key frame and keyframe filtering is enabled with overlay, | 
|  | // then do not pop. | 
|  | if (pop_lookahead && cpi->oxcf.kf_cfg.enable_keyframe_filtering > 1 && | 
|  | cpi->rc.frames_to_key == 0 && cpi->rc.frames_till_gf_update_due == 0 && | 
|  | !is_stat_generation_stage(cpi) && cpi->lookahead) { | 
|  | if (cpi->lookahead->read_ctxs[cpi->compressor_stage].sz && | 
|  | (*flush || | 
|  | cpi->lookahead->read_ctxs[cpi->compressor_stage].sz == | 
|  | cpi->lookahead->read_ctxs[cpi->compressor_stage].pop_sz)) { | 
|  | pop_lookahead = 0; | 
|  | } | 
|  | } | 
|  | frame_params->show_frame = pop_lookahead; | 
|  | if (pop_lookahead) { | 
|  | // show frame, pop from buffer | 
|  | // Get last frame source. | 
|  | if (cm->current_frame.frame_number > 0) { | 
|  | *last_source = | 
|  | av1_lookahead_peek(cpi->lookahead, -1, cpi->compressor_stage); | 
|  | } | 
|  | // Read in the source frame. | 
|  | source = av1_lookahead_pop(cpi->lookahead, *flush, cpi->compressor_stage); | 
|  | } else { | 
|  | // no show frames are arf frames | 
|  | source = | 
|  | av1_lookahead_peek(cpi->lookahead, src_index, cpi->compressor_stage); | 
|  | if (source != NULL) { | 
|  | cm->showable_frame = 1; | 
|  | } | 
|  | } | 
|  | return source; | 
|  | } | 
|  |  | 
|  | // Don't allow a show_existing_frame to coincide with an error resilient or | 
|  | // S-Frame. An exception can be made in the case of a keyframe, since it does | 
|  | // not depend on any previous frames. | 
|  | static int allow_show_existing(const AV1_COMP *const cpi, | 
|  | unsigned int frame_flags) { | 
|  | if (cpi->common.current_frame.frame_number == 0) return 0; | 
|  |  | 
|  | const struct lookahead_entry *lookahead_src = | 
|  | av1_lookahead_peek(cpi->lookahead, 0, cpi->compressor_stage); | 
|  | if (lookahead_src == NULL) return 1; | 
|  |  | 
|  | const int is_error_resilient = | 
|  | cpi->oxcf.tool_cfg.error_resilient_mode || | 
|  | (lookahead_src->flags & AOM_EFLAG_ERROR_RESILIENT); | 
|  | const int is_s_frame = cpi->oxcf.kf_cfg.enable_sframe || | 
|  | (lookahead_src->flags & AOM_EFLAG_SET_S_FRAME); | 
|  | const int is_key_frame = | 
|  | (cpi->rc.frames_to_key == 0) || (frame_flags & FRAMEFLAGS_KEY); | 
|  | return !(is_error_resilient || is_s_frame) || is_key_frame; | 
|  | } | 
|  |  | 
|  | // Update frame_flags to tell the encoder's caller what sort of frame was | 
|  | // encoded. | 
|  | static void update_frame_flags(const AV1_COMMON *const cm, | 
|  | unsigned int *frame_flags) { | 
|  | if (encode_show_existing_frame(cm)) { | 
|  | *frame_flags &= ~FRAMEFLAGS_KEY; | 
|  | return; | 
|  | } | 
|  |  | 
|  | if (cm->current_frame.frame_type == KEY_FRAME) { | 
|  | *frame_flags |= FRAMEFLAGS_KEY; | 
|  | } else { | 
|  | *frame_flags &= ~FRAMEFLAGS_KEY; | 
|  | } | 
|  | } | 
|  |  | 
|  | #define DUMP_REF_FRAME_IMAGES 0 | 
|  |  | 
|  | #if DUMP_REF_FRAME_IMAGES == 1 | 
|  | static int dump_one_image(AV1_COMMON *cm, | 
|  | const YV12_BUFFER_CONFIG *const ref_buf, | 
|  | char *file_name) { | 
|  | int h; | 
|  | FILE *f_ref = NULL; | 
|  |  | 
|  | if (ref_buf == NULL) { | 
|  | printf("Frame data buffer is NULL.\n"); | 
|  | return AOM_CODEC_MEM_ERROR; | 
|  | } | 
|  |  | 
|  | if ((f_ref = fopen(file_name, "wb")) == NULL) { | 
|  | printf("Unable to open file %s to write.\n", file_name); | 
|  | return AOM_CODEC_MEM_ERROR; | 
|  | } | 
|  |  | 
|  | // --- Y --- | 
|  | for (h = 0; h < cm->height; ++h) { | 
|  | fwrite(&ref_buf->y_buffer[h * ref_buf->y_stride], 1, cm->width, f_ref); | 
|  | } | 
|  | // --- U --- | 
|  | for (h = 0; h < (cm->height >> 1); ++h) { | 
|  | fwrite(&ref_buf->u_buffer[h * ref_buf->uv_stride], 1, (cm->width >> 1), | 
|  | f_ref); | 
|  | } | 
|  | // --- V --- | 
|  | for (h = 0; h < (cm->height >> 1); ++h) { | 
|  | fwrite(&ref_buf->v_buffer[h * ref_buf->uv_stride], 1, (cm->width >> 1), | 
|  | f_ref); | 
|  | } | 
|  |  | 
|  | fclose(f_ref); | 
|  |  | 
|  | return AOM_CODEC_OK; | 
|  | } | 
|  |  | 
|  | static void dump_ref_frame_images(AV1_COMP *cpi) { | 
|  | AV1_COMMON *const cm = &cpi->common; | 
|  | MV_REFERENCE_FRAME ref_frame; | 
|  |  | 
|  | for (ref_frame = LAST_FRAME; ref_frame <= ALTREF_FRAME; ++ref_frame) { | 
|  | char file_name[256] = ""; | 
|  | snprintf(file_name, sizeof(file_name), "/tmp/enc_F%d_ref_%d.yuv", | 
|  | cm->current_frame.frame_number, ref_frame); | 
|  | dump_one_image(cm, get_ref_frame_yv12_buf(cpi, ref_frame), file_name); | 
|  | } | 
|  | } | 
|  | #endif  // DUMP_REF_FRAME_IMAGES == 1 | 
|  |  | 
|  | int av1_get_refresh_ref_frame_map(AV1_COMMON *cm, int refresh_frame_flags) { | 
|  | (void)cm; | 
|  | int ref_map_index = INVALID_IDX; | 
|  |  | 
|  | for (ref_map_index = 0; ref_map_index < REF_FRAMES; ++ref_map_index) { | 
|  | if ((refresh_frame_flags >> ref_map_index) & 1) break; | 
|  | } | 
|  |  | 
|  | return ref_map_index; | 
|  | } | 
|  |  | 
|  | int use_subgop_cfg(const GF_GROUP *const gf_group, int gf_index) { | 
|  | if (gf_index < 0) return 0; | 
|  | if (gf_group->subgop_cfg == NULL) return 0; | 
|  | if (gf_index == 1) return !gf_group->has_overlay_for_key_frame; | 
|  | return 1; | 
|  | } | 
|  |  | 
|  | static int get_free_ref_map_index(RefFrameMapPair ref_map_pairs[REF_FRAMES]) { | 
|  | for (int idx = 0; idx < REF_FRAMES; ++idx) | 
|  | if (ref_map_pairs[idx].disp_order == -1) return idx; | 
|  | return INVALID_IDX; | 
|  | } | 
|  |  | 
|  | static int get_refresh_idx(int update_arf, int refresh_level, | 
|  | int cur_frame_disp, | 
|  | RefFrameMapPair ref_frame_map_pairs[REF_FRAMES]) { | 
|  | int arf_count = 0; | 
|  | int oldest_arf_order = INT32_MAX; | 
|  | int oldest_arf_idx = -1; | 
|  |  | 
|  | int oldest_frame_order = INT32_MAX; | 
|  | int oldest_idx = -1; | 
|  |  | 
|  | int oldest_ref_level_order = INT32_MAX; | 
|  | int oldest_ref_level_idx = -1; | 
|  |  | 
|  | for (int map_idx = 0; map_idx < REF_FRAMES; map_idx++) { | 
|  | RefFrameMapPair ref_pair = ref_frame_map_pairs[map_idx]; | 
|  | if (ref_pair.disp_order == -1) continue; | 
|  | const int frame_order = ref_pair.disp_order; | 
|  | const int reference_frame_level = ref_pair.pyr_level; | 
|  | // Keep future frames and three closest previous frames in output order | 
|  | if (frame_order > cur_frame_disp - 3) continue; | 
|  |  | 
|  | // Keep track of the oldest reference frame matching the specified | 
|  | // refresh level from the subgop cfg | 
|  | if (refresh_level > 0 && refresh_level == reference_frame_level) { | 
|  | if (frame_order < oldest_ref_level_order) { | 
|  | oldest_ref_level_order = frame_order; | 
|  | oldest_ref_level_idx = map_idx; | 
|  | } | 
|  | } | 
|  |  | 
|  | // Keep track of the oldest level 1 frame if the current frame is level also | 
|  | // 1 | 
|  | if (reference_frame_level == 1) { | 
|  | // If there are more than 2 level 1 frames in the reference list, | 
|  | // discard the oldest | 
|  | if (frame_order < oldest_arf_order) { | 
|  | oldest_arf_order = frame_order; | 
|  | oldest_arf_idx = map_idx; | 
|  | } | 
|  | arf_count++; | 
|  | continue; | 
|  | } | 
|  |  | 
|  | // Update the overall oldest reference frame | 
|  | if (frame_order < oldest_frame_order) { | 
|  | oldest_frame_order = frame_order; | 
|  | oldest_idx = map_idx; | 
|  | } | 
|  | } | 
|  | if (oldest_ref_level_idx > -1) return oldest_ref_level_idx; | 
|  | if (update_arf && arf_count > 2) return oldest_arf_idx; | 
|  | if (oldest_idx >= 0) return oldest_idx; | 
|  | if (oldest_arf_idx >= 0) return oldest_arf_idx; | 
|  | assert(0 && "No valid refresh index found"); | 
|  | return -1; | 
|  | } | 
|  |  | 
|  | static int get_refresh_frame_flags_subgop_cfg( | 
|  | const AV1_COMP *const cpi, int gf_index, int cur_disp_order, | 
|  | RefFrameMapPair ref_frame_map_pairs[REF_FRAMES], int refresh_mask, | 
|  | int free_fb_index) { | 
|  | const SubGOPStepCfg *step_gop_cfg = get_subgop_step(&cpi->gf_group, gf_index); | 
|  | assert(step_gop_cfg != NULL); | 
|  | const int pyr_level = step_gop_cfg->pyr_level; | 
|  | const FRAME_TYPE_CODE type_code = step_gop_cfg->type_code; | 
|  | const int refresh_level = step_gop_cfg->refresh; | 
|  | if (refresh_level == 0) return 0; | 
|  |  | 
|  | // No refresh necessary for these frame types | 
|  | if (type_code == FRAME_TYPE_INO_REPEAT || | 
|  | type_code == FRAME_TYPE_INO_SHOWEXISTING) | 
|  | return refresh_mask; | 
|  | // If there is an open slot, refresh that one instead of replacing a reference | 
|  | if (free_fb_index != INVALID_IDX) { | 
|  | refresh_mask = 1 << free_fb_index; | 
|  | return refresh_mask; | 
|  | } | 
|  |  | 
|  | const int update_arf = type_code == FRAME_TYPE_OOO_FILTERED && pyr_level == 1; | 
|  | const int refresh_idx = get_refresh_idx(update_arf, refresh_level, | 
|  | cur_disp_order, ref_frame_map_pairs); | 
|  | return 1 << refresh_idx; | 
|  | } | 
|  |  | 
|  | int av1_get_refresh_frame_flags( | 
|  | const AV1_COMP *const cpi, const EncodeFrameParams *const frame_params, | 
|  | FRAME_UPDATE_TYPE frame_update_type, int gf_index, int cur_disp_order, | 
|  | RefFrameMapPair ref_frame_map_pairs[REF_FRAMES]) { | 
|  | // Switch frames and shown key-frames overwrite all reference slots | 
|  | if ((frame_params->frame_type == KEY_FRAME && !cpi->no_show_fwd_kf) || | 
|  | frame_params->frame_type == S_FRAME) { | 
|  | return REFRESH_FRAME_ALL; | 
|  | } | 
|  |  | 
|  | // show_existing_frames don't actually send refresh_frame_flags so set the | 
|  | // flags to 0 to keep things consistent. | 
|  | if (frame_params->show_existing_frame && | 
|  | (!frame_params->error_resilient_mode || | 
|  | frame_params->frame_type == KEY_FRAME)) { | 
|  | return 0; | 
|  | } | 
|  |  | 
|  | int refresh_mask = 0; | 
|  | const ExtRefreshFrameFlagsInfo *const ext_refresh_frame_flags = | 
|  | &cpi->ext_flags.refresh_frame; | 
|  |  | 
|  | if (is_frame_droppable(ext_refresh_frame_flags)) return 0; | 
|  |  | 
|  | if (ext_refresh_frame_flags->update_pending) { | 
|  | return refresh_mask; | 
|  | } | 
|  |  | 
|  | // Search for the open slot to store the current frame. | 
|  | int free_fb_index = get_free_ref_map_index(ref_frame_map_pairs); | 
|  |  | 
|  | if (use_subgop_cfg(&cpi->gf_group, gf_index)) { | 
|  | const int mask = get_refresh_frame_flags_subgop_cfg( | 
|  | cpi, gf_index, cur_disp_order, ref_frame_map_pairs, refresh_mask, | 
|  | free_fb_index); | 
|  | return mask; | 
|  | } | 
|  |  | 
|  | // No refresh necessary for these frame types | 
|  | if (frame_update_type == OVERLAY_UPDATE || | 
|  | frame_update_type == KFFLT_OVERLAY_UPDATE || | 
|  | frame_update_type == INTNL_OVERLAY_UPDATE) { | 
|  | return refresh_mask; | 
|  | } | 
|  |  | 
|  | // If there is an open slot, refresh that one instead of replacing a reference | 
|  | if (free_fb_index != INVALID_IDX) { | 
|  | return 1 << free_fb_index; | 
|  | } | 
|  |  | 
|  | const int update_arf = frame_update_type == ARF_UPDATE; | 
|  | const int refresh_idx = | 
|  | get_refresh_idx(update_arf, -1, cur_disp_order, ref_frame_map_pairs); | 
|  | return 1 << refresh_idx; | 
|  | } | 
|  |  | 
|  | void setup_mi(AV1_COMP *const cpi, YV12_BUFFER_CONFIG *src) { | 
|  | AV1_COMMON *const cm = &cpi->common; | 
|  | const int num_planes = av1_num_planes(cm); | 
|  | MACROBLOCK *const x = &cpi->td.mb; | 
|  | MACROBLOCKD *const xd = &x->e_mbd; | 
|  |  | 
|  | av1_setup_src_planes(x, src, 0, 0, num_planes, NULL); | 
|  |  | 
|  | av1_setup_block_planes(xd, cm->seq_params.subsampling_x, | 
|  | cm->seq_params.subsampling_y, num_planes); | 
|  |  | 
|  | set_mi_offsets(&cm->mi_params, xd, 0, 0 | 
|  | #if CONFIG_C071_SUBBLK_WARPMV | 
|  | , | 
|  | 0, 0 | 
|  | #endif  // CONFIG_C071_SUBBLK_WARPMV | 
|  | ); | 
|  | } | 
|  |  | 
|  | // Apply temporal filtering to source frames and encode the filtered frame. | 
|  | // If the current frame does not require filtering, this function is identical | 
|  | // to av1_encode() except that tpl is not performed. | 
|  | static int denoise_and_encode(AV1_COMP *const cpi, uint8_t *const dest, | 
|  | EncodeFrameInput *const frame_input, | 
|  | EncodeFrameParams *const frame_params, | 
|  | EncodeFrameResults *const frame_results) { | 
|  | const AV1EncoderConfig *const oxcf = &cpi->oxcf; | 
|  | AV1_COMMON *const cm = &cpi->common; | 
|  | const GF_GROUP *const gf_group = &cpi->gf_group; | 
|  |  | 
|  | // Decide whether to apply temporal filtering to the source frame. | 
|  | int apply_filtering = 0; | 
|  | int arf_src_index = -1; | 
|  | if (frame_params->frame_type == KEY_FRAME) { | 
|  | // Decide whether it is allowed to perform key frame filtering | 
|  | int allow_kf_filtering = | 
|  | oxcf->kf_cfg.enable_keyframe_filtering && | 
|  | !is_stat_generation_stage(cpi) && !frame_params->show_existing_frame && | 
|  | cpi->rc.frames_to_key > cpi->oxcf.algo_cfg.arnr_max_frames && | 
|  | !is_lossless_requested(&oxcf->rc_cfg) && | 
|  | oxcf->algo_cfg.arnr_max_frames > 0; | 
|  | if (allow_kf_filtering) { | 
|  | const double y_noise_level = av1_estimate_noise_from_single_plane( | 
|  | frame_input->source, 0, cm->seq_params.bit_depth); | 
|  | apply_filtering = y_noise_level > 0; | 
|  | } else { | 
|  | apply_filtering = 0; | 
|  | } | 
|  | // If we are doing kf filtering, set up a few things. | 
|  | if (apply_filtering) { | 
|  | MACROBLOCKD *const xd = &cpi->td.mb.e_mbd; | 
|  | av1_init_mi_buffers(&cm->mi_params); | 
|  | setup_mi(cpi, frame_input->source); | 
|  | av1_init_macroblockd(cm, xd); | 
|  | memset(cpi->mbmi_ext_info.frame_base, 0, | 
|  | cpi->mbmi_ext_info.alloc_size * | 
|  | sizeof(*cpi->mbmi_ext_info.frame_base)); | 
|  |  | 
|  | av1_set_speed_features_framesize_independent(cpi, oxcf->speed); | 
|  | av1_set_speed_features_framesize_dependent(cpi, oxcf->speed); | 
|  | av1_set_rd_speed_thresholds(cpi); | 
|  | av1_setup_frame_buf_refs(cm); | 
|  | av1_setup_frame_sign_bias(cm); | 
|  | av1_frame_init_quantizer(cpi); | 
|  | av1_setup_past_independence(cm); | 
|  |  | 
|  | if (gf_group->update_type[gf_group->index] == KEY_FRAME && | 
|  | !cpi->no_show_fwd_kf) | 
|  | cm->current_frame.frame_number = 0; | 
|  |  | 
|  | if (!frame_params->show_frame && cpi->no_show_fwd_kf) { | 
|  | // fwd kf | 
|  | arf_src_index = -1 * gf_group->arf_src_offset[gf_group->index]; | 
|  | } else if (!frame_params->show_frame) { | 
|  | arf_src_index = 0; | 
|  | } else { | 
|  | arf_src_index = -1; | 
|  | } | 
|  | } | 
|  | } else if (get_frame_update_type(&cpi->gf_group) == ARF_UPDATE || | 
|  | get_frame_update_type(&cpi->gf_group) == KFFLT_UPDATE || | 
|  | get_frame_update_type(&cpi->gf_group) == INTNL_ARF_UPDATE) { | 
|  | // ARF | 
|  | apply_filtering = oxcf->algo_cfg.arnr_max_frames > 0; | 
|  | if (gf_group->is_user_specified) { | 
|  | apply_filtering &= gf_group->is_filtered[gf_group->index]; | 
|  | } | 
|  | if (apply_filtering) { | 
|  | arf_src_index = gf_group->arf_src_offset[gf_group->index]; | 
|  | } | 
|  | } | 
|  | // Save the pointer to the original source image. | 
|  | YV12_BUFFER_CONFIG *source_buffer = frame_input->source; | 
|  | // apply filtering to frame | 
|  | int show_existing_alt_ref = 0; | 
|  | if (apply_filtering) { | 
|  | // TODO(bohanli): figure out why we need frame_type in cm here. | 
|  | cm->current_frame.frame_type = frame_params->frame_type; | 
|  | const int code_arf = | 
|  | av1_temporal_filter(cpi, arf_src_index, &show_existing_alt_ref); | 
|  | if (code_arf) { | 
|  | aom_extend_frame_borders(&cpi->alt_ref_buffer, av1_num_planes(cm)); | 
|  | frame_input->source = &cpi->alt_ref_buffer; | 
|  | aom_copy_metadata_to_frame_buffer(frame_input->source, | 
|  | source_buffer->metadata); | 
|  | } | 
|  | } | 
|  | #if CONFIG_OUTPUT_FRAME_BASED_ON_ORDER_HINT | 
|  | // when enable_frame_output_order == 1, show_existing mechanism is | 
|  | // used for alt_ref in encoder side internally, but the OBU with | 
|  | // show_existing_frame == 1 is not signaled in the bitstream. | 
|  | if (cm->seq_params.enable_frame_output_order) show_existing_alt_ref = 1; | 
|  | #endif  // CONFIG_OUTPUT_FRAME_BASED_ON_ORDER_HINT | 
|  | set_show_existing_alt_ref(&cpi->gf_group, apply_filtering, | 
|  | oxcf->algo_cfg.enable_overlay, | 
|  | show_existing_alt_ref); | 
|  |  | 
|  | // perform tpl after filtering | 
|  | int allow_tpl = oxcf->gf_cfg.lag_in_frames > 1 && | 
|  | !is_stat_generation_stage(cpi) && | 
|  | oxcf->algo_cfg.enable_tpl_model; | 
|  | if (frame_params->frame_type == KEY_FRAME) { | 
|  | // Don't do tpl for fwd key frames | 
|  | allow_tpl = allow_tpl && !cpi->sf.tpl_sf.disable_filtered_key_tpl && | 
|  | !cpi->no_show_fwd_kf; | 
|  | } else { | 
|  | // Do tpl after ARF is filtered, or if no ARF, at the second frame of GF | 
|  | // group. | 
|  | // TODO(bohanli): if no ARF, just do it at the first frame. | 
|  | int gf_index = gf_group->index; | 
|  | allow_tpl = allow_tpl && (gf_group->update_type[gf_index] == ARF_UPDATE || | 
|  | gf_group->update_type[gf_index] == GF_UPDATE); | 
|  | if (allow_tpl) { | 
|  | // Need to set the size for TPL for ARF | 
|  | // TODO(bohanli): Why is this? what part of it is necessary? | 
|  | av1_set_frame_size(cpi, cm->width, cm->height); | 
|  | } | 
|  | } | 
|  |  | 
|  | if (gf_group->index == 0) av1_init_tpl_stats(&cpi->tpl_data); | 
|  | if (allow_tpl) av1_tpl_setup_stats(cpi, 0, frame_params, frame_input); | 
|  |  | 
|  | if (av1_encode(cpi, dest, frame_input, frame_params, frame_results) != | 
|  | AOM_CODEC_OK) { | 
|  | return AOM_CODEC_ERROR; | 
|  | } | 
|  |  | 
|  | // Set frame_input source to true source for psnr calculation. | 
|  | if (apply_filtering && is_psnr_calc_enabled(cpi)) { | 
|  | cpi->source = | 
|  | av1_scale_if_required(cm, source_buffer, &cpi->scaled_source, | 
|  | cm->features.interp_filter, 0, false, true); | 
|  | cpi->unscaled_source = source_buffer; | 
|  | } | 
|  |  | 
|  | return AOM_CODEC_OK; | 
|  | } | 
|  |  | 
|  | int av1_encode_strategy(AV1_COMP *const cpi, size_t *const size, | 
|  | uint8_t *const dest, unsigned int *frame_flags, | 
|  | int64_t *const time_stamp, int64_t *const time_end, | 
|  | const aom_rational64_t *const timestamp_ratio, | 
|  | int flush) { | 
|  | AV1EncoderConfig *const oxcf = &cpi->oxcf; | 
|  | AV1_COMMON *const cm = &cpi->common; | 
|  | GF_GROUP *gf_group = &cpi->gf_group; | 
|  | ExternalFlags *const ext_flags = &cpi->ext_flags; | 
|  |  | 
|  | EncodeFrameInput frame_input; | 
|  | EncodeFrameParams frame_params; | 
|  | EncodeFrameResults frame_results; | 
|  | memset(&frame_input, 0, sizeof(frame_input)); | 
|  | memset(&frame_params, 0, sizeof(frame_params)); | 
|  | memset(&frame_results, 0, sizeof(frame_results)); | 
|  |  | 
|  | // Check if we need to stuff more src frames | 
|  | if (flush == 0) { | 
|  | int srcbuf_size = | 
|  | av1_lookahead_depth(cpi->lookahead, cpi->compressor_stage); | 
|  | int pop_size = av1_lookahead_pop_sz(cpi->lookahead, cpi->compressor_stage); | 
|  |  | 
|  | // Continue buffering look ahead buffer. | 
|  | if (srcbuf_size < pop_size) return -1; | 
|  | } | 
|  |  | 
|  | if (!av1_lookahead_peek(cpi->lookahead, 0, cpi->compressor_stage)) { | 
|  | if (flush && oxcf->pass == 1 && !cpi->twopass.first_pass_done) { | 
|  | av1_end_first_pass(cpi); /* get last stats packet */ | 
|  | cpi->twopass.first_pass_done = 1; | 
|  | } | 
|  | return -1; | 
|  | } | 
|  |  | 
|  | if (!is_stat_generation_stage(cpi)) { | 
|  | // If this is a forward keyframe, mark as a show_existing_frame | 
|  | // TODO(bohanli): find a consistent condition for fwd keyframes | 
|  | if (oxcf->kf_cfg.fwd_kf_enabled && | 
|  | (gf_group->index == (gf_group->size - 1)) && | 
|  | (gf_group->update_type[gf_group->index] == OVERLAY_UPDATE || | 
|  | gf_group->update_type[gf_group->index] == KFFLT_OVERLAY_UPDATE) && | 
|  | gf_group->arf_index >= 0 && cpi->rc.frames_to_key == 0) { | 
|  | frame_params.show_existing_frame = 1; | 
|  | } else { | 
|  | frame_params.show_existing_frame = | 
|  | (gf_group->show_existing_alt_ref && | 
|  | (gf_group->update_type[gf_group->index] == OVERLAY_UPDATE || | 
|  | gf_group->update_type[gf_group->index] == KFFLT_OVERLAY_UPDATE)) || | 
|  | gf_group->update_type[gf_group->index] == INTNL_OVERLAY_UPDATE; | 
|  | } | 
|  | frame_params.show_existing_frame &= allow_show_existing(cpi, *frame_flags); | 
|  |  | 
|  | // Reset show_existing_alt_ref decision to 0 after it is used. | 
|  | if (gf_group->update_type[gf_group->index] == OVERLAY_UPDATE || | 
|  | gf_group->update_type[gf_group->index] == KFFLT_OVERLAY_UPDATE) { | 
|  | gf_group->show_existing_alt_ref = 0; | 
|  | } | 
|  | } else { | 
|  | frame_params.show_existing_frame = 0; | 
|  | } | 
|  |  | 
|  | if (!is_stat_generation_stage(cpi)) { | 
|  | av1_get_second_pass_params(cpi, &frame_params); | 
|  | } | 
|  |  | 
|  | struct lookahead_entry *source = NULL; | 
|  | struct lookahead_entry *last_source = NULL; | 
|  | if (frame_params.show_existing_frame) { | 
|  | source = av1_lookahead_pop(cpi->lookahead, flush, cpi->compressor_stage); | 
|  | frame_params.show_frame = 1; | 
|  | } else { | 
|  | source = choose_frame_source(cpi, &flush, &last_source, &frame_params); | 
|  | } | 
|  |  | 
|  | if (source == NULL) {  // If no source was found, we can't encode a frame. | 
|  | if (flush && oxcf->pass == 1 && !cpi->twopass.first_pass_done) { | 
|  | av1_end_first_pass(cpi); /* get last stats packet */ | 
|  | cpi->twopass.first_pass_done = 1; | 
|  | } | 
|  | return -1; | 
|  | } | 
|  | // Source may be changed if temporal filtered later. | 
|  | frame_input.source = &source->img; | 
|  | frame_input.last_source = last_source != NULL ? &last_source->img : NULL; | 
|  | frame_input.ts_duration = source->ts_end - source->ts_start; | 
|  | // Save unfiltered source. It is used in av1_get_second_pass_params(). | 
|  | cpi->unfiltered_source = frame_input.source; | 
|  |  | 
|  | *time_stamp = source->ts_start; | 
|  | *time_end = source->ts_end; | 
|  | if (source->ts_start < cpi->time_stamps.first_ever) { | 
|  | cpi->time_stamps.first_ever = source->ts_start; | 
|  | cpi->time_stamps.prev_end_seen = source->ts_start; | 
|  | } | 
|  |  | 
|  | if (!is_stat_generation_stage(cpi) && | 
|  | cpi->tpl_data.tpl_stats_pool[0] == NULL) { | 
|  | setup_tpl_buffers(cm, &cpi->tpl_data, cpi->oxcf.algo_cfg.enable_tpl_model, | 
|  | oxcf->gf_cfg.lag_in_frames); | 
|  | } | 
|  |  | 
|  | av1_apply_encoding_flags(cpi, source->flags); | 
|  | if (!frame_params.show_existing_frame) | 
|  | *frame_flags = (source->flags & AOM_EFLAG_FORCE_KF) ? FRAMEFLAGS_KEY : 0; | 
|  |  | 
|  | // Shown frames and arf-overlay frames need frame-rate considering | 
|  | if (frame_params.show_frame) | 
|  | adjust_frame_rate(cpi, source->ts_start, source->ts_end); | 
|  |  | 
|  | if (!frame_params.show_existing_frame) { | 
|  | if (cpi->film_grain_table) { | 
|  | cm->cur_frame->film_grain_params_present = aom_film_grain_table_lookup( | 
|  | cpi->film_grain_table, *time_stamp, *time_end, 0 /* =erase */, | 
|  | &cm->film_grain_params); | 
|  | } else { | 
|  | cm->cur_frame->film_grain_params_present = | 
|  | cm->seq_params.film_grain_params_present; | 
|  | } | 
|  | // only one operating point supported now | 
|  | const int64_t pts64 = ticks_to_timebase_units(timestamp_ratio, *time_stamp); | 
|  | if (pts64 < 0 || pts64 > UINT32_MAX) return AOM_CODEC_ERROR; | 
|  | cm->frame_presentation_time = (uint32_t)pts64; | 
|  | } | 
|  |  | 
|  | FRAME_UPDATE_TYPE frame_update_type = get_frame_update_type(gf_group); | 
|  |  | 
|  | if (frame_params.show_existing_frame && | 
|  | frame_params.frame_type != KEY_FRAME) { | 
|  | // Force show-existing frames to be INTER, except forward keyframes | 
|  | frame_params.frame_type = INTER_FRAME; | 
|  | } | 
|  |  | 
|  | // TODO(david.turner@argondesign.com): Move all the encode strategy | 
|  | // (largely near av1_get_compressed_data) in here | 
|  |  | 
|  | // TODO(david.turner@argondesign.com): Change all the encode strategy to | 
|  | // modify frame_params instead of cm or cpi. | 
|  |  | 
|  | // Per-frame encode speed.  In theory this can vary, but things may have | 
|  | // been written assuming speed-level will not change within a sequence, so | 
|  | // this parameter should be used with caution. | 
|  | frame_params.speed = oxcf->speed; | 
|  |  | 
|  | // Work out some encoding parameters specific to the pass: | 
|  | if (has_no_stats_stage(cpi) && oxcf->q_cfg.aq_mode == CYCLIC_REFRESH_AQ) { | 
|  | av1_cyclic_refresh_update_parameters(cpi); | 
|  | } else if (is_stat_generation_stage(cpi)) { | 
|  | cpi->td.mb.e_mbd.lossless[0] = is_lossless_requested(&oxcf->rc_cfg); | 
|  | const int kf_requested = (cm->current_frame.frame_number == 0 || | 
|  | (*frame_flags & FRAMEFLAGS_KEY)); | 
|  | if (kf_requested && frame_update_type != OVERLAY_UPDATE && | 
|  | frame_update_type != KFFLT_OVERLAY_UPDATE && | 
|  | frame_update_type != INTNL_OVERLAY_UPDATE) { | 
|  | frame_params.frame_type = KEY_FRAME; | 
|  | } else { | 
|  | frame_params.frame_type = INTER_FRAME; | 
|  | } | 
|  | } else if (is_stat_consumption_stage(cpi)) { | 
|  | #if CONFIG_MISMATCH_DEBUG | 
|  | #if CONFIG_OUTPUT_FRAME_BASED_ON_ORDER_HINT | 
|  | mismatch_move_frame_idx_w(!cm->seq_params.enable_frame_output_order || | 
|  | !frame_params.show_existing_frame); | 
|  | #else | 
|  | mismatch_move_frame_idx_w(1); | 
|  | #endif  // CONFIG_OUTPUT_FRAME_BASED_ON_ORDER_HINT | 
|  | #endif  // CONFIG_MISMATCH_DEBUG | 
|  | #if TXCOEFF_COST_TIMER | 
|  | cm->txcoeff_cost_timer = 0; | 
|  | cm->txcoeff_cost_count = 0; | 
|  | #endif | 
|  | } | 
|  |  | 
|  | #if CONFIG_MISMATCH_DEBUG | 
|  | if (has_no_stats_stage(cpi)) { | 
|  | #if CONFIG_OUTPUT_FRAME_BASED_ON_ORDER_HINT | 
|  | mismatch_move_frame_idx_w(!cm->seq_params.enable_frame_output_order || | 
|  | !frame_params.show_existing_frame); | 
|  | #else | 
|  | mismatch_move_frame_idx_w(1); | 
|  | #endif  // CONFIG_OUTPUT_FRAME_BASED_ON_ORDER_HINT | 
|  | } | 
|  | #endif  // CONFIG_MISMATCH_DEBUG | 
|  |  | 
|  | if (!is_stat_generation_stage(cpi)) | 
|  | set_ext_overrides(cm, &frame_params, ext_flags); | 
|  |  | 
|  | // Shown keyframes and S frames refresh all reference buffers | 
|  | const int force_refresh_all = | 
|  | ((frame_params.frame_type == KEY_FRAME && frame_params.show_frame) || | 
|  | frame_params.frame_type == S_FRAME) && | 
|  | !frame_params.show_existing_frame; | 
|  |  | 
|  | (void)force_refresh_all; | 
|  | av1_configure_buffer_updates(cpi, frame_update_type); | 
|  |  | 
|  | const int order_offset = gf_group->arf_src_offset[gf_group->index]; | 
|  | const int cur_frame_disp = | 
|  | cpi->common.current_frame.frame_number + order_offset; | 
|  | #if CONFIG_PRIMARY_REF_FRAME_OPT | 
|  | init_ref_map_pair(&cpi->common, cm->ref_frame_map_pairs, | 
|  | gf_group->update_type[gf_group->index] == KF_UPDATE); | 
|  | #else | 
|  | RefFrameMapPair ref_frame_map_pairs[REF_FRAMES]; | 
|  | init_ref_map_pair(&cpi->common, ref_frame_map_pairs, | 
|  | gf_group->update_type[gf_group->index] == KF_UPDATE); | 
|  | #endif  // CONFIG_PRIMARY_REF_FRAME_OPT | 
|  |  | 
|  | if (!is_stat_generation_stage(cpi)) { | 
|  | cm->current_frame.frame_type = frame_params.frame_type; | 
|  | cm->features.error_resilient_mode = frame_params.error_resilient_mode; | 
|  |  | 
|  | #if CONFIG_PRIMARY_REF_FRAME_OPT | 
|  | if (cm->seq_params.explicit_ref_frame_map) | 
|  | av1_get_ref_frames_enc(cm, cur_frame_disp, cm->ref_frame_map_pairs); | 
|  | else | 
|  | av1_get_ref_frames(cm, cur_frame_disp, cm->ref_frame_map_pairs); | 
|  | #else | 
|  | if (cm->seq_params.explicit_ref_frame_map) | 
|  | av1_get_ref_frames_enc(cm, cur_frame_disp, ref_frame_map_pairs); | 
|  | else | 
|  | av1_get_ref_frames(cm, cur_frame_disp, ref_frame_map_pairs); | 
|  | #endif  // CONFIG_PRIMARY_REF_FRAME_OPT | 
|  |  | 
|  | #if CONFIG_ALLOW_SAME_REF_COMPOUND | 
|  | cm->ref_frames_info.num_same_ref_compound = | 
|  | AOMMIN(cm->seq_params.num_same_ref_compound, | 
|  | cm->ref_frames_info.num_total_refs); | 
|  | #endif  // CONFIG_ALLOW_SAME_REF_COMPOUND | 
|  | #if CONFIG_IMPROVED_GLOBAL_MOTION | 
|  | cm->cur_frame->num_ref_frames = cm->ref_frames_info.num_total_refs; | 
|  | #endif  // CONFIG_IMPROVED_GLOBAL_MOTION | 
|  |  | 
|  | // ref_frame_flags is defined based on the external flag | 
|  | // max-reference-frames. | 
|  | frame_params.ref_frame_flags = | 
|  | (1 << cpi->common.ref_frames_info.num_total_refs) - 1; | 
|  |  | 
|  | #if !CONFIG_PRIMARY_REF_FRAME_OPT | 
|  | frame_params.primary_ref_frame = | 
|  | choose_primary_ref_frame(cpi, &frame_params); | 
|  | #endif  // !CONFIG_PRIMARY_REF_FRAME_OPT | 
|  | frame_params.order_offset = gf_group->arf_src_offset[gf_group->index]; | 
|  |  | 
|  | if (!is_stat_generation_stage(cpi) && | 
|  | use_subgop_cfg(&cpi->gf_group, cpi->gf_group.index) && | 
|  | frame_update_type != KF_UPDATE) { | 
|  | get_gop_cfg_enabled_refs(cpi, &frame_params.ref_frame_flags, | 
|  | frame_params.order_offset); | 
|  | } | 
|  |  | 
|  | frame_params.refresh_frame_flags = av1_get_refresh_frame_flags( | 
|  | cpi, &frame_params, frame_update_type, cpi->gf_group.index, | 
|  | #if CONFIG_PRIMARY_REF_FRAME_OPT | 
|  | cur_frame_disp, cm->ref_frame_map_pairs); | 
|  | #else | 
|  | cur_frame_disp, ref_frame_map_pairs); | 
|  | #endif  // CONFIG_PRIMARY_REF_FRAME_OPT | 
|  |  | 
|  | frame_params.existing_fb_idx_to_show = INVALID_IDX; | 
|  | // Find the frame buffer to show based on display order | 
|  | if (frame_params.show_existing_frame) { | 
|  | for (int frame = 0; frame < REF_FRAMES; frame++) { | 
|  | const RefCntBuffer *const buf = cm->ref_frame_map[frame]; | 
|  | if (buf == NULL) continue; | 
|  | const int frame_order = (int)buf->display_order_hint; | 
|  | if (frame_order == cur_frame_disp) | 
|  | frame_params.existing_fb_idx_to_show = frame; | 
|  | } | 
|  | } | 
|  | } | 
|  |  | 
|  | // The way frame_params->remapped_ref_idx is setup is a placeholder. | 
|  | // Currently, reference buffer assignment is done by update_ref_frame_map() | 
|  | // which is called by high-level strategy AFTER encoding a frame.  It | 
|  | // modifies cm->remapped_ref_idx.  If you want to use an alternative method | 
|  | // to determine reference buffer assignment, just put your assignments into | 
|  | // frame_params->remapped_ref_idx here and they will be used when encoding | 
|  | // this frame.  If frame_params->remapped_ref_idx is setup independently of | 
|  | // cm->remapped_ref_idx then update_ref_frame_map() will have no effect. | 
|  | memcpy(frame_params.remapped_ref_idx, cm->remapped_ref_idx, | 
|  | REF_FRAMES * sizeof(*cm->remapped_ref_idx)); | 
|  |  | 
|  | cpi->td.mb.delta_qindex = 0; | 
|  |  | 
|  | if (!frame_params.show_existing_frame) { | 
|  | cm->quant_params.using_qmatrix = oxcf->q_cfg.using_qm; | 
|  | #if CONFIG_LR_IMPROVEMENTS | 
|  | av1_set_lr_tools(cm->seq_params.lr_tools_disable_mask[0], 0, &cm->features); | 
|  | av1_set_lr_tools(cm->seq_params.lr_tools_disable_mask[1], 1, &cm->features); | 
|  | av1_set_lr_tools(cm->seq_params.lr_tools_disable_mask[1], 2, &cm->features); | 
|  | #endif  // CONFIG_LR_IMPROVEMENTS | 
|  | } | 
|  | if (denoise_and_encode(cpi, dest, &frame_input, &frame_params, | 
|  | &frame_results) != AOM_CODEC_OK) { | 
|  | return AOM_CODEC_ERROR; | 
|  | } | 
|  |  | 
|  | if (!is_stat_generation_stage(cpi)) { | 
|  | // First pass doesn't modify reference buffer assignment or produce frame | 
|  | // flags | 
|  | update_frame_flags(&cpi->common, frame_flags); | 
|  | } | 
|  |  | 
|  | if (!is_stat_generation_stage(cpi)) { | 
|  | #if TXCOEFF_COST_TIMER | 
|  | cm->cum_txcoeff_cost_timer += cm->txcoeff_cost_timer; | 
|  | fprintf(stderr, | 
|  | "\ntxb coeff cost block number: %ld, frame time: %ld, cum time %ld " | 
|  | "in us\n", | 
|  | cm->txcoeff_cost_count, cm->txcoeff_cost_timer, | 
|  | cm->cum_txcoeff_cost_timer); | 
|  | #endif | 
|  | if (!has_no_stats_stage(cpi)) av1_twopass_postencode_update(cpi); | 
|  | } | 
|  |  | 
|  | #if CONFIG_TUNE_VMAF | 
|  | if (!is_stat_generation_stage(cpi) && | 
|  | (oxcf->tune_cfg.tuning >= AOM_TUNE_VMAF_WITH_PREPROCESSING && | 
|  | oxcf->tune_cfg.tuning <= AOM_TUNE_VMAF_NEG_MAX_GAIN)) { | 
|  | av1_update_vmaf_curve(cpi); | 
|  | } | 
|  | #endif | 
|  |  | 
|  | if (!is_stat_generation_stage(cpi)) { | 
|  | #if !CONFIG_PRIMARY_REF_FRAME_OPT | 
|  | update_fb_of_context_type(cpi, &frame_params, cpi->fb_of_context_type); | 
|  | #endif  // !CONFIG_PRIMARY_REF_FRAME_OPT | 
|  | set_additional_frame_flags(cm, frame_flags); | 
|  | update_rc_counts(cpi); | 
|  | } | 
|  |  | 
|  | // Unpack frame_results: | 
|  | *size = frame_results.size; | 
|  |  | 
|  | // Leave a signal for a higher level caller about if this frame is droppable | 
|  | if (*size > 0) { | 
|  | cpi->droppable = is_frame_droppable(&ext_flags->refresh_frame); | 
|  | } | 
|  |  | 
|  | return AOM_CODEC_OK; | 
|  | } | 
|  |  | 
|  | // Determine whether a frame is a keyframe arf. Will return 0 for fwd kf arf. | 
|  | // Note it depends on frame_since_key and gf_group, therefore should be called | 
|  | // after the gf group is defined, or otherwise a keyframe arf may still return | 
|  | // 0. | 
|  | int av1_check_keyframe_arf(int gf_index, GF_GROUP *gf_group, | 
|  | int frame_since_key) { | 
|  | if (gf_index >= gf_group->size) return 0; | 
|  | (void)frame_since_key; | 
|  | return gf_group->update_type[gf_index] == KFFLT_UPDATE; | 
|  | /* | 
|  | return gf_group->update_type[gf_index] == ARF_UPDATE && | 
|  | gf_group->update_type[gf_index + 1] == OVERLAY_UPDATE && | 
|  | frame_since_key == 0; | 
|  | */ | 
|  | } | 
|  |  | 
|  | // Determine whether a frame is a keyframe overlay (will also return 0 for fwd | 
|  | // kf overlays). | 
|  | int av1_check_keyframe_overlay(int gf_index, GF_GROUP *gf_group, | 
|  | int frame_since_key) { | 
|  | if (gf_index < 1) return 0; | 
|  | (void)frame_since_key; | 
|  | return gf_group->update_type[gf_index] == KFFLT_OVERLAY_UPDATE; | 
|  | /* | 
|  | return gf_group->update_type[gf_index - 1] == ARF_UPDATE && | 
|  | gf_group->update_type[gf_index] == OVERLAY_UPDATE && | 
|  | frame_since_key == 0; | 
|  | */ | 
|  | } |