source: ntrip/trunk/BNC/bncapp.cpp@ 3046

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