source: ntrip/trunk/BNC/src/rinex/corrfile.cpp@ 6183

Last change on this file since 6183 was 6183, checked in by mervart, 8 years ago
File size: 3.5 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/* -------------------------------------------------------------------------
26 * BKG NTRIP Client
27 * -------------------------------------------------------------------------
28 *
29 * Class: t_corrFile
30 *
31 * Purpose: Reads DGPS Correction File
32 *
33 * Author: L. Mervart
34 *
35 * Created: 12-Feb-2012
36 *
37 * Changes:
38 *
39 * -----------------------------------------------------------------------*/
40
41#include <iostream>
42#include "corrfile.h"
43#include "bncutils.h"
44#include "bncephuser.h"
45
46using namespace std;
47
48// Constructor
49////////////////////////////////////////////////////////////////////////////
50t_corrFile::t_corrFile(QString fileName) {
51 expandEnvVar(fileName);
52 _file = new QFile(fileName);
53 _file->open(QIODevice::ReadOnly | QIODevice::Text);
54 _stream = new QTextStream();
55 _stream->setDevice(_file);
56 _lastOrbCorr = 0;
57 _lastClkCorr = 0;
58}
59
60// Destructor
61////////////////////////////////////////////////////////////////////////////
62t_corrFile::~t_corrFile() {
63 delete _stream;
64 delete _file;
65}
66
67// Read till a given time
68////////////////////////////////////////////////////////////////////////////
69void t_corrFile::syncRead(const bncTime& tt) {
70
71 if (stopRead(tt)) {
72 return;
73 }
74
75 _orbCorr.clear();
76 _clkCorr.clear();
77
78 while (_stream->status() == QTextStream::Ok && !_stream->atEnd()) {
79 QString line = _stream->readLine().trimmed();
80 if (line.isEmpty() || line[0] == '!') {
81 continue;
82 }
83 if (line[0] == 'O') {
84 delete _lastOrbCorr; _lastOrbCorr = new t_orbCorr(line.toAscii().data());
85 }
86 else if (line[0] == 'C') {
87 delete _lastClkCorr; _lastClkCorr = new t_clkCorr(line.toAscii().data());
88 }
89 if (stopRead(tt)) {
90 break;
91 }
92 }
93
94 if (_orbCorr.size() > 0) {
95 emit newOrbCorrections(_orbCorr);
96 _orbCorr.clear();
97 }
98 if (_clkCorr.size() > 0) {
99 emit newClkCorrections(_clkCorr);
100 _clkCorr.clear();
101 }
102}
103
104// Read till a given time
105////////////////////////////////////////////////////////////////////////////
106bool t_corrFile::stopRead(const bncTime& tt) {
107 if (_lastOrbCorr) {
108 if (_lastOrbCorr->_time > tt) {
109 return true;
110 }
111 else {
112 _orbCorr.push_back(*_lastOrbCorr);
113 _corrIODs[QString(_lastOrbCorr->_prn.toString().c_str())] = _lastOrbCorr->_iod;
114 delete _lastOrbCorr; _lastOrbCorr = 0;
115 }
116 }
117 if (_lastClkCorr) {
118 if (_lastClkCorr->_time > tt) {
119 return true;
120 }
121 else {
122 _clkCorr.push_back(*_lastClkCorr);
123 _corrIODs[QString(_lastClkCorr->_prn.toString().c_str())] = _lastClkCorr->_iod;
124 delete _lastClkCorr; _lastClkCorr = 0;
125 }
126 }
127 return false;
128}
Note: See TracBrowser for help on using the repository browser.