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

Last change on this file since 6186 was 6186, 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 _orbCorr.clear();
72 _clkCorr.clear();
73
74 while (! stopRead(tt0 && _stream->status() == QTextStream::Ok && !_stream->atEnd()) {
75 QString line = _stream->readLine().trimmed();
76 if (line.isEmpty() || line[0] == '!') {
77 continue;
78 }
79 if (line[0] == 'O') {
80 delete _lastOrbCorr; _lastOrbCorr = new t_orbCorr(line.toAscii().data());
81 }
82 else if (line[0] == 'C') {
83 delete _lastClkCorr; _lastClkCorr = new t_clkCorr(line.toAscii().data());
84 }
85 if (stopRead(tt)) {
86 break;
87 }
88 }
89
90 if (_orbCorr.size() > 0) {
91 emit newOrbCorrections(_orbCorr);
92 _orbCorr.clear();
93 }
94 if (_clkCorr.size() > 0) {
95 emit newClkCorrections(_clkCorr);
96 _clkCorr.clear();
97 }
98}
99
100// Read till a given time
101////////////////////////////////////////////////////////////////////////////
102bool t_corrFile::stopRead(const bncTime& tt) {
103 if (_lastOrbCorr) {
104 if (_lastOrbCorr->_time > tt) {
105 return true;
106 }
107 else {
108 _orbCorr.push_back(*_lastOrbCorr);
109 _corrIODs[QString(_lastOrbCorr->_prn.toString().c_str())] = _lastOrbCorr->_iod;
110 delete _lastOrbCorr; _lastOrbCorr = 0;
111 }
112 }
113 if (_lastClkCorr) {
114 if (_lastClkCorr->_time > tt) {
115 return true;
116 }
117 else {
118 _clkCorr.push_back(*_lastClkCorr);
119 _corrIODs[QString(_lastClkCorr->_prn.toString().c_str())] = _lastClkCorr->_iod;
120 delete _lastClkCorr; _lastClkCorr = 0;
121 }
122 }
123 return false;
124}
Note: See TracBrowser for help on using the repository browser.