| OLD | NEW |
| 1 /* | 1 /* |
| 2 * Copyright (c) 2014 The WebM project authors. All Rights Reserved. | 2 * Copyright (c) 2014 The WebM project authors. All Rights Reserved. |
| 3 * | 3 * |
| 4 * Use of this source code is governed by a BSD-style license | 4 * Use of this source code is governed by a BSD-style license |
| 5 * that can be found in the LICENSE file in the root of the source | 5 * that can be found in the LICENSE file in the root of the source |
| 6 * tree. An additional intellectual property rights grant can be found | 6 * tree. An additional intellectual property rights grant can be found |
| 7 * in the file PATENTS. All contributing project authors may | 7 * in the file PATENTS. All contributing project authors may |
| 8 * be found in the AUTHORS file in the root of the source tree. | 8 * be found in the AUTHORS file in the root of the source tree. |
| 9 */ | 9 */ |
| 10 | 10 |
| (...skipping 49 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 60 vp9_get_tile_n_bits(mi_cols, &min_log2_tile_cols, &max_log2_tile_cols); | 60 vp9_get_tile_n_bits(mi_cols, &min_log2_tile_cols, &max_log2_tile_cols); |
| 61 log2_tile_cols = clamp(cpi->oxcf.tile_columns, | 61 log2_tile_cols = clamp(cpi->oxcf.tile_columns, |
| 62 min_log2_tile_cols, max_log2_tile_cols); | 62 min_log2_tile_cols, max_log2_tile_cols); |
| 63 return (1 << log2_tile_cols); | 63 return (1 << log2_tile_cols); |
| 64 } | 64 } |
| 65 | 65 |
| 66 void vp9_encode_tiles_mt(VP9_COMP *cpi) { | 66 void vp9_encode_tiles_mt(VP9_COMP *cpi) { |
| 67 VP9_COMMON *const cm = &cpi->common; | 67 VP9_COMMON *const cm = &cpi->common; |
| 68 const int tile_cols = 1 << cm->log2_tile_cols; | 68 const int tile_cols = 1 << cm->log2_tile_cols; |
| 69 const VPxWorkerInterface *const winterface = vpx_get_worker_interface(); | 69 const VPxWorkerInterface *const winterface = vpx_get_worker_interface(); |
| 70 const int num_workers = MIN(cpi->oxcf.max_threads, tile_cols); | 70 const int num_workers = VPXMIN(cpi->oxcf.max_threads, tile_cols); |
| 71 int i; | 71 int i; |
| 72 | 72 |
| 73 vp9_init_tile_data(cpi); | 73 vp9_init_tile_data(cpi); |
| 74 | 74 |
| 75 // Only run once to create threads and allocate thread data. | 75 // Only run once to create threads and allocate thread data. |
| 76 if (cpi->num_workers == 0) { | 76 if (cpi->num_workers == 0) { |
| 77 int allocated_workers = num_workers; | 77 int allocated_workers = num_workers; |
| 78 | 78 |
| 79 // While using SVC, we need to allocate threads according to the highest | 79 // While using SVC, we need to allocate threads according to the highest |
| 80 // resolution. | 80 // resolution. |
| 81 if (cpi->use_svc) { | 81 if (cpi->use_svc) { |
| 82 int max_tile_cols = get_max_tile_cols(cpi); | 82 int max_tile_cols = get_max_tile_cols(cpi); |
| 83 allocated_workers = MIN(cpi->oxcf.max_threads, max_tile_cols); | 83 allocated_workers = VPXMIN(cpi->oxcf.max_threads, max_tile_cols); |
| 84 } | 84 } |
| 85 | 85 |
| 86 CHECK_MEM_ERROR(cm, cpi->workers, | 86 CHECK_MEM_ERROR(cm, cpi->workers, |
| 87 vpx_malloc(allocated_workers * sizeof(*cpi->workers))); | 87 vpx_malloc(allocated_workers * sizeof(*cpi->workers))); |
| 88 | 88 |
| 89 CHECK_MEM_ERROR(cm, cpi->tile_thr_data, | 89 CHECK_MEM_ERROR(cm, cpi->tile_thr_data, |
| 90 vpx_calloc(allocated_workers, | 90 vpx_calloc(allocated_workers, |
| 91 sizeof(*cpi->tile_thr_data))); | 91 sizeof(*cpi->tile_thr_data))); |
| 92 | 92 |
| 93 for (i = 0; i < allocated_workers; i++) { | 93 for (i = 0; i < allocated_workers; i++) { |
| (...skipping 95 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 189 VPxWorker *const worker = &cpi->workers[i]; | 189 VPxWorker *const worker = &cpi->workers[i]; |
| 190 EncWorkerData *const thread_data = (EncWorkerData*)worker->data1; | 190 EncWorkerData *const thread_data = (EncWorkerData*)worker->data1; |
| 191 | 191 |
| 192 // Accumulate counters. | 192 // Accumulate counters. |
| 193 if (i < cpi->num_workers - 1) { | 193 if (i < cpi->num_workers - 1) { |
| 194 vp9_accumulate_frame_counts(cm, thread_data->td->counts, 0); | 194 vp9_accumulate_frame_counts(cm, thread_data->td->counts, 0); |
| 195 accumulate_rd_opt(&cpi->td, thread_data->td); | 195 accumulate_rd_opt(&cpi->td, thread_data->td); |
| 196 } | 196 } |
| 197 } | 197 } |
| 198 } | 198 } |
| OLD | NEW |