DataContainer.h

#ifndef CARMA_PIPELINE_DATACONTAINER_H
#define CARMA_PIPELINE_DATACONTAINER_H

#include "carma/util/PthreadMutex.h"
#include "carma/util/types.h"

#include <map>

namespace carma {

namespace correlator {
namespace lib {

class CorrelatorData;

}  // namespace carma::correlator::lib
}  // namespace carma::correlator

namespace pipeline {

class DataContainer {
    public:

        explicit DataContainer( );

        virtual ~DataContainer( );

        void getCorrelatorData( carma::correlator::lib::CorrelatorData * cd,
                                carma::util::frameType frame ) const;

        void fillCorrelatorData( 
            const carma::correlator::lib::CorrelatorData & cd );

        void setExpectedNumberOfBands( int expectedNumberOfBands );

        void clearCorrelatorData( carma::util::frameType olderThan );

        typedef ::std::map< int, int >                 LateBandMap;

        LateBandMap getLateBandMap( ) const;

        typedef ::std::map< int, int >                 DupBandMap;

        DupBandMap getDuplicateBandMap( ) const;

    private:

        DataContainer( const DataContainer & rhs );
        DataContainer & operator=( const DataContainer & rhs );

        mutable carma::util::PthreadMutex              guard_;
        typedef ::std::map< 
            carma::util::frameType,
            carma::correlator::lib::CorrelatorData * > CorrelatorDataMap;
        CorrelatorDataMap                              correlatorData_;
        int                                            expectedNumberOfBands_;
        carma::util::frameType                         oldestValidFrame_;
        
        mutable carma::util::PthreadMutex              lateBandMapGuard_;
        LateBandMap                                    lateBandMap_;
        
        mutable carma::util::PthreadMutex              dupBandMapGuard_;
        DupBandMap                                     dupBandMap_;
};


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


#endif