source: ntrip/trunk/BNC/RTCM/RTCM2Decoder.h@ 2761

Last change on this file since 2761 was 2492, checked in by stoecker, 14 years ago

removed double storage of RTCM3 stuff

File size: 3.9 KB
Line 
1// Part of BNC, a utility for retrieving decoding and
2// converting GNSS data streams from NTRIP broadcasters.
3//
4// Copyright (C) 2007
5// German Federal Agency for Cartography and Geodesy (BKG)
6// http://www.bkg.bund.de
7// Czech Technical University Prague, Department of Geodesy
8// http://www.fsv.cvut.cz
9//
10// Email: euref-ip@bkg.bund.de
11//
12// This program is free software; you can redistribute it and/or
13// modify it under the terms of the GNU General Public License
14// as published by the Free Software Foundation, version 2.
15//
16// This program is distributed in the hope that it will be useful,
17// but WITHOUT ANY WARRANTY; without even the implied warranty of
18// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
19// GNU General Public License for more details.
20//
21// You should have received a copy of the GNU General Public License
22// along with this program; if not, write to the Free Software
23// Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA.
24
25#ifndef INC_RTCM2DECODER_H
26#define INC_RTCM2DECODER_H
27
28#include <map>
29#include <vector>
30#include <list>
31
32#include "GPSDecoder.h"
33#include "RTCM2.h"
34#include "RTCM2_2021.h"
35#include "rtcm3torinex.h"
36#include "ephemeris.h"
37
38class RTCM2Decoder: public GPSDecoder {
39
40 public:
41 RTCM2Decoder(const std::string& ID);
42 virtual ~RTCM2Decoder();
43 virtual t_irc Decode(char* buffer, int bufLen, std::vector<std::string>& errmsg);
44
45 bool storeEph(const gpsephemeris& gpseph, std::string& storedPRN, std::vector<int>& IODs);
46 bool storeEph(const t_ephGPS& gpseph, std::string& storedPRN, std::vector<int>& IODs);
47
48 t_irc getStaCrd(double& xx, double& yy, double& zz);
49
50 t_irc getStaCrd(double& xx, double& yy, double& zz,
51 double& dx1, double& dy1, double& dz1,
52 double& dx2, double& dy2, double& dz2);
53
54 const rtcm2::RTCM2_2021& msg2021() const { return _msg2021; }
55
56 std::string ID() const { return _ID; }
57
58 private:
59
60 class t_ephList {
61 public:
62 t_ephList() {}
63
64 ~t_ephList() {
65 for (std::list<t_eph*>::iterator ii = _eph.begin(); ii != _eph.end(); ii++) {
66 delete (*ii);
67 }
68 }
69
70 bool store(t_eph* eph) {
71 if ( _eph.size() == 0 ) {
72 _eph.push_back(eph);
73 return true;
74 }
75
76 std::list<t_eph*>::iterator ii = _eph.begin();
77 while (ii != _eph.end()) {
78 if ( eph->IOD() == (*ii)->IOD() ) {
79 return false;
80 }
81 if ( ! eph->isNewerThan(*ii) ) {
82 break;
83 }
84 ++ii;
85 }
86
87 if ( ii == _eph.begin() && _eph.size() == MAXSIZE) {
88 return false;
89 }
90
91 _eph.insert(ii, eph);
92
93 while ( _eph.size() > MAXSIZE ) {
94 delete _eph.front();
95 _eph.pop_front();
96 }
97
98 return true;
99 }
100
101 const t_eph* getEph(int IOD) const {
102 for (std::list<t_eph*>::const_iterator ii = _eph.begin(); ii != _eph.end(); ii++) {
103 if ( (*ii)->IOD() == IOD ) {
104 return (*ii);
105 }
106 }
107 return 0;
108 }
109
110 void getIODs(std::vector<int>& IODs) const {
111 IODs.clear();
112 for (std::list<t_eph*>::const_iterator ii = _eph.begin(); ii != _eph.end(); ii++) {
113 IODs.push_back((*ii)->IOD());
114 }
115 }
116
117 static const unsigned MAXSIZE = 5;
118
119 std::list<t_eph*> _eph;
120 };
121
122 void translateCorr2Obs(std::vector<std::string>& errmsg);
123
124 std::string _ID;
125
126 std::string _buffer;
127 rtcm2::RTCM2packet _PP;
128
129 // for messages 18, 19 decoding
130 rtcm2::RTCM2_Obs _ObsBlock;
131
132 // for messages 20, 21 decoding
133 rtcm2::RTCM2_03 _msg03;
134 rtcm2::RTCM2_22 _msg22;
135 rtcm2::RTCM2_23 _msg23;
136 rtcm2::RTCM2_24 _msg24;
137 rtcm2::RTCM2_2021 _msg2021;
138 std::map<std::string, t_ephList*> _ephList;
139
140 typedef std::map<std::string, t_ephList*> t_listMap;
141};
142
143#endif // include blocker
Note: See TracBrowser for help on using the repository browser.