NetworkObsStreams.hpp

Go to the documentation of this file.

#pragma ident "$Id: $"

#ifndef GPSTK_NETWORK_OBS_STREAMS_HPP
#define GPSTK_NETWORK_OBS_STREAMS_HPP

//============================================================================
//
//  This file is part of GPSTk, the GPS Toolkit.
//
//  The GPSTk is free software; you can redistribute it and/or modify
//  it under the terms of the GNU Lesser General Public License as published
//  by the Free Software Foundation; either version 2.1 of the License, or
//  any later version.
//
//  The GPSTk is distributed in the hope that it will be useful,
//  but WITHOUT ANY WARRANTY; without even the implied warranty of
//  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
//  GNU Lesser General Public License for more details.
//
//  You should have received a copy of the GNU Lesser General Public
//  License along with GPSTk; if not, write to the Free Software Foundation,
//  Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
//
//  Wei Yan - Chinese Academy of Sciences . 2009, 2010, 2011
//
//============================================================================

#include <iostream>
#include <string>
#include <list>
#include <map>
#include "RinexObsStream.hpp"
#include "DataStructures.hpp"
#include "Synchronize.hpp"

namespace gpstk
{


      
   class NetworkObsStreams
   {
   public:
      NetworkObsStreams() : synchronizeException(false)
      {}

      virtual ~NetworkObsStreams()
      { cleanUp(); }
         
      bool addRinexObsFile(const std::string& obsFile);

      void setReferenceSource(const SourceID& refSource)
      { referenceSource = refSource; }


      void setSynchronizeException(const bool& synException = true)
      { synchronizeException = synException; }

      bool readEpochData(gnssDataMap& gdsMap)
         throw(SynchronizeException);
         
      SourceID sourceIDOfRinexObsFile(std::string obsFile);

      RinexObsStream* getRinexObsStream(const SourceID& source)
      { return mapSourceStream[source]; }

   protected:

      struct ObsData
      {
         std::string obsFile;
         
         SourceID obsSource;

         Synchronize* pSynchro;
         RinexObsStream* pObsStream;
      };

      std::list<ObsData> allStreamData;

      std::map<SourceID, RinexObsStream*> mapSourceStream;

      std::map<SourceID, Synchronize*> mapSourceSynchro;
     
      SourceID referenceSource;
         
      bool synchronizeException;

   private:
         // Do some clean operation 
      virtual void cleanUp();

   }; // End of class 'NetworkObsStreams'



}  // End of namespace gpstk

#endif   // NetworkObsStreams

---