diff options
Diffstat (limited to 'recordmydesktop/src/rmd_threads.c')
| -rw-r--r-- | recordmydesktop/src/rmd_threads.c | 169 |
1 files changed, 0 insertions, 169 deletions
diff --git a/recordmydesktop/src/rmd_threads.c b/recordmydesktop/src/rmd_threads.c deleted file mode 100644 index cb81f84..0000000 --- a/recordmydesktop/src/rmd_threads.c +++ /dev/null @@ -1,169 +0,0 @@ -/****************************************************************************** -* recordMyDesktop * -******************************************************************************* -* * -* Copyright (C) 2006,2007,2008 John Varouhakis * -* * -* * -* This program is free software; you can redistribute it and/or modify * -* it under the terms of the GNU General Public License as published by * -* the Free Software Foundation; either version 2 of the License, or * -* (at your option) any later version. * -* * -* This program is distributed in the hope that it will be useful, * -* but WITHOUT ANY WARRANTY; without even the implied warranty of * -* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the * -* GNU General Public License for more details. * -* * -* You should have received a copy of the GNU General Public License * -* along with this program; if not, write to the Free Software * -* Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA * -* * -* * -* * -* For further information contact me at johnvarouhakis@gmail.com * -******************************************************************************/ - -#include "config.h" -#include "rmd_threads.h" - -#include "rmd_cache_audio.h" -#include "rmd_cache_frame.h" -#include "rmd_capture_sound.h" -#include "rmd_encode_image_buffer.h" -#include "rmd_encode_sound_buffer.h" -#include "rmd_flush_to_ogg.h" -#include "rmd_get_frame.h" -#include "rmd_jack.h" -#include "rmd_register_callbacks.h" -#include "rmd_timer.h" -#include "rmd_types.h" - -#include <pthread.h> - -#include <stdio.h> -#include <stdlib.h> -#include <unistd.h> - -void rmdThreads(ProgData *pdata) { - pthread_t image_capture_t, - image_encode_t, - image_cache_t, - sound_capture_t, - sound_encode_t, - sound_cache_t, - flush_to_ogg_t, - timer_t; - - if (pdata->args.delay > 0) { - fprintf(stderr, "Will sleep for %d seconds now.\n", pdata->args.delay); - sleep(pdata->args.delay); - } - - /*start threads*/ - pthread_create( &image_capture_t, - NULL, - (void *)rmdGetFrame, - (void *)pdata); - - if (pdata->args.encOnTheFly) - pthread_create( &image_encode_t, - NULL, - (void *)rmdEncodeImageBuffer, - (void *)pdata); - else - pthread_create( &image_cache_t, - NULL, - (void *)rmdCacheImageBuffer, - (void *)pdata); - - if (!pdata->args.nosound) { - if (!pdata->args.use_jack) - pthread_create( &sound_capture_t, - NULL, - (void *)rmdCaptureSound, - (void *)pdata); - - if (pdata->args.encOnTheFly) - pthread_create( &sound_encode_t, - NULL, - (void *)rmdEncodeSoundBuffer, - (void *)pdata); - else - pthread_create( &sound_cache_t, - NULL, - (void *)rmdCacheSoundBuffer, - (void *)pdata); - } - - if (pdata->args.encOnTheFly) - pthread_create( &flush_to_ogg_t, - NULL, - (void *)rmdFlushToOgg, - (void *)pdata); - - rmdRegisterCallbacks(pdata); - pdata->timer_alive = 1; - pthread_create( &timer_t, - NULL, - (void *)rmdTimer, - (void *)pdata); - fprintf(stderr,"Capturing!\n"); - -#ifdef HAVE_LIBJACK - if (pdata->args.use_jack) - pdata->jdata->capture_started = 1; -#endif - //wait all threads to finish - - pthread_join(image_capture_t, NULL); - fprintf(stderr,"Shutting down."); - //if no damage events have been received the thread will get stuck - pthread_mutex_lock(&pdata->theora_lib_mutex); - while (!pdata->th_encoding_clean) { - puts("waiting for th_enc"); - pthread_cond_signal(&pdata->image_buffer_ready); - pthread_mutex_unlock(&pdata->theora_lib_mutex); - usleep(10000); - pthread_mutex_lock(&pdata->theora_lib_mutex); - } - pthread_mutex_unlock(&pdata->theora_lib_mutex); - - if (pdata->args.encOnTheFly) - pthread_join(image_encode_t, NULL); - else - pthread_join(image_cache_t, NULL); - fprintf(stderr,"."); - - if (!pdata->args.nosound) { -#ifdef HAVE_LIBJACK - if (pdata->args.use_jack) - rmdStopJackClient(pdata->jdata); -#endif - if (!pdata->args.use_jack) - pthread_join(sound_capture_t,NULL); - - fprintf(stderr,"."); - pthread_mutex_lock(&pdata->vorbis_lib_mutex); - while (!pdata->v_encoding_clean) { - puts("waiting for v_enc"); - pthread_cond_signal(&pdata->sound_data_read); - pthread_mutex_unlock(&pdata->vorbis_lib_mutex); - usleep(10000); - pthread_mutex_lock(&pdata->vorbis_lib_mutex); - } - pthread_mutex_unlock(&pdata->vorbis_lib_mutex); - - if (pdata->args.encOnTheFly) - pthread_join(sound_encode_t, NULL); - else - pthread_join(sound_cache_t, NULL); - } else - fprintf(stderr,".."); - - fprintf(stderr,"."); - - //Now that we are done with recording we cancel the timer - pdata->timer_alive = 0; - pthread_join(timer_t,NULL); -} |