Changeset 8583

Timestamp:

01/17/09 03:43:39 (4 years ago)

Author:

caguayog

Message:

Moving processing thread creation to start method. Mutex added for synchronization but may be unnecessary

Location:

ossiedev/trunk/components/TxDemo

Files:

• TxDemo.cpp (modified) (4 diffs)
• TxDemo.h (modified) (1 diff)

ossiedev/trunk/components/TxDemo/TxDemo.cpp

@@ -33 +33 @@
     // initialize packet delay to be 5 seconds
     packet_delay = 5000;
-
-    //Create the thread for the writer's processing function 
-    processing_thread = new omni_thread(Run, (void *) this);
-
-    //Start the thread containing the writer's processing function 
-    processing_thread->start();
-
 }
 
@@ -73 +66 @@
 {
     DEBUG(3, TxDemo, "start() invoked")
-    thread_started=true;
+    thread_started = true;    //initialize
+    //Create the thread for the writer's processing function 
+    processing_thread = new omni_thread(Run, (void *) this);
+
+    //Start the thread containing the writer's processing function 
+    processing_thread->start();
 }
 
@@ -79 +77 @@
 {  
     DEBUG(3, TxDemo, "stop() invoked")
+    processing_mutex.lock();
     thread_started=false;
+    processing_mutex.unlock();
 }
 
@@ -131 +131 @@
     }
 
-    while(true) {
-        if (thread_started) {
-            // push data to output
-            dataOutPort->pushPacket(I_out, Q_out);
-
-            // wait
-            usleep(packet_delay*1000);
-        }
+    while(continue_processing()) {
+        // push data to output
+        dataOutPort->pushPacket(I_out, Q_out);
+
+        // wait
+        usleep(packet_delay*1000);
     }
 }
-
+bool TxDemo_i::continue_processing(void)
+{
+    bool status;
+    processing_mutex.lock();
+    status = thread_started;
+    processing_mutex.unlock();
+    return status;
+}
 
 unsigned char data_i[512] = {

ossiedev/trunk/components/TxDemo/TxDemo.h

@@ -85 +85 @@
     /// Main signal processing method
     void ProcessData();
-    bool thread_started;
+    bool continue_processing(void);     ///< for start - stop processing
+    volatile bool thread_started;
+    omni_mutex processing_mutex;
    
     omni_condition *component_running;  ///< for component shutdown