aboutsummaryrefslogtreecommitdiffstats
path: root/src/EtiReader.h
blob: be12075fb00e5c2b871f05a28ae020a2e0b6a0a9 (plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
/*
   Copyright (C) 2005, 2006, 2007, 2008, 2009, 2010, 2011 Her Majesty
   the Queen in Right of Canada (Communications Research Center Canada)

   Includes modifications for which no copyright is claimed
   2012, Matthias P. Braendli, matthias.braendli@mpb.li
 */
/*
   This file is part of ODR-DabMod.

   ODR-DabMod 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 3 of the
   License, or (at your option) any later version.

   ODR-DabMod 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.

   You should have received a copy of the GNU General Public License
   along with ODR-DabMod.  If not, see <http://www.gnu.org/licenses/>.
 */

#ifndef ETI_READER_H
#define ETI_READER_H

#ifdef HAVE_CONFIG_H
#   include <config.h>
#endif


#include "Eti.h"
#include "Log.h"
#include "FicSource.h"
#include "SubchannelSource.h"
#include "TimestampDecoder.h"

#include <vector>
#include <stdint.h>
#include <sys/types.h>


class EtiReader
{
public:
    EtiReader(struct modulator_offset_config& modconf, Logger& logger);
    virtual ~EtiReader();
    EtiReader(const EtiReader&);
    EtiReader& operator=(const EtiReader&);

    FicSource* getFic();
    unsigned getMode();
    unsigned getFp();
    const std::vector<SubchannelSource*>& getSubchannels();
    int process(Buffer* dataIn);

    void calculateTimestamp(struct frame_timestamp& ts)
    {
        myTimestampDecoder.calculateTimestamp(ts);
    }

    /* Return the frame counter */
    uint32_t getFCT();

    /* Returns true if we have valid time stamps in the ETI*/
    bool sourceContainsTimestamp();

protected:
    /* Main program logger */
    Logger& myLogger;

    /* Transform the ETI TIST to a PPS offset in ms */
    double getPPSOffset();

    void sync();
    int state;
    uint32_t nb_frames;
    uint16_t framesize;
    eti_SYNC eti_sync;
    eti_FC eti_fc;
    std::vector<eti_STC> eti_stc;
    eti_EOH eti_eoh;
    eti_EOF eti_eof;
    eti_TIST eti_tist;
    FicSource* myFicSource;
    std::vector<SubchannelSource*> mySources;
    TimestampDecoder myTimestampDecoder;
    
private:
    size_t myCurrentFrame;
    bool time_ext_enabled;
    unsigned long timestamp_seconds;
};


#endif // ETI_READER_H