generic-library/vpx
1
0
Fork 0
Code Issues Pull Requests Releases Wiki Activity

vp8_decoder_create_threads: check sem/pthread returns

Browse Source 
Change-Id: I353da4a2f988ca51d48d0ca91236e8cc0bb48ff5
This commit is contained in:
James Zern
2016-08-23 18:46:31 -07:00
parent 13338a481f
commit a6efe6d437
1 changed files with 24 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

29
vp8/decoder/threading.c
View File

@@ -609,8 +609,13 @@ void vp8_decoder_create_threads(VP8D_COMP *pbi) {
CALLOC_ARRAY_ALIGNED(pbi->mb_row_di, pbi->decoding_thread_count, 32); CALLOC_ARRAY_ALIGNED(pbi->mb_row_di, pbi->decoding_thread_count, 32);
CALLOC_ARRAY(pbi->de_thread_data, pbi->decoding_thread_count); CALLOC_ARRAY(pbi->de_thread_data, pbi->decoding_thread_count);
if (sem_init(&pbi->h_event_end_decoding, 0, 0)) {
vpx_internal_error(&pbi->common.error, VPX_CODEC_MEM_ERROR,
"Failed to initialize semaphore");
}
for (ithread = 0; ithread < pbi->decoding_thread_count; ++ithread) { for (ithread = 0; ithread < pbi->decoding_thread_count; ++ithread) {
sem_init(&pbi->h_event_start_decoding[ithread], 0, 0); if (sem_init(&pbi->h_event_start_decoding[ithread], 0, 0)) break;
vp8_setup_block_dptrs(&pbi->mb_row_di[ithread].mbd); vp8_setup_block_dptrs(&pbi->mb_row_di[ithread].mbd);
@@ -618,13 +623,23 @@ void vp8_decoder_create_threads(VP8D_COMP *pbi) {
pbi->de_thread_data[ithread].ptr1 = (void *)pbi; pbi->de_thread_data[ithread].ptr1 = (void *)pbi;
pbi->de_thread_data[ithread].ptr2 = (void *)&pbi->mb_row_di[ithread]; pbi->de_thread_data[ithread].ptr2 = (void *)&pbi->mb_row_di[ithread];
pthread_create(&pbi->h_decoding_thread[ithread], 0, thread_decoding_proc, if (pthread_create(&pbi->h_decoding_thread[ithread], 0,
(&pbi->de_thread_data[ithread])); thread_decoding_proc, &pbi->de_thread_data[ithread])) {
sem_destroy(&pbi->h_event_start_decoding[ithread]);
break;
}
} }
sem_init(&pbi->h_event_end_decoding, 0, 0); pbi->allocated_decoding_thread_count = ithread;
if (pbi->allocated_decoding_thread_count != pbi->decoding_thread_count) {
pbi->allocated_decoding_thread_count = pbi->decoding_thread_count; /* the remainder of cleanup cases will be handled in
* vp8_decoder_remove_threads(). */
if (pbi->allocated_decoding_thread_count == 0) {
sem_destroy(&pbi->h_event_end_decoding);
}
vpx_internal_error(&pbi->common.error, VPX_CODEC_MEM_ERROR,
"Failed to create threads");
}
} }
} }
@@ -770,7 +785,9 @@ void vp8_decoder_remove_threads(VP8D_COMP *pbi) {
sem_destroy(&pbi->h_event_start_decoding[i]); sem_destroy(&pbi->h_event_start_decoding[i]);
} }
if (pbi->allocated_decoding_thread_count) {
sem_destroy(&pbi->h_event_end_decoding); sem_destroy(&pbi->h_event_end_decoding);
}
vpx_free(pbi->h_decoding_thread); vpx_free(pbi->h_decoding_thread);
pbi->h_decoding_thread = NULL; pbi->h_decoding_thread = NULL;