mlt_properties_set_int( this->properties, "buffer", 1 );
// Default audio buffer
- mlt_properties_set_int( this->properties, "audio_buffer", 512 );
+ mlt_properties_set_int( this->properties, "audio_buffer", 2048 );
// Ensure we don't join on a non-running object
this->joined = 1;
{
consumer_stop( parent );
- this->running = 1;
- this->joined = 0;
-
-
pthread_mutex_lock( &mlt_sdl_mutex );
int ret = SDL_Init( SDL_INIT_AUDIO | SDL_INIT_NOPARACHUTE );
pthread_mutex_unlock( &mlt_sdl_mutex );
return -1;
}
+ this->running = 1;
+ this->joined = 0;
pthread_create( &this->thread, NULL, consumer_thread, this );
}
// Get the actual object
consumer_sdl this = parent->child;
- if ( this->joined == 0 )
+ if ( this->running && !this->joined )
{
// Kill the thread and clean up
this->joined = 1;
#endif
pthread_join( this->thread, NULL );
+ // Unlatch the video thread
+ pthread_mutex_lock( &this->video_mutex );
+ pthread_cond_broadcast( &this->video_cond );
+ pthread_mutex_unlock( &this->video_mutex );
+
// Unlatch the audio callback
pthread_mutex_lock( &this->audio_mutex );
pthread_cond_broadcast( &this->audio_cond );
pthread_mutex_unlock( &this->audio_mutex );
- SDL_QuitSubSystem( SDL_INIT_AUDIO );
+ if ( this->playing )
+ SDL_QuitSubSystem( SDL_INIT_AUDIO );
}
return 0;
int duration = 0;
int64_t playtime = 0;
struct timespec tm = { 0, 100000 };
- int last_position = -1;
+// int last_position = -1;
this->refresh_count = 0;
// Loop until told not to
pthread_mutex_unlock( &this->refresh_mutex );
}
else
+ {
mlt_frame_close( frame );
+ frame = NULL;
+ }
// Optimisation to reduce latency
- if ( speed == 1.0 )
+ if ( frame && speed == 1.0 )
{
// TODO: disabled due to misbehavior on parallel-consumer
// if ( last_position != -1 && last_position + 1 != mlt_frame_get_position( frame ) )
// mlt_consumer_purge( consumer );
- last_position = mlt_frame_get_position( frame );
+// last_position = mlt_frame_get_position( frame );
}
else
{
mlt_consumer_purge( consumer );
- last_position = -1;
+// last_position = -1;
}
}
}