DerivedDataReader.h

Go to the documentation of this file.

// -*- mode: C++; indent-tabs-mode: nil; c-basic-offset: 4; tab-width: 4; -*-
// vim: set shiftwidth=4 softtabstop=4 expandtab:
/*
 ********************************************************************
 ** NIDAS: NCAR In-situ Data Acquistion Software
 **
 ** 2007, Copyright University Corporation for Atmospheric Research
 **
 ** This program is free software; you can redistribute it and/or modify
 ** it under the terms of the GNU General Public License as published by
 ** the Free Software Foundation; either version 2 of the License, or
 ** (at your option) any later version.
 **
 ** This program 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 General Public License for more details.
 **
 ** The LICENSE.txt file accompanying this software contains
 ** a copy of the GNU General Public License. If it is not found,
 ** write to the Free Software Foundation, Inc.,
 ** 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA.
 **
 ********************************************************************
*/

#ifndef _nidas_core_DerivedDataReader_h_
#define _nidas_core_DerivedDataReader_h_

#include <nidas/util/SocketAddress.h>
#include <nidas/util/ParseException.h>
#include <nidas/util/Thread.h>

#include <vector>

namespace nidas { namespace core {

class DerivedDataClient;

class DerivedDataReader : public nidas::util::Thread
{
public:

    float getTrueAirspeed() const       { return _tas; }
    float getAmbientTemperature() const { return _at; }
    float getStaticPressure() const { return _ps; }
    float getLatitude() const       { return _lat; }
    float getLongitude() const      { return _lon; }
    float getAltitude() const       { return _alt; }
    float getRadarAltitude() const  { return _radarAlt; }
    float getTrueHeading() const        { return _thdg; }
    float getGroundSpeed() const        { return _grndSpd; }

    int run() throw(nidas::util::Exception);

    void addClient(DerivedDataClient * ddc);

    void removeClient(DerivedDataClient * ddc);

    static DerivedDataReader * createInstance(const nidas::util::SocketAddress&);

    static void deleteInstance();

    static DerivedDataReader * getInstance();

    void interrupt();

private:

    DerivedDataReader(const nidas::util::SocketAddress&);

    ~DerivedDataReader();

    void notifyClients();

    static DerivedDataReader * _instance;

    static nidas::util::Mutex _instanceMutex;

    nidas::util::Mutex _clientMutex;

    std::list<DerivedDataClient*> _clients;

    nidas::util::SocketAddress* _saddr;

    int parseIWGADTS(const char *);

    float _tas;     // True Airspeed.  Meters per second
    float _at;      // Ambient Temperature.  deg_C
    float _ps;      // Static Pressure.  hPa
    float _lat;         // Latitude, deg north
    float _lon;         // Longitude, deg east
    float _alt;     // Altitude (probably GPS).  Meters
    float _radarAlt;    // Distance above surface/ground.  Meters
    float _thdg;    // True Heading. degrees_true
    float _grndSpd; // Ground Speed. meters per second.

    int _parseErrors;
    int _errorLogs;

    struct IWG1_Field {
        IWG1_Field(int n,float* p): nf(n),fp(p) {}
        int nf;         // which field in the IWG1 string, after the "IWG1,timetag,"
        float *fp;      // pointer to the data
    };

    std::vector<IWG1_Field> _fields;

    DerivedDataReader(const DerivedDataReader&);

    DerivedDataReader& operator=(const DerivedDataReader&);

};

}}      // namespace nidas namespace core

#endif