Changeset 165 in pacpusframework for branches/2.0-beta1/examples

Timestamp:

Aug 1, 2013, 6:30:31 PM (11 years ago)

Author:

Marek Kurdej

Message:

Major: changed plugins section name to plugings. Parameters section will be used for something else.

Location:

branches/2.0-beta1/examples/ProducerConsumerExample

Files:

• ConsumerExample.cpp (modified) (2 diffs)
• ProducerConsumerExample.xml (modified) (1 diff)
• ProducerExample.cpp (modified) (3 diffs)

branches/2.0-beta1/examples/ProducerConsumerExample/ConsumerExample.cpp

@@ -52 +52 @@
     LOG_TRACE(Q_FUNC_INFO);
     moveToThread(&thread);
+    m_counter = 0;
     
-    m_counter = 0;
-    static const char * outputFileName = "test2.txt";
+    static const char * outputFileName = "consumer.txt";
     m_file.open(outputFileName, std::ios_base::out | std::ios_base::app);
     if (!m_file.is_open()) {
@@ -77 +77 @@
 void ConsumerExample::process(const QImage& matrix)
 {
-    LOG_INFO("Size " << matrix.size().width()<< " x " << matrix.size().height());
-    unsigned int k = 0;
+    m_file << ++m_counter << " " << road_time() << "\n" << std::flush;
 
-    // a process
-    for (int i = 0; i < 100; ++i) {
-        ++k;
-    }
-    m_file << ++m_counter << " " << road_time() << "\n";
+    LOG_INFO("Received QIMage: "
+        << "size = " << matrix.size().width()<< " x " << matrix.size().height()
+        );
+
+    // DO PROCESSING
 
     setState(MONITOR_OK);

branches/2.0-beta1/examples/ProducerConsumerExample/ProducerConsumerExample.xml

@@ -10 +10 @@
     </connections>
 
-    <!-- FIXME: change into plugins -->
-    <parameters prefix="" postfix="_d" extension="dll">
+    <plugins prefix="" postfix="" extension="dll">
         <plugin lib="ProducerConsumerExample" />
-        <plugin lib="ShMem" />
+    </plugins>
+    
+    <parameters>
     </parameters>
 </pacpus>

branches/2.0-beta1/examples/ProducerConsumerExample/ProducerExample.cpp

@@ -71 +71 @@
 void ProducerExample::run()
 {
-    unsigned int counter = 0;
-    int waitTime = 5000;
+    unsigned int counter = 1;
+    int waitTimeMicros = 150 * 1000;
 
     std::fstream file(outputFileName, std::ios_base::out | std::ios_base::app);
@@ -87 +87 @@
     while (isActive()) {
         //mat.setPixel(0,0,i);
-        LOG_INFO("Size " << mat.size().width()<< " x " << mat.size().height());
+        LOG_INFO("Sent QImage: "
+            << "size = " << mat.size().width()<< " x " << mat.size().height()
+            );
 
         if (imageOutput && imageOutput->hasConnection()) {
@@ -93 +95 @@
         }
 
-        LOG_INFO("Send data " << counter << " time " << road_time());
-        file << ++counter << " " << road_time() << "\n";
+        LOG_INFO("Sent data=" << counter << ", time=" << road_time());
+        file << counter << " " << road_time() << "\n" << std::flush;
 
-        usleep(waitTime);
+        usleep(waitTimeMicros);
         ++counter;
         setState(MONITOR_OK);