Changeset 8804

Timestamp:

02/26/09 10:58:57 (4 years ago)

Author:

jgaeddert

Message:

adding separate threads for playback, capture

Location:

ossiedev/branches/0.7.x/platform/AudioDevice/src

Files:

• AudioDevice.cpp (modified) (3 diffs)
• AudioDevice.h (modified) (2 diffs)

ossiedev/branches/0.7.x/platform/AudioDevice/src/AudioDevice.cpp

@@ -41 +41 @@
 
     // Start the capture_sound thread
-    processing_thread = new omni_thread(run, (void *) this);
-    processing_thread->start();
+    capture_thread = new omni_thread(run_capture, (void *) this);
+    capture_thread->start();
 
-    // TODO: start sound_playback thread
+    // Start playback_sound thread
+    playback_thread = new omni_thread(run_playback, (void *) this);
+    playback_thread->start();
 }
 
@@ -50 +52 @@
 AudioDevice_i::~AudioDevice_i()
 {
-
 }
 
 // static function for omni thread
-void AudioDevice_i::run( void * data )
+void AudioDevice_i::run_capture( void * data )
 {
     ((AudioDevice_i*) data)->capture_sound();
+}
+
+
+// static function for omni thread
+void AudioDevice_i::run_playback( void * data )
+{
+    ((AudioDevice_i*) data)->playback_sound();
 }
 
@@ -166 +174 @@
 }
 
+void AudioDevice_i::playback_sound()
+{
+    DEBUG(3, AudioDevice, "playback_sound() invoked")
+    PortTypes::ShortSequence L_out, R_out;
+
+    L_out.length(1);
+    R_out.length(1);
+   
+    while(1)
+    {
+        //dataOut->pushPacket(L_out, R_out);
+    }
+}
+

ossiedev/branches/0.7.x/platform/AudioDevice/src/AudioDevice.h

@@ -67 +67 @@
         throw (CF::Resource::StartError, CORBA::SystemException);
 
-    /// static function for omni thread
-    static void run( void * data );
+    /// static function for omni thread: capture_sound()
+    static void run_capture( void * data );
+
+    /// static function for omni thread: playback_sound()
+    static void run_playback( void * data );
 
     /// Sets isRunning to False (pause)
@@ -109 +112 @@
     void capture_sound();
 
+    /// main processing loop for playing sound
+    void playback_sound();
+
     omni_condition *component_running; ///< for component shutdown
-    omni_thread *processing_thread;    ///< for component writer function
+    omni_thread *capture_thread;    ///< for component writer function
+    omni_thread *playback_thread;    ///< for component writer function
 
     CORBA::UShort *simple_ptr;