diff options
Diffstat (limited to 'src/rmd_threads.c')
| -rw-r--r-- | src/rmd_threads.c | 169 |
1 files changed, 169 insertions, 0 deletions
diff --git a/src/rmd_threads.c b/src/rmd_threads.c new file mode 100644 index 0000000..cb81f84 --- /dev/null +++ b/src/rmd_threads.c @@ -0,0 +1,169 @@ +/****************************************************************************** +* 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); +} |