Changeset 1149:cf7498bdfad5 in mediastreamer2

Timestamp:

Sep 13, 2010 11:26:33 PM (3 years ago)

Author:

Jehan Monnier <jehan.monnier@…>

Branch:

default

Message:

reduce amount of pthread signal (just in case)
set player/recorder threads to high prio

File:

• src/msandroid.cpp (modified) (8 diffs)

src/msandroid.cpp

@@ -29 +29 @@
 static void sound_read_setup(MSFilter *f);
 
+static void set_high_prio(void){
+        struct sched_param param;
+        int result=0;
+        memset(&param,0,sizeof(param));
+        int policy=SCHED_OTHER;
+        param.sched_priority=sched_get_priority_max(policy);
+        if((result=pthread_setschedparam(pthread_self(),policy, &param))) {
+                ms_warning("Set sched param failed with error code(%i)\n",result);
+        } else {
+                ms_message("msandroid thread priority set to max");
+        }
+}
 /*
  mediastreamer2 sound card functions
@@ -179 +191 @@
         jmethodID record_id=0;
 
+        set_high_prio();
 
         jint result = d->jvm->AttachCurrentThread(&jni_env,NULL);
@@ -428 +441 @@
 class msandroid_sound_write_data : public msandroid_sound_data{
 public:
-        msandroid_sound_write_data() :audio_track_class(0),audio_track(0),write_chunk_size(0),writtenBytes(0){
+        msandroid_sound_write_data() :audio_track_class(0),audio_track(0),write_chunk_size(0),writtenBytes(0),last_sample_date(0){
                 bufferizer = ms_bufferizer_new();
                 ms_cond_init(&cond,0);
@@ -445 +458 @@
         int                     write_chunk_size;
         unsigned int    writtenBytes;
+        unsigned long   last_sample_date;
+        bool sleeping;
         unsigned int getWriteBuffSize() {
                 return buff_size;
@@ -460 +475 @@
 
         jint result;
+        set_high_prio();
         int buff_size = d->getWriteBuffSize();
         result = d->jvm->AttachCurrentThread(&jni_env,NULL);
@@ -506 +522 @@
                         }
                 }
-                if (d->started) ms_cond_wait(&d->cond,&d->mutex);
+                if (d->started) {
+                        d->sleeping=true;
+                        ms_cond_wait(&d->cond,&d->mutex);
+                        d->sleeping=false;
+                }
                 ms_mutex_unlock(&d->mutex);
         }
@@ -665 +685 @@
                         ms_mutex_lock(&d->mutex);
                         ms_bufferizer_put(d->bufferizer,m);
-                        ms_cond_signal(&d->cond);
+                        if (d->sleeping)
+                                ms_cond_signal(&d->cond);
+                        d->last_sample_date=f->ticker->time;
                         ms_mutex_unlock(&d->mutex);
                 }else freemsg(m);
@@ -703 +725 @@
         ms_andsnd_jvm=jvm;
 }
+
+