Merge "Enhance the row mt sync read to accept the sync_range greater than 1"
This commit is contained in:
@@ -3316,7 +3316,7 @@ static void encode_rd_sb_row(VP9_COMP *cpi, ThreadData *td,
|
||||
MODE_INFO **mi = cm->mi_grid_visible + idx_str;
|
||||
|
||||
(*(cpi->row_mt_sync_read_ptr))(&tile_data->row_mt_sync, sb_row,
|
||||
sb_col_in_tile - 1);
|
||||
sb_col_in_tile);
|
||||
|
||||
if (sf->adaptive_pred_interp_filter) {
|
||||
for (i = 0; i < 64; ++i) td->leaf_tree[i].pred_interp_filter = SWITCHABLE;
|
||||
@@ -4094,7 +4094,7 @@ static void encode_nonrd_sb_row(VP9_COMP *cpi, ThreadData *td,
|
||||
int seg_skip = 0;
|
||||
|
||||
(*(cpi->row_mt_sync_read_ptr))(&tile_data->row_mt_sync, sb_row,
|
||||
sb_col_in_tile - 1);
|
||||
sb_col_in_tile);
|
||||
|
||||
x->source_variance = UINT_MAX;
|
||||
vp9_zero(x->pred_mv);
|
||||
|
@@ -320,7 +320,7 @@ void vp9_row_mt_sync_read(VP9RowMTSync *const row_mt_sync, int r, int c) {
|
||||
pthread_mutex_t *const mutex = &row_mt_sync->mutex_[r - 1];
|
||||
pthread_mutex_lock(mutex);
|
||||
|
||||
while (c > row_mt_sync->cur_col[r - 1] - nsync) {
|
||||
while (c > row_mt_sync->cur_col[r - 1] - nsync + 1) {
|
||||
pthread_cond_wait(&row_mt_sync->cond_[r - 1], mutex);
|
||||
}
|
||||
pthread_mutex_unlock(mutex);
|
||||
@@ -349,7 +349,7 @@ void vp9_row_mt_sync_write(VP9RowMTSync *const row_mt_sync, int r, int c,
|
||||
|
||||
if (c < cols - 1) {
|
||||
cur = c;
|
||||
if (c % nsync) sig = 0;
|
||||
if (c % nsync != nsync - 1) sig = 0;
|
||||
} else {
|
||||
cur = cols + nsync;
|
||||
}
|
||||
|
@@ -884,7 +884,7 @@ void vp9_first_pass_encode_tile_mb_row(VP9_COMP *cpi, ThreadData *td,
|
||||
const int mb_index = mb_row * cm->mb_cols + mb_col;
|
||||
#endif
|
||||
|
||||
(*(cpi->row_mt_sync_read_ptr))(&tile_data->row_mt_sync, mb_row, c - 1);
|
||||
(*(cpi->row_mt_sync_read_ptr))(&tile_data->row_mt_sync, mb_row, c);
|
||||
|
||||
// Adjust to the next column of MBs.
|
||||
x->plane[0].src.buf = cpi->Source->y_buffer +
|
||||
|
Reference in New Issue
Block a user