Changeset 4230

Timestamp:

06/28/07 11:26:13 (6 years ago)

Author:

DrewCormier

Message:

code now works without latency problems. data gets storred in a big matrix, then written to file at the end

Files:

• components/FileOutput/branches/write_single_file/FileOutput.cpp (modified) (4 diffs)

components/FileOutput/branches/write_single_file/FileOutput.cpp

@@ -30 +30 @@
 
 #include "FileOutput.h"
+
+
+
+short Ibuf[8000][8192];
+short Qbuf[8000][8192];
+
+
 
 FileOutput_i::FileOutput_i(const char *uuid, omni_condition *condition) : Resource_impl(uuid), component_running(condition) 
@@ -132 +139 @@
 }
 
+static void write_data_bmlarc(std::ofstream  *fname)
+{
+    for(unsigned int j(0);j<8000;++j) {
+
+        for (unsigned int i(0); i < 8192; ++i) {
+                (*fname) << Ibuf[j][i] << " " << Qbuf[j][i] << std::endl;
+        }
+    }
+}
+
+static void buf_data(PortTypes::ShortSequence &I_in, PortTypes::ShortSequence &Q_in)
+{
+    static int Nrecords=0;
+
+    for (unsigned int i(0); i < I_in.length(); ++i) {
+        //(*fname) << I_in[i] << " " << Q_in[i] << std::endl;
+        Ibuf[Nrecords][i]=I_in[i]; 
+        Qbuf[Nrecords][i]=Q_in[i]; 
+   }
+   Nrecords++;
+}
+
 
 void FileOutput_i::process_data()
@@ -138 +167 @@
 
     PortTypes::ShortSequence *I_in(NULL), *Q_in(NULL);
+
+    //PortTypes::ShortSequence 
+ 
+    //static short Ibuf[8000][8192];
+    //static short Qbuf[8000][8192];
+
     unsigned int len(0);
     unsigned int numberEvents(0);  // count the number of packets that have been written
-    unsigned int maxEvents(1000);  // number of packets to write (1 second of ATSC data?
+    unsigned int maxEvents(8000);  // number of packets to write (1 second of ATSC data?
     std::ofstream *outFile(NULL);
 
@@ -149 +184 @@
         len = I_in->length();
 
-        if (numberEvents >= NumberFiles) {
-            dataIn_0->bufferEmptied();
-            continue;
-        }
-       
-        // Handle file state
-        if (numberEvents <= maxEvents){ 
-                if (numberEvents == 0) {// First packet: Open file and write data
-                        numberEvents++;
-                        std::ostringstream fname;
+        //std::cout << numberEvents << std::endl;
+
+        if (numberEvents <= maxEvents){
+                if (numberEvents < maxEvents) { // Write data
+                        //write_data(outFile, *I_in, *Q_in);
+                        buf_data(*I_in,*Q_in);
+                        numberEvents++;
+
+                } else if (numberEvents == maxEvents) {  //last desired packet
+                        std::ostringstream fname;
                         fname << FileName << numberEvents << ".dat"; 
                         outFile = new std::ofstream(fname.str().c_str());
 
-                        write_data(outFile, *I_in, *Q_in);
-
-                } else if (numberEvents < maxEvents) { // Write data
-                        write_data(outFile, *I_in, *Q_in);
+                        //write_data(outFile, *I_in, *Q_in);
+                        //buf_data(*I_in,*Q_in);
+
                         numberEvents++;
-
-                } else if (numberEvents == maxEvents) {  //last desired packet
-                        numberEvents++;
-                        write_data(outFile, *I_in, *Q_in);
+                        write_data_bmlarc(outFile);
                             delete(outFile);
                 }
         
         } else {
+
                 std::cout << "done writing data \n" ;
-                sleep(20);
+                //sleep(20);
         }