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

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

eph checkstate is marked as debug output

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::unhealthy) {
205 messagePrivate(QString("%1: UNHEALTHY %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 }
210 if (eph->checkState() == t_eph::bad) {
211 messagePrivate(QString("%1: WRONG %2:%3")
212 .arg(eph->receptStaID())
213 .arg(eph->navTypeString(eph->navType(), eph->prn(), 99.0))
214 .arg(eph->rinexDateStr(eph->TOC(), eph->prn(), 99.0)).toLatin1());
215 }
216 if (eph->checkState() == t_eph::outdated) {
217 messagePrivate(QString("%1: OUTDATED %2:%3")
218 .arg(eph->receptStaID())
219 .arg(eph->navTypeString(eph->navType(), eph->prn(), 99.0))
220 .arg(eph->rinexDateStr(eph->TOC(), eph->prn(), 99.0)).toLatin1());
221 }
222#endif
223 printEphHeader();
224 printEph(*eph, (ircPut == success));
225 return success;
226}
227
228// New GPS Ephemeris
229////////////////////////////////////////////////////////////////////////////
230void t_bncCore::slotNewGPSEph(t_ephGPS eph) {
231 if (checkPrintEph(&eph) == success) {
232 emit newGPSEph(eph);
233 }
234}
235
236// New Glonass Ephemeris
237////////////////////////////////////////////////////////////////////////////
238void t_bncCore::slotNewGlonassEph(t_ephGlo eph) {
239 if (checkPrintEph(&eph) == success) {
240 emit newGlonassEph(eph);
241 }
242}
243
244// New Galileo Ephemeris
245////////////////////////////////////////////////////////////////////////////
246void t_bncCore::slotNewGalileoEph(t_ephGal eph) {
247 if (checkPrintEph(&eph) == success) {
248 emit newGalileoEph(eph);
249 }
250}
251
252// New SBAS Ephemeris
253////////////////////////////////////////////////////////////////////////////
254void t_bncCore::slotNewSBASEph(t_ephSBAS eph) {
255 if (checkPrintEph(&eph) == success) {
256 emit newSBASEph(eph);
257 }
258}
259
260// New BDS Ephemeris
261////////////////////////////////////////////////////////////////////////////
262void t_bncCore::slotNewBDSEph(t_ephBDS eph) {
263 if (checkPrintEph(&eph) == success) {
264 emit newBDSEph(eph);
265 }
266}
267
268// Print Header of the output File(s)
269////////////////////////////////////////////////////////////////////////////
270void t_bncCore::printEphHeader() {
271
272 bncSettings settings;
273 QStringList comments;
274
275 QListIterator<QString> it(settings.value("mountPoints").toStringList());
276 while (it.hasNext()) {
277 QStringList hlp = it.next().split(" ");
278 if (hlp.size() < 7)
279 continue;
280 QUrl url(hlp[0]);
281 QString decoder = hlp[1];
282 comments.append("Source: " + decoder +
283 " " + QUrl::toAce(url.host()) +
284 "/" + url.path().mid(1).toLatin1());
285 }
286
287 // Initialization
288 // --------------
289 if (_rinexVers == 0) {
290
291 _rinexVers = settings.value("ephVersion").toInt();
292
293 _ephPath = settings.value("ephPath").toString();
294
295 if ( !_ephPath.isEmpty() ) {
296 if ( _ephPath[_ephPath.length()-1] != QDir::separator() ) {
297 _ephPath += QDir::separator();
298 }
299 expandEnvVar(_ephPath);
300 }
301 }
302
303 // (Re-)Open output File(s)
304 // ------------------------
305 if (!_ephPath.isEmpty()) {
306
307 QDateTime datTim = currentDateAndTimeGPS();
308
309 QString ephFileNameGPS = _ephPath + "BRDC";
310
311 QString hlpStr = bncRinex::nextEpochStr(datTim,
312 settings.value("ephIntr").toString(), _rinexVers);
313
314 if (_rinexVers > 2) {
315 QString country = "WRD"; // WORLD
316 QString monNum = "0";
317 QString recNum = "0";
318 ephFileNameGPS += QString("%1").arg(monNum, 1, 10) +
319 QString("%1").arg(recNum, 1, 10) +
320 country +
321 "_S_" + // stream
322 QString("%1").arg(datTim.date().year()) +
323 QString("%1").arg(datTim.date().dayOfYear(), 3, 10, QChar('0')) +
324 hlpStr + // HM_period
325 "_MN.rnx"; // mixed BRDC
326 }
327 else { // RNX v2.11
328 ephFileNameGPS += QString("%1").arg(datTim.date().dayOfYear(), 3, 10, QChar('0')) +
329 hlpStr + datTim.toString(".yyN");
330 }
331
332 if (_ephFileNameGPS == ephFileNameGPS) {
333 return;
334 }
335 else {
336 _ephFileNameGPS = ephFileNameGPS;
337 }
338
339 delete _ephStreamGPS;
340 delete _ephFileGPS;
341
342 QFlags<QIODevice::OpenModeFlag> appendFlagGPS;
343 QFlags<QIODevice::OpenModeFlag> appendFlagGlonass;
344
345 if ( Qt::CheckState(settings.value("rnxAppend").toInt()) == Qt::Checked &&
346 QFile::exists(ephFileNameGPS) ) {
347 appendFlagGPS = QIODevice::Append;
348 }
349
350 _ephFileGPS = new QFile(ephFileNameGPS);
351 _ephFileGPS->open(QIODevice::WriteOnly | appendFlagGPS);
352 _ephStreamGPS = new QTextStream();
353 _ephStreamGPS->setDevice(_ephFileGPS);
354
355 if (_rinexVers > 2) {
356 _ephFileGlonass = _ephFileGPS;
357 _ephStreamGlonass = _ephStreamGPS;
358 _ephFileGalileo = _ephFileGPS;
359 _ephStreamGalileo = _ephStreamGPS;
360 _ephFileSBAS = _ephFileGPS;
361 _ephStreamSBAS = _ephStreamGPS;
362 }
363 else {
364 QString ephFileNameGlonass = _ephPath + "BRDC" +
365 QString("%1").arg(datTim.date().dayOfYear(), 3, 10, QChar('0')) +
366 hlpStr + datTim.toString(".yyG");
367
368 delete _ephStreamGlonass;
369 delete _ephFileGlonass;
370
371 if ( Qt::CheckState(settings.value("rnxAppend").toInt()) == Qt::Checked &&
372 QFile::exists(ephFileNameGlonass) ) {
373 appendFlagGlonass = QIODevice::Append;
374 }
375
376 _ephFileGlonass = new QFile(ephFileNameGlonass);
377 _ephFileGlonass->open(QIODevice::WriteOnly | appendFlagGlonass);
378 _ephStreamGlonass = new QTextStream();
379 _ephStreamGlonass->setDevice(_ephFileGlonass);
380 }
381
382 // Header - RINEX Version 3
383 // ------------------------
384 if (_rinexVers > 2) {
385 if ( ! (appendFlagGPS & QIODevice::Append)) {
386 double rinexVersion = defaultRnxNavVersion4;
387 if (_rinexVers < 4.0) {
388 rinexVersion = defaultRnxNavVersion3;
389 }
390 QString line = QString().asprintf("%9.2f%11sN: GNSS NAV DATA M: Mixed%12sRINEX VERSION / TYPE\n",
391 rinexVersion, "", "");
392 *_ephStreamGPS << line;
393 line.clear();
394
395 QString hlp = currentDateAndTimeGPS().toString("yyyyMMdd hhmmss UTC").leftJustified(20, ' ', true);
396 *_ephStreamGPS << _pgmName.toLatin1().data()
397 << _userName.toLatin1().data()
398 << hlp.toLatin1().data()
399 << "PGM / RUN BY / DATE\n";
400
401 QStringListIterator it(comments);
402 while (it.hasNext()) {
403 *_ephStreamGPS << it.next().trimmed().left(60).leftJustified(60) << "COMMENT\n";
404 }
405
406 if (_rinexVers == 4) {
407 int leapSecs = gnumleap(datTim.date().year(), datTim.date().month(), datTim.date().day());
408 *_ephStreamGPS << QString("%1").arg(leapSecs, 6, 10, QLatin1Char(' ')).left(60).leftJustified(60)
409 << "LEAP SECONDS\n";
410 }
411
412 line = QString().asprintf("%60sEND OF HEADER\n", "");
413 *_ephStreamGPS << line;
414
415 _ephStreamGPS->flush();
416 }
417 }
418
419 // Headers - RINEX Version 2
420 // -------------------------
421 else {
422 if (! (appendFlagGPS & QIODevice::Append)) {
423 QString line = QString().asprintf("%9.2f%11sN: GPS NAV DATA%25sRINEX VERSION / TYPE\n",
424 defaultRnxNavVersion2, "", "");
425 *_ephStreamGPS << line;
426 line.clear();
427
428 QString hlp = currentDateAndTimeGPS().date().toString("dd-MMM-yyyy").leftJustified(20, ' ', true);
429 *_ephStreamGPS << _pgmName.toLatin1().data()
430 << _userName.toLatin1().data()
431 << hlp.toLatin1().data()
432 << "PGM / RUN BY / DATE\n";
433
434 QStringListIterator it(comments);
435 while (it.hasNext()) {
436 *_ephStreamGPS << it.next().trimmed().left(60).leftJustified(60) << "COMMENT\n";
437 }
438
439 line = QString().asprintf("%60sEND OF HEADER\n", "");
440 *_ephStreamGPS << line;
441
442 _ephStreamGPS->flush();
443 }
444 if (! (appendFlagGlonass & QIODevice::Append)) {
445 QString line = QString().asprintf("%9.2f%11sG: GLONASS NAV DATA%21sRINEX VERSION / TYPE\n",
446 defaultRnxNavVersion2, "", "");
447 *_ephStreamGlonass << line;
448 line.clear();
449
450 QString hlp = currentDateAndTimeGPS().date().toString("dd-MMM-yyyy").leftJustified(20, ' ', true);
451 *_ephStreamGlonass << _pgmName.toLatin1().data()
452 << _userName.toLatin1().data()
453 << hlp.toLatin1().data()
454 << "PGM / RUN BY / DATE\n";
455
456 QStringListIterator it(comments);
457 while (it.hasNext()) {
458 *_ephStreamGlonass << it.next().trimmed().left(60).leftJustified(60) << "COMMENT\n";
459 }
460
461 line = QString().asprintf("%60sEND OF HEADER\n", "");
462 *_ephStreamGlonass << line;
463
464 _ephStreamGlonass->flush();
465 }
466 }
467 }
468}
469
470// Print One Ephemeris
471////////////////////////////////////////////////////////////////////////////
472void t_bncCore::printEph(const t_eph& eph, bool printFile) {
473
474 QString strV2 = eph.toString(defaultRnxNavVersion2);
475 QString strV3 = eph.toString(defaultRnxNavVersion3);
476 QString strV4 = eph.toString(defaultRnxNavVersion4);
477
478 if (_rinexVers == 2 && eph.type() == t_eph::GLONASS) {
479 printOutputEph(printFile, _ephStreamGlonass, strV2, strV3, strV4);
480 }
481 else if(_rinexVers == 2 && eph.type() == t_eph::GPS) {
482 printOutputEph(printFile, _ephStreamGPS, strV2, strV3, strV4);
483 }
484 else if (_rinexVers >= 3) {
485 printOutputEph(printFile, _ephStreamGPS, strV2, strV3, strV4);
486 }
487}
488
489// Output
490////////////////////////////////////////////////////////////////////////////
491void t_bncCore::printOutputEph(bool printFile, QTextStream* stream,
492 const QString& strV2, const QString& strV3,
493 const QString& strV4) {
494 QString strVx;
495 if (_rinexVers == 2) {
496 strVx = strV2;
497 }
498 else if (_rinexVers == 3) {
499 strVx = strV3;
500 }
501 else if (_rinexVers == 4) {
502 strVx = strV4;
503 }
504
505 // Output into file
506 // ----------------
507 if (printFile && stream) {
508 *stream << strVx.toLatin1();
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(strVx.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.