DataCollectorTest.h

#ifndef CARMA_PIPELINE_DATACOLLECTORTEST_H
#define CARMA_PIPELINE_DATACOLLECTORTEST_H

namespace carma {
  namespace pipeline {
    
      class DataContainer;
    
      class DataCollectorTest {
      public:

        DataCollectorTest();

        DataCollectorTest(int bandNumber);

        virtual ~DataCollectorTest();

      private:    
        DataContainer*      _dataContainer;
        long                _numWritten; // number of consecutive writes
        int                 _bandNumber;

        void start();

        // must use a static method in pthread
        static void* staticStart(void* arg);
        void fillDataContainer();
        void update();
      };

  } // End namespace pipeline
} // End namespace carma

#endif