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

Last change on this file since 9765 was 9765, checked in by stuerze, 8 weeks ago

some more changes to consider RINEX Version 4 nav file (EPH key only)

File size: 24.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_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 <sstream>
43#include <QMessageBox>
44#include <cmath>
45
46#include "bnccore.h"
47#include "bncutils.h"
48#include "bncrinex.h"
49#include "bncsettings.h"
50#include "bncversion.h"
51#include "ephemeris.h"
52#include "rinex/rnxobsfile.h"
53#include "rinex/rnxnavfile.h"
54#include "pppMain.h"
55#include "combination/bnccomb.h"
56
57using namespace std;
58
59// Singleton
60////////////////////////////////////////////////////////////////////////////
61t_bncCore* t_bncCore::instance() {
62 static t_bncCore _bncCore;
63 return &_bncCore;
64}
65
66// Constructor
67////////////////////////////////////////////////////////////////////////////
68t_bncCore::t_bncCore() : _ephUser(false) {
69 _GUIenabled = true;
70 _logFileFlag = 0;
71 _logFile = 0;
72 _logStream = 0;
73 _rawFile = 0;
74 _caster = 0;
75 _bncComb = 0;
76
77 // Eph file(s)
78 // -----------
79 _rinexVers = 0;
80 _ephFileGPS = 0;
81 _ephStreamGPS = 0;
82 _ephFileGlonass = 0;
83 _ephStreamGlonass = 0;
84 _ephFileGalileo = 0;
85 _ephStreamGalileo = 0;
86 _ephFileSBAS = 0;
87 _ephStreamSBAS = 0;
88
89 _portEph = 0;
90 _serverEph = 0;
91 _socketsEph = 0;
92
93 _portCorr = 0;
94 _serverCorr = 0;
95 _socketsCorr = 0;
96
97 _pgmName = QString(BNCPGMNAME).leftJustified(20, ' ', true);
98#ifdef WIN32
99 _userName = QString("${USERNAME}");
100#else
101 _userName = QString("${USER}");
102#endif
103 expandEnvVar(_userName);
104
105 _userName = _userName.leftJustified(20, ' ', true);
106 _dateAndTimeGPS = 0;
107 _mainWindow = 0;
108
109 _pppMain = new BNC_PPP::t_pppMain();
110 qRegisterMetaType< QVector<double> > ("QVector<double>");
111 qRegisterMetaType<bncTime> ("bncTime");
112 qRegisterMetaType<t_ephGPS> ("t_ephGPS");
113 qRegisterMetaType<t_ephGlo> ("t_ephGlo");
114 qRegisterMetaType<t_ephGal> ("t_ephGal");
115 qRegisterMetaType<t_ephSBAS> ("t_ephSBAS");
116 qRegisterMetaType<t_ephBDS> ("t_ephBDS");
117 qRegisterMetaType<QList<t_orbCorr> > ("QList<t_orbCorr>");
118 qRegisterMetaType<QList<t_clkCorr> > ("QList<t_clkCorr>");
119 qRegisterMetaType<QList<t_satCodeBias> > ("QList<t_satCodeBias>");
120 qRegisterMetaType<QList<t_satPhaseBias> > ("QList<t_satPhaseBias>");
121 qRegisterMetaType<t_vTec> ("t_vTec");
122}
123
124// Destructor
125////////////////////////////////////////////////////////////////////////////
126t_bncCore::~t_bncCore() {
127 delete _logStream;
128 delete _logFile;
129 delete _ephStreamGPS;
130 delete _ephFileGPS;
131 delete _serverEph;
132 delete _socketsEph;
133 delete _serverCorr;
134 delete _socketsCorr;
135 if (_rinexVers == 2) {
136 delete _ephStreamGlonass;
137 delete _ephFileGlonass;
138 }
139
140 delete _dateAndTimeGPS;
141 delete _rawFile;
142 delete _bncComb;
143 delete _pppMain;
144}
145
146// Write a Program Message
147////////////////////////////////////////////////////////////////////////////
148void t_bncCore::slotMessage(QByteArray msg, bool showOnScreen) {
149
150 QMutexLocker locker(&_mutexMessage);
151
152 messagePrivate(msg);
153 emit newMessage(msg, showOnScreen);
154}
155
156// Write a Program Message (private, no lock)
157////////////////////////////////////////////////////////////////////////////
158void t_bncCore::messagePrivate(const QByteArray& msg) {
159
160 // First time resolve the log file name
161 // ------------------------------------
162 QDate currDate = currentDateAndTimeGPS().date();
163 if (_logFileFlag == 0 || _fileDate != currDate) {
164 delete _logStream; _logStream = 0;
165 delete _logFile; _logFile = 0;
166 _logFileFlag = 1;
167 bncSettings settings;
168 QString logFileName = settings.value("logFile").toString();
169 if ( !logFileName.isEmpty() ) {
170 expandEnvVar(logFileName);
171 _logFile = new QFile(logFileName + "_" +
172 currDate.toString("yyMMdd").toLatin1().data());
173 _fileDate = currDate;
174 if ( Qt::CheckState(settings.value("rnxAppend").toInt()) == Qt::Checked) {
175 _logFile->open(QIODevice::WriteOnly | QIODevice::Append);
176 }
177 else {
178 _logFile->open(QIODevice::WriteOnly);
179 }
180 _logStream = new QTextStream();
181 _logStream->setDevice(_logFile);
182 }
183 }
184
185 if (_logStream) {
186 QByteArray msgLocal = msg;
187 if (msg.indexOf('\n') == 0) {
188 *_logStream << endl;
189 msgLocal = msg.mid(1);
190 }
191 *_logStream << currentDateAndTimeGPS().toString("yy-MM-dd hh:mm:ss ").toLatin1().data();
192 *_logStream << msgLocal.data() << endl;
193 _logStream->flush();
194 _logFile->flush();
195 }
196}
197
198//
199////////////////////////////////////////////////////////////////////////////
200t_irc t_bncCore::checkPrintEph(t_eph* eph) {
201 QMutexLocker locker(&_mutex);
202 t_irc ircPut = _ephUser.putNewEph(eph, true);
203#ifdef BNC_DEBUG_BCEP
204 if (eph->checkState() == t_eph::bad) {
205 messagePrivate(QString("%1: WRONG %2:%3")
206 .arg(eph->receptStaID())
207 .arg(eph->navTypeString(eph->navType(), eph->prn(), 99.0))
208 .arg(eph->rinexDateStr(eph->TOC(), eph->prn(), 99.0)).toLatin1());
209 return failure;
210 }
211 else if (eph->checkState() == t_eph::outdated) {
212 messagePrivate(QString("%1: OUTDATED %2:%3")
213 .arg(eph->receptStaID())
214 .arg(eph->navTypeString(eph->navType(), eph->prn(), 99.0))
215 .arg(eph->rinexDateStr(eph->TOC(), eph->prn(), 99.0)).toLatin1());
216 return failure;
217 }
218 else if (eph->checkState() == t_eph::unhealthy) {
219 messagePrivate(QString("%1: UNHEALTHY %2:%3")
220 .arg(eph->receptStaID())
221 .arg(eph->navTypeString(eph->navType(), eph->prn(), 99.0))
222 .arg(eph->rinexDateStr(eph->TOC(), eph->prn(), 99.0)).toLatin1());
223 }
224#endif
225 printEphHeader();
226 printEph(*eph, (ircPut == success));
227 return success;
228}
229
230// New GPS Ephemeris
231////////////////////////////////////////////////////////////////////////////
232void t_bncCore::slotNewGPSEph(t_ephGPS eph) {
233 if (checkPrintEph(&eph) == success) {
234 emit newGPSEph(eph);
235 }
236}
237
238// New Glonass Ephemeris
239////////////////////////////////////////////////////////////////////////////
240void t_bncCore::slotNewGlonassEph(t_ephGlo eph) {
241 if (checkPrintEph(&eph) == success) {
242 emit newGlonassEph(eph);
243 }
244}
245
246// New Galileo Ephemeris
247////////////////////////////////////////////////////////////////////////////
248void t_bncCore::slotNewGalileoEph(t_ephGal eph) {
249 if (checkPrintEph(&eph) == success) {
250 emit newGalileoEph(eph);
251 }
252}
253
254// New SBAS Ephemeris
255////////////////////////////////////////////////////////////////////////////
256void t_bncCore::slotNewSBASEph(t_ephSBAS eph) {
257 if (checkPrintEph(&eph) == success) {
258 emit newSBASEph(eph);
259 }
260}
261
262// New BDS Ephemeris
263////////////////////////////////////////////////////////////////////////////
264void t_bncCore::slotNewBDSEph(t_ephBDS eph) {
265 if (checkPrintEph(&eph) == success) {
266 emit newBDSEph(eph);
267 }
268}
269
270// Print Header of the output File(s)
271////////////////////////////////////////////////////////////////////////////
272void t_bncCore::printEphHeader() {
273
274 bncSettings settings;
275 QStringList comments;
276
277 QListIterator<QString> it(settings.value("mountPoints").toStringList());
278 while (it.hasNext()) {
279 QStringList hlp = it.next().split(" ");
280 if (hlp.size() < 7)
281 continue;
282 QUrl url(hlp[0]);
283 QString decoder = hlp[1];
284 comments.append("Source: " + decoder +
285 " " + QUrl::toAce(url.host()) +
286 "/" + url.path().mid(1).toLatin1());
287 }
288
289 // Initialization
290 // --------------
291 if (_rinexVers == 0) {
292
293 _rinexVers = settings.value("ephVersion").toInt();
294
295 _ephPath = settings.value("ephPath").toString();
296
297 if ( !_ephPath.isEmpty() ) {
298 if ( _ephPath[_ephPath.length()-1] != QDir::separator() ) {
299 _ephPath += QDir::separator();
300 }
301 expandEnvVar(_ephPath);
302 }
303 }
304
305 // (Re-)Open output File(s)
306 // ------------------------
307 if (!_ephPath.isEmpty()) {
308
309 QDateTime datTim = currentDateAndTimeGPS();
310
311 QString ephFileNameGPS = _ephPath + "BRDC";
312
313 QString hlpStr = bncRinex::nextEpochStr(datTim,
314 settings.value("ephIntr").toString(), _rinexVers);
315
316 if (_rinexVers > 2) {
317 QString country = "WRD"; // WORLD
318 QString monNum = "0";
319 QString recNum = "0";
320 ephFileNameGPS += QString("%1").arg(monNum, 1, 10) +
321 QString("%1").arg(recNum, 1, 10) +
322 country +
323 "_S_" + // stream
324 QString("%1").arg(datTim.date().year()) +
325 QString("%1").arg(datTim.date().dayOfYear(), 3, 10, QChar('0')) +
326 hlpStr + // HM_period
327 "_MN.rnx"; // mixed BRDC
328 }
329 else { // RNX v2.11
330 ephFileNameGPS += QString("%1").arg(datTim.date().dayOfYear(), 3, 10, QChar('0')) +
331 hlpStr + datTim.toString(".yyN");
332 }
333
334 if (_ephFileNameGPS == ephFileNameGPS) {
335 return;
336 }
337 else {
338 _ephFileNameGPS = ephFileNameGPS;
339 }
340
341 delete _ephStreamGPS;
342 delete _ephFileGPS;
343
344 QFlags<QIODevice::OpenModeFlag> appendFlagGPS;
345 QFlags<QIODevice::OpenModeFlag> appendFlagGlonass;
346
347 if ( Qt::CheckState(settings.value("rnxAppend").toInt()) == Qt::Checked &&
348 QFile::exists(ephFileNameGPS) ) {
349 appendFlagGPS = QIODevice::Append;
350 }
351
352 _ephFileGPS = new QFile(ephFileNameGPS);
353 _ephFileGPS->open(QIODevice::WriteOnly | appendFlagGPS);
354 _ephStreamGPS = new QTextStream();
355 _ephStreamGPS->setDevice(_ephFileGPS);
356
357 if (_rinexVers > 2) {
358 _ephFileGlonass = _ephFileGPS;
359 _ephStreamGlonass = _ephStreamGPS;
360 _ephFileGalileo = _ephFileGPS;
361 _ephStreamGalileo = _ephStreamGPS;
362 _ephFileSBAS = _ephFileGPS;
363 _ephStreamSBAS = _ephStreamGPS;
364 }
365 else {
366 QString ephFileNameGlonass = _ephPath + "BRDC" +
367 QString("%1").arg(datTim.date().dayOfYear(), 3, 10, QChar('0')) +
368 hlpStr + datTim.toString(".yyG");
369
370 delete _ephStreamGlonass;
371 delete _ephFileGlonass;
372
373 if ( Qt::CheckState(settings.value("rnxAppend").toInt()) == Qt::Checked &&
374 QFile::exists(ephFileNameGlonass) ) {
375 appendFlagGlonass = QIODevice::Append;
376 }
377
378 _ephFileGlonass = new QFile(ephFileNameGlonass);
379 _ephFileGlonass->open(QIODevice::WriteOnly | appendFlagGlonass);
380 _ephStreamGlonass = new QTextStream();
381 _ephStreamGlonass->setDevice(_ephFileGlonass);
382 }
383
384 // Header - RINEX Version 3
385 // ------------------------
386 if (_rinexVers > 2) {
387 if ( ! (appendFlagGPS & QIODevice::Append)) {
388 double rinexVersion = defaultRnxNavVersion4;
389 if (_rinexVers < 4.0) {
390 rinexVersion = defaultRnxNavVersion3;
391 }
392 QString line = QString().asprintf("%9.2f%11sN: GNSS NAV DATA M: Mixed%12sRINEX VERSION / TYPE\n",
393 rinexVersion, "", "");
394 *_ephStreamGPS << line;
395 line.clear();
396
397 QString hlp = currentDateAndTimeGPS().toString("yyyyMMdd hhmmss UTC").leftJustified(20, ' ', true);
398 *_ephStreamGPS << _pgmName.toLatin1().data()
399 << _userName.toLatin1().data()
400 << hlp.toLatin1().data()
401 << "PGM / RUN BY / DATE\n";
402
403 QStringListIterator it(comments);
404 while (it.hasNext()) {
405 *_ephStreamGPS << it.next().trimmed().left(60).leftJustified(60) << "COMMENT\n";
406 }
407
408 if (_rinexVers == 4) {
409 int leapSecs = gnumleap(datTim.date().year(), datTim.date().month(), datTim.date().day());
410 *_ephStreamGPS << QString("%1").arg(leapSecs, 6, 10, QLatin1Char(' ')).left(60).leftJustified(60)
411 << "LEAP SECONDS\n";
412 }
413
414 line = QString().asprintf("%60sEND OF HEADER\n", "");
415 *_ephStreamGPS << line;
416
417 _ephStreamGPS->flush();
418 }
419 }
420
421 // Headers - RINEX Version 2
422 // -------------------------
423 else {
424 if (! (appendFlagGPS & QIODevice::Append)) {
425 QString line = QString().asprintf("%9.2f%11sN: GPS NAV DATA%25sRINEX VERSION / TYPE\n",
426 defaultRnxNavVersion2, "", "");
427 *_ephStreamGPS << line;
428 line.clear();
429
430 QString hlp = currentDateAndTimeGPS().date().toString("dd-MMM-yyyy").leftJustified(20, ' ', true);
431 *_ephStreamGPS << _pgmName.toLatin1().data()
432 << _userName.toLatin1().data()
433 << hlp.toLatin1().data()
434 << "PGM / RUN BY / DATE\n";
435
436 QStringListIterator it(comments);
437 while (it.hasNext()) {
438 *_ephStreamGPS << it.next().trimmed().left(60).leftJustified(60) << "COMMENT\n";
439 }
440
441 line = QString().asprintf("%60sEND OF HEADER\n", "");
442 *_ephStreamGPS << line;
443
444 _ephStreamGPS->flush();
445 }
446 if (! (appendFlagGlonass & QIODevice::Append)) {
447 QString line = QString().asprintf("%9.2f%11sG: GLONASS NAV DATA%21sRINEX VERSION / TYPE\n",
448 defaultRnxNavVersion2, "", "");
449 *_ephStreamGlonass << line;
450 line.clear();
451
452 QString hlp = currentDateAndTimeGPS().date().toString("dd-MMM-yyyy").leftJustified(20, ' ', true);
453 *_ephStreamGlonass << _pgmName.toLatin1().data()
454 << _userName.toLatin1().data()
455 << hlp.toLatin1().data()
456 << "PGM / RUN BY / DATE\n";
457
458 QStringListIterator it(comments);
459 while (it.hasNext()) {
460 *_ephStreamGlonass << it.next().trimmed().left(60).leftJustified(60) << "COMMENT\n";
461 }
462
463 line = QString().asprintf("%60sEND OF HEADER\n", "");
464 *_ephStreamGlonass << line;
465
466 _ephStreamGlonass->flush();
467 }
468 }
469 }
470}
471
472// Print One Ephemeris
473////////////////////////////////////////////////////////////////////////////
474void t_bncCore::printEph(const t_eph& eph, bool printFile) {
475
476 QString strV2 = eph.toString(defaultRnxNavVersion2);
477 QString strV3 = eph.toString(defaultRnxNavVersion3);
478 QString strV4 = eph.toString(defaultRnxNavVersion4);
479
480 if (_rinexVers == 2 && eph.type() == t_eph::GLONASS) {
481 printOutputEph(printFile, _ephStreamGlonass, strV2, strV3, strV4);
482 }
483 else if(_rinexVers == 2 && eph.type() == t_eph::GPS) {
484 printOutputEph(printFile, _ephStreamGPS, strV2, strV3, strV4);
485 }
486 else if (_rinexVers >= 3) {
487 printOutputEph(printFile, _ephStreamGPS, strV2, strV3, strV4);
488 }
489}
490
491// Output
492////////////////////////////////////////////////////////////////////////////
493void t_bncCore::printOutputEph(bool printFile, QTextStream* stream,
494 const QString& strV2, const QString& strV3,
495 const QString& strV4) {
496
497 // Output into file
498 // ----------------
499 if (printFile && stream) {
500 if (_rinexVers == 2) {
501 *stream << strV2.toLatin1();
502 }
503 else if (_rinexVers == 3) {
504 *stream << strV3.toLatin1();
505 }
506 else if (_rinexVers == 4) {
507 *stream << strV4.toLatin1();
508 }
509 stream->flush();
510 }
511
512 // Output into the socket
513 // ----------------------
514 if (_socketsEph) {
515 QMutableListIterator<QTcpSocket*> is(*_socketsEph);
516 while (is.hasNext()) {
517 QTcpSocket* sock = is.next();
518 if (sock->state() == QAbstractSocket::ConnectedState) {
519 if (sock->write(strV3.toLatin1()) == -1) {
520 delete sock;
521 is.remove();
522 }
523 }
524 else if (sock->state() != QAbstractSocket::ConnectingState) {
525 delete sock;
526 is.remove();
527 }
528 }
529 }
530}
531
532// Set Port Number
533////////////////////////////////////////////////////////////////////////////
534void t_bncCore::setPortEph(int port) {
535 _portEph = port;
536 if (_portEph != 0) {
537 delete _serverEph;
538 _serverEph = new QTcpServer;
539 _serverEph->setProxy(QNetworkProxy::NoProxy);
540 if ( !_serverEph->listen(QHostAddress::Any, _portEph) ) {
541 QString message = "t_bncCore: Cannot listen on ephemeris port "
542 + QByteArray::number(_portEph) + ": "
543 + _serverEph->errorString();
544 slotMessage(message.toLatin1(), true);
545 }
546 connect(_serverEph, SIGNAL(newConnection()), this, SLOT(slotNewConnectionEph()));
547 delete _socketsEph;
548 _socketsEph = new QList<QTcpSocket*>;
549 }
550}
551
552// Set Port Number
553////////////////////////////////////////////////////////////////////////////
554void t_bncCore::setPortCorr(int port) {
555 _portCorr = port;
556 if (_portCorr != 0) {
557 delete _serverCorr;
558 _serverCorr = new QTcpServer;
559 _serverCorr->setProxy(QNetworkProxy::NoProxy);
560 if ( !_serverCorr->listen(QHostAddress::Any, _portCorr) ) {
561 QString message = "t_bncCore: Cannot listen on correction port "
562 + QByteArray::number(_portCorr) + ": "
563 + _serverCorr->errorString();
564 slotMessage(message.toLatin1(), true);
565 }
566 connect(_serverCorr, SIGNAL(newConnection()), this, SLOT(slotNewConnectionCorr()));
567 delete _socketsCorr;
568 _socketsCorr = new QList<QTcpSocket*>;
569 }
570}
571
572// New Connection
573////////////////////////////////////////////////////////////////////////////
574void t_bncCore::slotNewConnectionEph() {
575 _socketsEph->push_back( _serverEph->nextPendingConnection() );
576}
577
578// New Connection
579////////////////////////////////////////////////////////////////////////////
580void t_bncCore::slotNewConnectionCorr() {
581 _socketsCorr->push_back( _serverCorr->nextPendingConnection() );
582}
583
584//
585////////////////////////////////////////////////////////////////////////////
586void t_bncCore::slotQuit() {
587 delete _caster; _caster = 0;
588 qApp->quit();
589}
590
591//
592////////////////////////////////////////////////////////////////////////////
593void t_bncCore::slotNewOrbCorrections(QList<t_orbCorr> orbCorrections) {
594 QMutexLocker locker(&_mutex);
595 emit newOrbCorrections(orbCorrections);
596 if (_socketsCorr) {
597 ostringstream out;
598 t_orbCorr::writeEpoch(&out, orbCorrections);
599 QMutableListIterator<QTcpSocket*> is(*_socketsCorr);
600 while (is.hasNext()) {
601 QTcpSocket* sock = is.next();
602 if (sock->state() == QAbstractSocket::ConnectedState) {
603 if (sock->write(out.str().c_str()) == -1) {
604 delete sock;
605 is.remove();
606 }
607 }
608 else if (sock->state() != QAbstractSocket::ConnectingState) {
609 delete sock;
610 is.remove();
611 }
612 }
613 }
614}
615
616//
617////////////////////////////////////////////////////////////////////////////
618void t_bncCore::slotNewClkCorrections(QList<t_clkCorr> clkCorrections) {
619 QMutexLocker locker(&_mutex);
620 emit newClkCorrections(clkCorrections);
621 if (_socketsCorr) {
622 ostringstream out;
623 t_clkCorr::writeEpoch(&out, clkCorrections);
624 QMutableListIterator<QTcpSocket*> is(*_socketsCorr);
625 while (is.hasNext()) {
626 QTcpSocket* sock = is.next();
627 if (sock->state() == QAbstractSocket::ConnectedState) {
628 if (sock->write(out.str().c_str()) == -1) {
629 delete sock;
630 is.remove();
631 }
632 }
633 else if (sock->state() != QAbstractSocket::ConnectingState) {
634 delete sock;
635 is.remove();
636 }
637 }
638 }
639}
640
641//
642////////////////////////////////////////////////////////////////////////////
643void t_bncCore::slotNewCodeBiases(QList<t_satCodeBias> codeBiases) {
644 QMutexLocker locker(&_mutex);
645 emit newCodeBiases(codeBiases);
646 if (_socketsCorr) {
647 ostringstream out;
648 t_satCodeBias::writeEpoch(&out, codeBiases);
649 QMutableListIterator<QTcpSocket*> is(*_socketsCorr);
650 while (is.hasNext()) {
651 QTcpSocket* sock = is.next();
652 if (sock->state() == QAbstractSocket::ConnectedState) {
653 if (sock->write(out.str().c_str()) == -1) {
654 delete sock;
655 is.remove();
656 }
657 }
658 else if (sock->state() != QAbstractSocket::ConnectingState) {
659 delete sock;
660 is.remove();
661 }
662 }
663 }
664}
665
666//
667////////////////////////////////////////////////////////////////////////////
668void t_bncCore::slotNewPhaseBiases(QList<t_satPhaseBias> phaseBiases) {
669 QMutexLocker locker(&_mutex);
670 emit newPhaseBiases(phaseBiases);
671 if (_socketsCorr) {
672 ostringstream out;
673 t_satPhaseBias::writeEpoch(&out, phaseBiases);
674 QMutableListIterator<QTcpSocket*> is(*_socketsCorr);
675 while (is.hasNext()) {
676 QTcpSocket* sock = is.next();
677 if (sock->state() == QAbstractSocket::ConnectedState) {
678 if (sock->write(out.str().c_str()) == -1) {
679 delete sock;
680 is.remove();
681 }
682 }
683 else if (sock->state() != QAbstractSocket::ConnectingState) {
684 delete sock;
685 is.remove();
686 }
687 }
688 }
689}
690
691//
692////////////////////////////////////////////////////////////////////////////
693void t_bncCore::slotNewTec(t_vTec vTec) {
694 QMutexLocker locker(&_mutex);
695 emit newTec(vTec);
696 if (_socketsCorr) {
697 ostringstream out;
698 t_vTec::write(&out, vTec);
699 QMutableListIterator<QTcpSocket*> is(*_socketsCorr);
700 while (is.hasNext()) {
701 QTcpSocket* sock = is.next();
702 if (sock->state() == QAbstractSocket::ConnectedState) {
703 if (sock->write(out.str().c_str()) == -1) {
704 delete sock;
705 is.remove();
706 }
707 }
708 else if (sock->state() != QAbstractSocket::ConnectingState) {
709 delete sock;
710 is.remove();
711 }
712 }
713 }
714}
715
716//
717////////////////////////////////////////////////////////////////////////////
718void t_bncCore::setConfFileName(const QString& confFileName) {
719 if (confFileName.isEmpty()) {
720 _confFileName = QDir::homePath() + QDir::separator()
721 + ".config" + QDir::separator()
722 + qApp->organizationName() + QDir::separator()
723 + qApp->applicationName() + ".bnc";
724 }
725 else {
726 _confFileName = confFileName;
727 }
728}
729
730// Raw Output
731////////////////////////////////////////////////////////////////////////////
732void t_bncCore::writeRawData(const QByteArray& data, const QByteArray& staID,
733 const QByteArray& format) {
734
735 QMutexLocker locker(&_mutex);
736
737 if (!_rawFile) {
738 bncSettings settings;
739 QByteArray fileName = settings.value("rawOutFile").toByteArray();
740 if (!fileName.isEmpty()) {
741 _rawFile = new bncRawFile(fileName, staID, bncRawFile::output);
742 }
743 }
744
745 if (_rawFile) {
746 _rawFile->writeRawData(data, staID, format);
747 }
748}
749
750//
751////////////////////////////////////////////////////////////////////////////
752void t_bncCore::initCombination() {
753 _bncComb = new bncComb();
754 if (_bncComb->nStreams() < 1) {
755 delete _bncComb;
756 _bncComb = 0;
757 }
758}
759
760//
761////////////////////////////////////////////////////////////////////////////
762void t_bncCore::stopCombination() {
763 delete _bncComb;
764 _bncComb = 0;
765}
766
767//
768////////////////////////////////////////////////////////////////////////////
769bool t_bncCore::dateAndTimeGPSSet() const {
770 QMutexLocker locker(&_mutexDateAndTimeGPS);
771 if (_dateAndTimeGPS) {
772 return true;
773 }
774 else {
775 return false;
776 }
777}
778
779//
780////////////////////////////////////////////////////////////////////////////
781QDateTime t_bncCore::dateAndTimeGPS() const {
782 QMutexLocker locker(&_mutexDateAndTimeGPS);
783 if (_dateAndTimeGPS) {
784 return *_dateAndTimeGPS;
785 }
786 else {
787 return QDateTime();
788 }
789}
790
791//
792////////////////////////////////////////////////////////////////////////////
793void t_bncCore::setDateAndTimeGPS(QDateTime dateTime) {
794 QMutexLocker locker(&_mutexDateAndTimeGPS);
795 delete _dateAndTimeGPS;
796 _dateAndTimeGPS = new QDateTime(dateTime);
797}
798
799//
800////////////////////////////////////////////////////////////////////////////
801void t_bncCore::startPPP() {
802 _pppMain->start();
803}
804
805//
806////////////////////////////////////////////////////////////////////////////
807void t_bncCore::stopPPP() {
808 _pppMain->stop();
809 emit stopRinexPPP();
810}
811
Note: See TracBrowser for help on using the repository browser.