source: ntrip/trunk/BNC/src/bnccore.cpp@ 5900

Last change on this file since 5900 was 5900, checked in by mervart, 8 years ago
File size: 24.7 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_bncCore
30 *
31 * Purpose: This class implements the main application
32 *
33 * Author: L. Mervart
34 *
35 * Created: 29-Aug-2006
36 *
37 * Changes:
38 *
39 * -----------------------------------------------------------------------*/
40
41#include <iostream>
42#include <QMessageBox>
43#include <cmath>
44
45#include "bnccore.h"
46#include "bncutils.h"
47#include "bncrinex.h"
48#include "bncsettings.h"
49#include "bncversion.h"
50#include "ephemeris.h"
51#include "rinex/rnxobsfile.h"
52#include "rinex/rnxnavfile.h"
53#include "PPP/pppMain.h"
54
55#ifdef USE_COMBINATION
56#include "combination/bnccomb.h"
57#endif
58
59using namespace std;
60
61// Singleton
62////////////////////////////////////////////////////////////////////////////
63t_bncCore* t_bncCore::instance() {
64 static t_bncCore _bncCore;
65 return &_bncCore;
66}
67
68// Constructor
69////////////////////////////////////////////////////////////////////////////
70t_bncCore::t_bncCore() {
71 _GUIenabled = true;
72 _logFileFlag = 0;
73 _logFile = 0;
74 _logStream = 0;
75 _rawFile = 0;
76 _caster = 0;
77#ifdef USE_COMBINATION
78 _bncComb = 0;
79#endif
80
81 // Lists of Ephemeris
82 // ------------------
83 for (int ii = PRN_GPS_START; ii <= PRN_GPS_END; ii++) {
84 _gpsEph[ii-PRN_GPS_START] = 0;
85 }
86 for (int ii = PRN_GLONASS_START; ii <= PRN_GLONASS_END; ii++) {
87 _glonassEph[ii-PRN_GLONASS_START] = 0;
88 }
89 for (int ii = PRN_GALILEO_START; ii <= PRN_GALILEO_END; ii++) {
90 _galileoEph[ii-PRN_GALILEO_START] = 0;
91 }
92
93 // Eph file(s)
94 // -----------
95 _rinexVers = 0;
96 _ephFileGPS = 0;
97 _ephStreamGPS = 0;
98 _ephFileGlonass = 0;
99 _ephStreamGlonass = 0;
100 _ephFileGalileo = 0;
101 _ephStreamGalileo = 0;
102
103 _port = 0;
104 _server = 0;
105 _sockets = 0;
106
107 _portCorr = 0;
108 _serverCorr = 0;
109 _socketsCorr = 0;
110
111 _pgmName = QString(BNCPGMNAME).leftJustified(20, ' ', true);
112#ifdef WIN32
113 _userName = QString("${USERNAME}");
114#else
115 _userName = QString("${USER}");
116#endif
117 expandEnvVar(_userName);
118 _userName = _userName.leftJustified(20, ' ', true);
119
120 _corrs = new QMultiMap<bncTime, QString>;
121
122 _dateAndTimeGPS = 0;
123
124 for (int ii = 0; ii < PRN_GLONASS_NUM; ++ii) {
125 _GLOFreq[ii] = 0;
126 }
127
128 _mainWindow = 0;
129
130 _pppMain = new BNC_PPP::t_pppMain();
131}
132
133// Destructor
134////////////////////////////////////////////////////////////////////////////
135t_bncCore::~t_bncCore() {
136 delete _logStream;
137 delete _logFile;
138 delete _ephStreamGPS;
139 delete _ephFileGPS;
140 delete _server;
141 delete _sockets;
142 delete _serverCorr;
143 delete _socketsCorr;
144 if (_rinexVers == 2) {
145 delete _ephStreamGlonass;
146 delete _ephFileGlonass;
147 }
148 for (int ii = PRN_GPS_START; ii <= PRN_GPS_END; ii++) {
149 delete _gpsEph[ii-PRN_GPS_START];
150 }
151 for (int ii = PRN_GLONASS_START; ii <= PRN_GLONASS_END; ii++) {
152 delete _glonassEph[ii-PRN_GLONASS_START];
153 }
154 for (int ii = PRN_GALILEO_START; ii <= PRN_GALILEO_END; ii++) {
155 delete _galileoEph[ii-PRN_GALILEO_START];
156 }
157
158 delete _corrs;
159
160 delete _dateAndTimeGPS;
161
162 delete _rawFile;
163
164#ifdef USE_COMBINATION
165 delete _bncComb;
166#endif
167}
168
169// Write a Program Message
170////////////////////////////////////////////////////////////////////////////
171void t_bncCore::slotMessage(QByteArray msg, bool showOnScreen) {
172
173 QMutexLocker locker(&_mutexMessage);
174
175 messagePrivate(msg);
176 emit newMessage(msg, showOnScreen);
177}
178
179// Write a Program Message (private, no lock)
180////////////////////////////////////////////////////////////////////////////
181void t_bncCore::messagePrivate(const QByteArray& msg) {
182
183 // First time resolve the log file name
184 // ------------------------------------
185 QDate currDate = currentDateAndTimeGPS().date();
186 if (_logFileFlag == 0 || _fileDate != currDate) {
187 delete _logStream; _logStream = 0;
188 delete _logFile; _logFile = 0;
189 _logFileFlag = 1;
190 bncSettings settings;
191 QString logFileName = settings.value("logFile").toString();
192 if ( !logFileName.isEmpty() ) {
193 expandEnvVar(logFileName);
194 _logFile = new QFile(logFileName + "_" +
195 currDate.toString("yyMMdd").toAscii().data());
196 _fileDate = currDate;
197 if ( Qt::CheckState(settings.value("rnxAppend").toInt()) == Qt::Checked) {
198 _logFile->open(QIODevice::WriteOnly | QIODevice::Append);
199 }
200 else {
201 _logFile->open(QIODevice::WriteOnly);
202 }
203 _logStream = new QTextStream();
204 _logStream->setDevice(_logFile);
205 }
206 }
207
208 if (_logStream) {
209 QByteArray msgLocal = msg;
210 if (msg.indexOf('\n') == 0) {
211 *_logStream << endl;
212 msgLocal = msg.mid(1);
213 }
214 *_logStream << currentDateAndTimeGPS().toString("yy-MM-dd hh:mm:ss ").toAscii().data();
215 *_logStream << msgLocal.data() << endl;
216 _logStream->flush();
217 _logFile->flush();
218 }
219}
220
221// New GPS Ephemeris
222////////////////////////////////////////////////////////////////////////////
223void t_bncCore::slotNewGPSEph(gpsephemeris* gpseph) {
224
225 QMutexLocker locker(&_mutex);
226
227 gpsephemeris copy_gpseph = *gpseph;
228 emit newEphGPS(copy_gpseph);
229
230 printEphHeader();
231
232 gpsephemeris** ee = &_gpsEph[gpseph->satellite-1];
233
234 if ( *ee != 0 &&
235 gpseph->GPSweek == (*ee)->GPSweek && gpseph->TOC == (*ee)->TOC ) {
236 checkEphemeris(*ee, gpseph);
237 }
238
239 if ( *ee == 0 ||
240 gpseph->GPSweek > (*ee)->GPSweek ||
241 (gpseph->GPSweek == (*ee)->GPSweek && gpseph->TOC > (*ee)->TOC) ) {
242 delete *ee;
243 *ee = gpseph;
244 printGPSEph(gpseph, true);
245 }
246 else {
247 printGPSEph(gpseph, false);
248 delete gpseph;
249 }
250}
251
252// New Glonass Ephemeris
253////////////////////////////////////////////////////////////////////////////
254void t_bncCore::slotNewGlonassEph(glonassephemeris* glonasseph, const QString& staID) {
255
256 QMutexLocker locker(&_mutex);
257
258 // Check wrong Ephemerides
259 // -----------------------
260 if (glonasseph->x_pos == 0.0 &&
261 glonasseph->y_pos == 0.0 &&
262 glonasseph->z_pos == 0.0) {
263 delete glonasseph;
264 return;
265 }
266
267 glonassephemeris copy_glonasseph = *glonasseph;
268 emit newEphGlonass(copy_glonasseph);
269
270 printEphHeader();
271
272 glonassephemeris** ee = &_glonassEph[glonasseph->almanac_number-1];
273
274 int wwOld, towOld, wwNew, towNew;
275 if (*ee != 0) {
276 wwOld = (*ee)->GPSWeek;
277 towOld = (*ee)->GPSTOW;
278 updatetime(&wwOld, &towOld, (*ee)->tb*1000, 0); // Moscow -> GPS
279
280 wwNew = glonasseph->GPSWeek;
281 towNew = glonasseph->GPSTOW;
282 updatetime(&wwNew, &towNew, glonasseph->tb*1000, 0); // Moscow -> GPS
283 }
284
285 if ( *ee == 0 ||
286 wwNew > wwOld ||
287 (wwNew == wwOld && towNew > towOld) ) {
288 delete *ee;
289 *ee = glonasseph;
290 printGlonassEph(glonasseph, true, staID);
291 }
292 else {
293 printGlonassEph(glonasseph, false, staID);
294 delete glonasseph;
295 }
296}
297
298// New Galileo Ephemeris
299////////////////////////////////////////////////////////////////////////////
300void t_bncCore::slotNewGalileoEph(galileoephemeris* galileoeph) {
301
302 QMutexLocker locker(&_mutex);
303
304 galileoephemeris copy_galileoeph = *galileoeph;
305 emit newEphGalileo(copy_galileoeph);
306
307 printEphHeader();
308
309 int galIndex = galileoeph->satellite;
310 /* GIOVE */
311 if(galIndex == 51) galIndex = 1;
312 else if(galIndex == 52) galIndex = 16;
313 if (galIndex < 0 || galIndex > PRN_GALILEO_END - PRN_GALILEO_START) {
314 emit( newMessage("Wrong Galileo Satellite Number", true) );
315 exit(1);
316 }
317
318 galileoephemeris** ee = &_galileoEph[galIndex];
319
320 if ( *ee == 0 ||
321 galileoeph->Week > (*ee)->Week ||
322 (galileoeph->Week == (*ee)->Week && galileoeph->TOC > (*ee)->TOC) ) {
323 delete *ee;
324 *ee = galileoeph;
325 printGalileoEph(galileoeph, true);
326 }
327 else {
328 printGalileoEph(galileoeph, false);
329 delete galileoeph;
330 }
331}
332
333// Print Header of the output File(s)
334////////////////////////////////////////////////////////////////////////////
335void t_bncCore::printEphHeader() {
336
337 bncSettings settings;
338
339 // Initialization
340 // --------------
341 if (_rinexVers == 0) {
342
343 if ( Qt::CheckState(settings.value("ephV3").toInt()) == Qt::Checked) {
344 _rinexVers = 3;
345 }
346 else {
347 _rinexVers = 2;
348 }
349
350 _ephPath = settings.value("ephPath").toString();
351
352 if ( !_ephPath.isEmpty() ) {
353 if ( _ephPath[_ephPath.length()-1] != QDir::separator() ) {
354 _ephPath += QDir::separator();
355 }
356 expandEnvVar(_ephPath);
357 }
358 }
359
360 // (Re-)Open output File(s)
361 // ------------------------
362 if (!_ephPath.isEmpty()) {
363
364 QDateTime datTim = currentDateAndTimeGPS();
365
366 QString ephFileNameGPS = _ephPath + "BRDC" +
367 QString("%1").arg(datTim.date().dayOfYear(), 3, 10, QChar('0'));
368
369 QString hlpStr = bncRinex::nextEpochStr(datTim,
370 settings.value("ephIntr").toString());
371
372 if (_rinexVers == 3) {
373 ephFileNameGPS += hlpStr + datTim.toString(".yyP");
374 }
375 else {
376 ephFileNameGPS += hlpStr + datTim.toString(".yyN");
377 }
378
379 if (_ephFileNameGPS == ephFileNameGPS) {
380 return;
381 }
382 else {
383 _ephFileNameGPS = ephFileNameGPS;
384 }
385
386 for (int ii = PRN_GPS_START; ii <= PRN_GPS_END; ii++) {
387 delete _gpsEph[ii-PRN_GPS_START];
388 _gpsEph[ii-PRN_GPS_START] = 0;
389 }
390 for (int ii = PRN_GLONASS_START; ii <= PRN_GLONASS_END; ii++) {
391 delete _glonassEph[ii-PRN_GLONASS_START];
392 _glonassEph[ii-PRN_GLONASS_START] = 0;
393 }
394 for (int ii = PRN_GALILEO_START; ii <= PRN_GALILEO_END; ii++) {
395 delete _galileoEph[ii-PRN_GALILEO_START];
396 _galileoEph[ii-PRN_GALILEO_START] = 0;
397 }
398
399 delete _ephStreamGPS;
400 delete _ephFileGPS;
401
402 QFlags<QIODevice::OpenModeFlag> appendFlagGPS;
403 QFlags<QIODevice::OpenModeFlag> appendFlagGlonass;
404 QFlags<QIODevice::OpenModeFlag> appendFlagGalileo;
405
406 if ( Qt::CheckState(settings.value("rnxAppend").toInt()) == Qt::Checked &&
407 QFile::exists(ephFileNameGPS) ) {
408 appendFlagGPS = QIODevice::Append;
409 }
410
411 _ephFileGPS = new QFile(ephFileNameGPS);
412 _ephFileGPS->open(QIODevice::WriteOnly | appendFlagGPS);
413 _ephStreamGPS = new QTextStream();
414 _ephStreamGPS->setDevice(_ephFileGPS);
415
416 if (_rinexVers == 3) {
417 _ephFileGlonass = _ephFileGPS;
418 _ephStreamGlonass = _ephStreamGPS;
419 _ephFileGalileo = _ephFileGPS;
420 _ephStreamGalileo = _ephStreamGPS;
421 }
422 else if (_rinexVers == 2) {
423 QString ephFileNameGlonass = _ephPath + "BRDC" +
424 QString("%1").arg(datTim.date().dayOfYear(), 3, 10, QChar('0')) +
425 hlpStr + datTim.toString(".yyG");
426
427 delete _ephStreamGlonass;
428 delete _ephFileGlonass;
429
430 if ( Qt::CheckState(settings.value("rnxAppend").toInt()) == Qt::Checked &&
431 QFile::exists(ephFileNameGlonass) ) {
432 appendFlagGlonass = QIODevice::Append;
433 }
434
435 _ephFileGlonass = new QFile(ephFileNameGlonass);
436 _ephFileGlonass->open(QIODevice::WriteOnly | appendFlagGlonass);
437 _ephStreamGlonass = new QTextStream();
438 _ephStreamGlonass->setDevice(_ephFileGlonass);
439 }
440
441 // Header - RINEX Version 3
442 // ------------------------
443 if (_rinexVers == 3) {
444 if ( ! (appendFlagGPS & QIODevice::Append)) {
445 QString line;
446 line.sprintf(
447 "%9.2f%11sN: GNSS NAV DATA M: Mixed%12sRINEX VERSION / TYPE\n",
448 3.0, "", "");
449 *_ephStreamGPS << line;
450
451 QString hlp = currentDateAndTimeGPS().toString("yyyyMMdd hhmmss UTC").leftJustified(20, ' ', true);
452 *_ephStreamGPS << _pgmName.toAscii().data()
453 << _userName.toAscii().data()
454 << hlp.toAscii().data()
455 << "PGM / RUN BY / DATE" << endl;
456
457 line.sprintf("%60sEND OF HEADER\n", "");
458 *_ephStreamGPS << line;
459
460 _ephStreamGPS->flush();
461 }
462 }
463
464 // Headers - RINEX Version 2
465 // -------------------------
466 else if (_rinexVers == 2) {
467 if (! (appendFlagGPS & QIODevice::Append)) {
468 QString line;
469 line.sprintf("%9.2f%11sN: GPS NAV DATA%25sRINEX VERSION / TYPE\n",
470 t_rnxNavFile::defaultRnxNavVersion2, "", "");
471 *_ephStreamGPS << line;
472
473 QString hlp = currentDateAndTimeGPS().date().toString("dd-MMM-yyyy").leftJustified(20, ' ', true);
474 *_ephStreamGPS << _pgmName.toAscii().data()
475 << _userName.toAscii().data()
476 << hlp.toAscii().data()
477 << "PGM / RUN BY / DATE" << endl;
478
479 line.sprintf("%60sEND OF HEADER\n", "");
480 *_ephStreamGPS << line;
481
482 _ephStreamGPS->flush();
483 }
484 if (! (appendFlagGlonass & QIODevice::Append)) {
485 QString line;
486 line.sprintf("%9.2f%11sG: GLONASS NAV DATA%21sRINEX VERSION / TYPE\n",
487 t_rnxNavFile::defaultRnxNavVersion2, "", "");
488 *_ephStreamGlonass << line;
489
490 QString hlp = currentDateAndTimeGPS().date().toString("dd-MMM-yyyy").leftJustified(20, ' ', true);
491 *_ephStreamGlonass << _pgmName.toAscii().data()
492 << _userName.toAscii().data()
493 << hlp.toAscii().data()
494 << "PGM / RUN BY / DATE" << endl;
495
496 line.sprintf("%60sEND OF HEADER\n", "");
497 *_ephStreamGlonass << line;
498
499 _ephStreamGlonass->flush();
500 }
501 }
502 }
503}
504
505// Print One GPS Ephemeris
506////////////////////////////////////////////////////////////////////////////
507void t_bncCore::printGPSEph(gpsephemeris* ep, bool printFile) {
508
509 t_ephGPS eph;
510 eph.set(ep);
511
512 QString strV2 = eph.toString(t_rnxNavFile::defaultRnxNavVersion2);
513 QString strV3 = eph.toString(t_rnxObsHeader::defaultRnxObsVersion3);
514
515 printOutput(printFile, _ephStreamGPS, strV2, strV3);
516}
517
518// Print One Glonass Ephemeris
519////////////////////////////////////////////////////////////////////////////
520void t_bncCore::printGlonassEph(glonassephemeris* ep, bool printFile, const QString& /* staID */) {
521
522 t_ephGlo eph;
523 eph.set(ep);
524
525 QString strV2 = eph.toString(t_rnxNavFile::defaultRnxNavVersion2);
526 QString strV3 = eph.toString(t_rnxObsHeader::defaultRnxObsVersion3);
527
528 //// beg test Dirk
529 // QString hlp = strV2;
530 // cout << hlp.replace('\n', ' ').toAscii().data() << ' ' << staID.toAscii().data() << endl;
531 //// end test Dirk
532
533 printOutput(printFile, _ephStreamGlonass, strV2, strV3);
534}
535
536// Print One Galileo Ephemeris
537////////////////////////////////////////////////////////////////////////////
538void t_bncCore::printGalileoEph(galileoephemeris* ep, bool printFile) {
539
540 t_ephGal eph;
541 eph.set(ep);
542
543 QString strV2 = eph.toString(t_rnxNavFile::defaultRnxNavVersion2);
544 QString strV3 = eph.toString(t_rnxObsHeader::defaultRnxObsVersion3);
545
546 printOutput(printFile, _ephStreamGalileo, strV2, strV3);
547}
548
549// Output
550////////////////////////////////////////////////////////////////////////////
551void t_bncCore::printOutput(bool printFile, QTextStream* stream,
552 const QString& strV2, const QString& strV3) {
553
554 // Output into file
555 // ----------------
556 if (printFile && stream) {
557 if (_rinexVers == 2) {
558 *stream << strV2.toAscii();
559 }
560 else {
561 *stream << strV3.toAscii();
562 }
563 stream->flush();
564 }
565
566 // Output into the socket
567 // ----------------------
568 if (_sockets) {
569 QMutableListIterator<QTcpSocket*> is(*_sockets);
570 while (is.hasNext()) {
571 QTcpSocket* sock = is.next();
572 if (sock->state() == QAbstractSocket::ConnectedState) {
573 if (sock->write(strV3.toAscii()) == -1) {
574 delete sock;
575 is.remove();
576 }
577 }
578 else if (sock->state() != QAbstractSocket::ConnectingState) {
579 delete sock;
580 is.remove();
581 }
582 }
583 }
584}
585
586// Set Port Number
587////////////////////////////////////////////////////////////////////////////
588void t_bncCore::setPort(int port) {
589 _port = port;
590 if (_port != 0) {
591 delete _server;
592 _server = new QTcpServer;
593 if ( !_server->listen(QHostAddress::Any, _port) ) {
594 slotMessage("t_bncCore: Cannot listen on ephemeris port", true);
595 }
596 connect(_server, SIGNAL(newConnection()), this, SLOT(slotNewConnection()));
597 delete _sockets;
598 _sockets = new QList<QTcpSocket*>;
599 }
600}
601
602// Set Port Number
603////////////////////////////////////////////////////////////////////////////
604void t_bncCore::setPortCorr(int port) {
605 _portCorr = port;
606 if (_portCorr != 0) {
607 delete _serverCorr;
608 _serverCorr = new QTcpServer;
609 if ( !_serverCorr->listen(QHostAddress::Any, _portCorr) ) {
610 slotMessage("t_bncCore: Cannot listen on correction port", true);
611 }
612 connect(_serverCorr, SIGNAL(newConnection()), this, SLOT(slotNewConnectionCorr()));
613 delete _socketsCorr;
614 _socketsCorr = new QList<QTcpSocket*>;
615 }
616}
617
618// New Connection
619////////////////////////////////////////////////////////////////////////////
620void t_bncCore::slotNewConnection() {
621 _sockets->push_back( _server->nextPendingConnection() );
622}
623
624// New Connection
625////////////////////////////////////////////////////////////////////////////
626void t_bncCore::slotNewConnectionCorr() {
627 _socketsCorr->push_back( _serverCorr->nextPendingConnection() );
628}
629
630//
631////////////////////////////////////////////////////////////////////////////
632void t_bncCore::slotQuit() {
633 cout << "t_bncCore::slotQuit" << endl;
634 delete _caster; _caster = 0;
635 qApp->quit();
636}
637
638//
639////////////////////////////////////////////////////////////////////////////
640void t_bncCore::slotNewCorrLine(QString line, QString staID, bncTime coTime) {
641
642 QMutexLocker locker(&_mutex);
643
644 // Combination of Corrections
645 // --------------------------
646#ifdef USE_COMBINATION
647 if (_bncComb) {
648 _bncComb->processCorrLine(staID, line);
649 }
650#endif
651
652 bncSettings settings;
653 _waitCoTime = settings.value("corrTime").toDouble();
654 if (_waitCoTime < 0.0) {
655 _waitCoTime = 0.0;
656 }
657
658 // First time, set the _lastCorrDumpTime
659 // -------------------------------------
660 if (!_lastCorrDumpTime[staID].valid()) {
661 _lastCorrDumpTime[staID] = coTime - 1.0;
662 }
663
664 // An old correction - throw it away
665 // ---------------------------------
666 if (_waitCoTime > 0.0 && coTime <= _lastCorrDumpTime[staID]) {
667 if (!_bncComb) {
668 QString line = staID + ": Correction for one sat neglected because overaged by " +
669 QString().sprintf(" %f sec",
670 _lastCorrDumpTime[staID] - coTime + _waitCoTime);
671 messagePrivate(line.toAscii());
672 emit( newMessage(line.toAscii(), true) );
673 }
674 return;
675 }
676
677 _corrs->insert(coTime, QString(line + " " + staID));
678
679 // Dump Corrections
680 // ----------------
681 if (_waitCoTime == 0.0) {
682 dumpCorrs();
683 }
684 else if (coTime - _waitCoTime > _lastCorrDumpTime[staID]) {
685 dumpCorrs(_lastCorrDumpTime[staID] + 1, coTime - _waitCoTime);
686 _lastCorrDumpTime[staID] = coTime - _waitCoTime;
687 }
688}
689
690// Dump Complete Correction Epochs
691////////////////////////////////////////////////////////////////////////////
692void t_bncCore::dumpCorrs(bncTime minTime, bncTime maxTime) {
693 QStringList allCorrs;
694 QMutableMapIterator<bncTime, QString> it(*_corrs);
695 while (it.hasNext()) {
696 it.next();
697 const bncTime& corrTime = it.key();
698 if (minTime <= corrTime && corrTime <= maxTime) {
699 allCorrs << it.value();
700 it.remove();
701 }
702 }
703 dumpCorrs(allCorrs);
704}
705
706// Dump all corrections
707////////////////////////////////////////////////////////////////////////////
708void t_bncCore::dumpCorrs() {
709 QStringList allCorrs;
710 QMutableMapIterator<bncTime, QString> it(*_corrs);
711 while (it.hasNext()) {
712 allCorrs << it.next().value();
713 it.remove();
714 }
715 dumpCorrs(allCorrs);
716}
717
718// Dump List of Corrections
719////////////////////////////////////////////////////////////////////////////
720void t_bncCore::dumpCorrs(const QStringList& allCorrs) {
721 emit newCorrections(allCorrs);
722 if (_socketsCorr) {
723 QListIterator<QString> it(allCorrs);
724 while (it.hasNext()) {
725 QString corrLine = it.next() + "\n";
726
727 QMutableListIterator<QTcpSocket*> is(*_socketsCorr);
728 while (is.hasNext()) {
729 QTcpSocket* sock = is.next();
730 if (sock->state() == QAbstractSocket::ConnectedState) {
731 if (sock->write(corrLine.toAscii()) == -1) {
732 delete sock;
733 is.remove();
734 }
735 }
736 else if (sock->state() != QAbstractSocket::ConnectingState) {
737 delete sock;
738 is.remove();
739 }
740 }
741 }
742 }
743}
744
745//
746////////////////////////////////////////////////////////////////////////////
747void t_bncCore::setConfFileName(const QString& confFileName) {
748 if (confFileName.isEmpty()) {
749 _confFileName = QDir::homePath() + QDir::separator()
750 + ".config" + QDir::separator()
751 + qApp->organizationName() + QDir::separator()
752 + qApp->applicationName() + ".bnc";
753 }
754 else {
755 _confFileName = confFileName;
756 }
757}
758
759// Raw Output
760////////////////////////////////////////////////////////////////////////////
761void t_bncCore::writeRawData(const QByteArray& data, const QByteArray& staID,
762 const QByteArray& format) {
763
764 QMutexLocker locker(&_mutex);
765
766 if (!_rawFile) {
767 bncSettings settings;
768 QByteArray fileName = settings.value("rawOutFile").toByteArray();
769 if (!fileName.isEmpty()) {
770 _rawFile = new bncRawFile(fileName, staID, bncRawFile::output);
771 }
772 }
773
774 if (_rawFile) {
775 _rawFile->writeRawData(data, staID, format);
776 }
777}
778
779// Get Glonass Slot Numbers from Global Array
780////////////////////////////////////////////////////////////////////////////
781void t_bncCore::getGlonassSlotNums(int GLOFreq[]) {
782
783 QMutexLocker locker(&_mutex);
784
785 for (int ii = 0; ii < PRN_GLONASS_NUM; ++ii) {
786 if (_GLOFreq[ii] != 0) {
787 GLOFreq[ii] = _GLOFreq[ii];
788 }
789 }
790}
791
792// Store Glonass Slot Numbers to Global Array
793////////////////////////////////////////////////////////////////////////////
794void t_bncCore::storeGlonassSlotNums(const int GLOFreq[]) {
795
796 QMutexLocker locker(&_mutex);
797
798 for (int ii = 0; ii < PRN_GLONASS_NUM; ++ii) {
799 if (GLOFreq[ii] != 0) {
800 _GLOFreq[ii] = GLOFreq[ii];
801 }
802 }
803}
804
805//
806////////////////////////////////////////////////////////////////////////////
807void t_bncCore::initCombination() {
808#ifdef USE_COMBINATION
809 _bncComb = new bncComb();
810 if (_bncComb->nStreams() < 1) {
811 delete _bncComb;
812 _bncComb = 0;
813 }
814#endif
815}
816
817//
818////////////////////////////////////////////////////////////////////////////
819void t_bncCore::stopCombination() {
820#ifdef USE_COMBINATION
821 delete _bncComb;
822 _bncComb = 0;
823#endif
824}
825
826// Check Ephemeris Consistency
827////////////////////////////////////////////////////////////////////////////
828void t_bncCore::checkEphemeris(gpsephemeris* oldEph, gpsephemeris* newEph) {
829 if (oldEph->clock_bias != newEph->clock_bias ||
830 oldEph->clock_drift != newEph->clock_drift ||
831 oldEph->clock_driftrate != newEph->clock_driftrate) {
832 QString msg = currentDateAndTimeGPS().toString(Qt::ISODate) +
833 QString(" %1 EPH DIFFERS\n").arg(oldEph->satellite);
834 messagePrivate(msg.toAscii());
835 }
836}
837
838
839//
840////////////////////////////////////////////////////////////////////////////
841bool t_bncCore::dateAndTimeGPSSet() const {
842 QMutexLocker locker(&_mutexDateAndTimeGPS);
843 if (_dateAndTimeGPS) {
844 return true;
845 }
846 else {
847 return false;
848 }
849}
850
851//
852////////////////////////////////////////////////////////////////////////////
853QDateTime t_bncCore::dateAndTimeGPS() const {
854 QMutexLocker locker(&_mutexDateAndTimeGPS);
855 if (_dateAndTimeGPS) {
856 return *_dateAndTimeGPS;
857 }
858 else {
859 return QDateTime();
860 }
861}
862
863//
864////////////////////////////////////////////////////////////////////////////
865void t_bncCore::setDateAndTimeGPS(QDateTime dateTime) {
866 QMutexLocker locker(&_mutexDateAndTimeGPS);
867 delete _dateAndTimeGPS;
868 _dateAndTimeGPS = new QDateTime(dateTime);
869}
870
871//
872////////////////////////////////////////////////////////////////////////////
873void t_bncCore::startPPP() {
874 _pppMain->start();
875}
876
877//
878////////////////////////////////////////////////////////////////////////////
879void t_bncCore::stopPPP() {
880 _pppMain->stop();
881}
Note: See TracBrowser for help on using the repository browser.