Changeset 2301

Timestamp:

12/01/06 13:38:37 (6 years ago)

Author:

balister

Message:

Code complete, needs testing.

Location:

components/FileOutput/trunk/FileOutput

Files:

• FileOutput.cpp (modified) (2 diffs)
• FileOutput.h (modified) (1 diff)
• FileOutput.prf.xml (modified) (1 diff)

components/FileOutput/trunk/FileOutput/FileOutput.cpp

@@ -24 +24 @@
 #include <string>
 #include <iostream>
+#include <sstream>
+#include <fstream>
+
 #include "FileOutput.h"
 
@@ -119 +122 @@
 }
 
+static void write_data(std::ofstream  *fname, PortTypes::ShortSequence &I_in, PortTypes::ShortSequence &Q_in)
+{
+
+    for (unsigned int i(0); i < I_in.length(); ++i) {
+        (*fname) << I_in[i] << " " << Q_in[i] << std::endl;
+    }
+}
+
+
 void FileOutput_i::process_data()
 {
     std::cout << "FileOutput's process_data thread started" << std::endl;
 
+    PortTypes::ShortSequence *I_in(NULL), *Q_in(NULL);
+    unsigned int len(0);
+    bool trigger(false), last_trigger(false);
+    unsigned int numberEvents(0);
+    std::ofstream *outFile(NULL);
 
 
-    PortTypes::ShortSequence *I_in_0(NULL), *Q_in_0(NULL);
-    CORBA::UShort I_in_0_length, Q_in_0_length;
+    while(1) {
+        dataIn_0->getData(I_in, Q_in);
 
-    while(1)
-    {
-        dataIn_0->getData(I_in_0, Q_in_0);
+        len = I_in->length();
 
-        I_in_0_length = I_in_0->length();
-        Q_in_0_length = Q_in_0->length();
+        if (numberEvents > NumberFiles) {
+            dataIn_0->bufferEmptied();
+            continue;
+        }
 
-        /*insert code here to do work*/
+        // calculate energy
+        unsigned int energy(0);
+        for (unsigned int i(0); i < len; ++i) {
+            if (abs((*I_in)[i]) > abs((*Q_in)[i])) 
+                energy += (*I_in)[i];
+            else
+                energy += (*Q_in)[i];
+        }
+        energy /= len;
 
+        // Do we write data?
+        if (energy > TriggerThreshold)
+            trigger = true;
+        else
+            trigger = false;
 
+        // Handle file state
+        if (trigger == true && last_trigger == false) {// Open file and write data
+            numberEvents++;
+            std::ostringstream fname;
+            fname << FileName << numberEvents << ".dat"; 
+            outFile = new std::ofstream(fname.str().c_str());
 
-
-
+            write_data(outFile, *I_in, *Q_in);
+        } else if (trigger == true && last_trigger == true) { // Write data
+            write_data(outFile, *I_in, *Q_in);
+        } else if (trigger == false && last_trigger == true) { // Write data and close
+            write_data(outFile, *I_in, *Q_in);
+            delete(outFile);
+        }
+        last_trigger = trigger;
 
         dataIn_0->bufferEmptied();

components/FileOutput/trunk/FileOutput/FileOutput.h

@@ -69 +69 @@
         
         std::string FileName;
-        short TriggerThreshold;
-        short NumberFiles;
+        unsigned short TriggerThreshold;
+        unsigned short NumberFiles;
         std::string FileFormat;
 

components/FileOutput/trunk/FileOutput/FileOutput.prf.xml

@@ -6 +6 @@
     <simple type="string" id="DCE:c2654772-ac2c-42be-8f0b-d6c7a4b0fa49" name="FileName" mode="readonly">
         <description>File Name for output data</description> 
-        <value>myData.dat</value> 
+        <value>myData</value> 
         <kind kindtype="configure"/>
     </simple>