Changeset 1299 in ntrip for trunk/BNC/bncgetthread.cpp

Timestamp:

Dec 12, 2008, 5:58:00 PM (15 years ago)

Author:

zdenek

Message:

* empty log message *

File:

• trunk/BNC/bncgetthread.cpp (modified) (19 diffs)

trunk/BNC/bncgetthread.cpp

@@ -111 +111 @@
       
   bncApp* app = (bncApp*) qApp;
-  app->connect(this, SIGNAL(newMessage(QByteArray)), 
-               app, SLOT(slotMessage(const QByteArray)));
+  app->connect(this, SIGNAL(newMessage(QByteArray,bool)), 
+               app, SLOT(slotMessage(const QByteArray,bool)));
 
   _decoder    = 0;
@@ -406 +406 @@
         emit(newMessage((_staID + ": Caster Response: " + line + 
                          "          Adjust User-ID and Password Register, see"
-                         "\n          " + reg).toAscii()));
+                         "\n          " + reg).toAscii(), true));
         return fatal;
       }
       if (line.indexOf("ICY 200 OK") != 0) {
-        emit(newMessage((_staID + ": Wrong Caster Response:\n" + line).toAscii()));
+        emit(newMessage((_staID + ": Wrong Caster Response:\n" + line).toAscii(), true));
         return failure;
       }
     }
     else {
-      emit(newMessage(_staID + ": Response Timeout"));
+      emit(newMessage(_staID + ": Response Timeout", true));
       return failure;
     }
@@ -424 +424 @@
   if (!_decoder) { 
     if      (_format.indexOf("RTCM_2") != -1) {
-      emit(newMessage("Get Data: " + _staID + " in RTCM 2.x format"));
+      emit(newMessage("Get Data: " + _staID + " in RTCM 2.x format", true));
       _decoder = new RTCM2Decoder(_staID.data());
     }
     else if (_format.indexOf("RTCM_3") != -1) {
-      emit(newMessage("Get Data: " + _staID + " in RTCM 3.x format"));
+      emit(newMessage("Get Data: " + _staID + " in RTCM 3.x format", true));
       _decoder = new RTCM3Decoder(_staID);
-      connect((RTCM3Decoder*) _decoder, SIGNAL(newMessage(QByteArray)), 
-              this, SIGNAL(newMessage(QByteArray)));
+      connect((RTCM3Decoder*) _decoder, SIGNAL(newMessage(QByteArray,bool)), 
+              this, SIGNAL(newMessage(QByteArray,bool)));
     }
     else if (_format.indexOf("RTIGS") != -1) {
-      emit(newMessage("Get Data: " + _staID + " in RTIGS format"));
+      emit(newMessage("Get Data: " + _staID + " in RTIGS format", true));
       _decoder = new RTIGSDecoder();
     }
     else if (_format.indexOf("ZERO") != -1) {
-      emit(newMessage("Get Data: " + _staID + " in original format"));
+      emit(newMessage("Get Data: " + _staID + " in original format", true));
       _decoder = new bncZeroDecoder(_staID);
     }
     else {
-      emit(newMessage(_staID + ": Unknown data format " + _format));
+      emit(newMessage(_staID + ": Unknown data format " + _format, true));
       if (_rawInpFile) {
         cerr << "Uknown data format" << endl;
@@ -491 +491 @@
   }
   else if (irc != success) {
-    emit(newMessage(_staID + ": initRun failed, reconnecting"));
+    emit(newMessage(_staID + ": initRun failed, reconnecting", true));
     tryReconnect();
   }
@@ -506 +506 @@
     try {
       if (_socket && _socket->state() != QAbstractSocket::ConnectedState) {
-        emit(newMessage(_staID + ": Socket not connected, reconnecting"));
+        emit(newMessage(_staID + ": Socket not connected, reconnecting", true));
         tryReconnect();
       }
@@ -553 +553 @@
 #ifdef DEBUG_RTCM2_2021
           for (unsigned ii = 0; ii < errmsg.size(); ii++) {
-            emit newMessage(_staID + ": " + errmsg[ii].c_str());
+            emit newMessage(_staID + ": " + errmsg[ii].c_str(), false);
           }
 #endif
@@ -574 +574 @@
 #ifdef DEBUG_RTCM2_2021
               for (unsigned ii = 0; ii < errmsg.size(); ii++) {
-                emit newMessage(_staID + ": " + errmsg[ii].c_str());
+                emit newMessage(_staID + ": " + errmsg[ii].c_str(), false);
               }
 #endif
@@ -619 +619 @@
                 _endDateCor = QDateTime::currentDateTime().addSecs(- _adviseReco * 60).toUTC().date().toString("yy-MM-dd");
                 _endTimeCor = QDateTime::currentDateTime().addSecs(- _adviseReco * 60).toUTC().time().toString("hh:mm:ss");
-                emit(newMessage((_staID + ": Recovery threshold exceeded, corruption ended " + _endDateCor + " " + _endTimeCor).toAscii()));
+                emit(newMessage((_staID + ": Recovery threshold exceeded, corruption ended " 
+                                + _endDateCor + " " + _endTimeCor).toAscii(), true));
                 callScript(("End_Corrupted " + _endDateCor + " " + _endTimeCor + " Begin was " + _begDateCor + " " + _begTimeCor).toAscii());
                 endCorrupt = true;
@@ -632 +633 @@
                   _begDateCor = _decodeSucc.toUTC().date().toString("yy-MM-dd");
                   _begTimeCor = _decodeSucc.toUTC().time().toString("hh:mm:ss");
-                  emit(newMessage((_staID + ": Failure threshold exceeded, corrupted since " + _begDateCor + " " + _begTimeCor).toAscii()));
+                  emit(newMessage((_staID + ": Failure threshold exceeded, corrupted since " 
+                                  + _begDateCor + " " + _begTimeCor).toAscii(), true));
                   callScript(("Begin_Corrupted " + _begDateCor + " " + _begTimeCor).toAscii());
                   begCorrupt = true;
@@ -653 +655 @@
             _endDateOut = QDateTime::currentDateTime().addSecs(- _adviseReco * 60).toUTC().date().toString("yy-MM-dd");
             _endTimeOut = QDateTime::currentDateTime().addSecs(- _adviseReco * 60).toUTC().time().toString("hh:mm:ss");
-            emit(newMessage((_staID + ": Recovery threshold exceeded, outage ended " + _endDateOut + " " + _endTimeOut).toAscii()));
+            emit(newMessage((_staID + ": Recovery threshold exceeded, outage ended " 
+                            + _endDateOut + " " + _endTimeOut).toAscii(), true));
             callScript(("End_Outage " + _endDateOut + " " + _endTimeOut + " Begin was " + _begDateOut + " " + _begTimeOut).toAscii());
           }
@@ -671 +674 @@
             for (int ii=0;ii<_decoder->_typeList.size();ii++) {
               type =  QString("%1 ").arg(_decoder->_typeList[ii]);
-              emit(newMessage(_staID + ": Received message type " + type.toAscii() ));
+              emit(newMessage(_staID + ": Received message type " + type.toAscii(), true));
             }
           }
@@ -681 +684 @@
             for (int ii=0;ii<_decoder->_antType.size();ii++) {
               ant1 =  QString("%1 ").arg(_decoder->_antType[ii]);
-              emit(newMessage(_staID + ": Antenna descriptor " + ant1.toAscii() ));
+              emit(newMessage(_staID + ": Antenna descriptor " + ant1.toAscii(), true));
             }
           }
@@ -697 +700 @@
               case GPSDecoder::t_antInfo::APC: antT = "APC"; break;
               }
-              emit(newMessage(_staID + ": " + antT + " (ITRF) X " + ant1 + "m"));
-              emit(newMessage(_staID + ": " + antT + " (ITRF) Y " + ant2 + "m"));
-              emit(newMessage(_staID + ": " + antT + " (ITRF) Z " + ant3 + "m"));
+              emit(newMessage(_staID + ": " + antT + " (ITRF) X " + ant1 + "m", true));
+              emit(newMessage(_staID + ": " + antT + " (ITRF) Y " + ant2 + "m", true));
+              emit(newMessage(_staID + ": " + antT + " (ITRF) Z " + ant3 + "m", true));
               if (_decoder->_antList[ii].height_f) {
                 QByteArray ant4 = QString("%1 ").arg(_decoder->_antList[ii].height,0,'f',4).toAscii();
-                emit(newMessage(_staID + ": Antenna height above marker "  + ant4 + "m"));
+                emit(newMessage(_staID + ": Antenna height above marker "  + ant4 + "m", true));
               }
               emit(newAntCrd(_staID, 
@@ -752 +755 @@
             if (week != obs->_o.GPSWeek || dt > maxDt) {
               if  (!wrongEpoch) {
-                emit( newMessage(_staID + ": Wrong observation epoch(s)") );
+                emit( newMessage(_staID + ": Wrong observation epoch(s)", true) );
                 wrongEpoch = true;
               }
@@ -777 +780 @@
                           .arg(numLat)
                           .arg(numGaps)
-                          .toAscii()) );
+                          .toAscii(), true) );
                       } else {
                         emit( newMessage(QString("%1: Mean latency %2 sec, min %3, max %4, rms %5, %6 epochs")
@@ -786 +789 @@
                           .arg(int((sqrt((sumLatQ - sumLat * sumLat / numLat)/numLat))*100)/100.)
                           .arg(numLat)
-                          .toAscii()) );
+                          .toAscii(), true) );
                       }
                     }
@@ -882 +885 @@
       // ------------------
       else {
-        emit(newMessage(_staID + ": Data Timeout, reconnecting"));
+        emit(newMessage(_staID + ": Data Timeout, reconnecting", true));
         tryReconnect();
       }
     }
     catch (const char* msg) {
-      emit(newMessage(_staID + msg));
+      emit(newMessage(_staID + msg, true));
       tryReconnect();
     }
@@ -931 +934 @@
           _begDateOut = _decodeTime.toUTC().date().toString("yy-MM-dd");
           _begTimeOut = _decodeTime.toUTC().time().toString("hh:mm:ss");
-          emit(newMessage((_staID + ": Failure threshold exceeded, outage since " + _begDateOut + " " + _begTimeOut).toAscii()));
+          emit(newMessage((_staID + ": Failure threshold exceeded, outage since " 
+                          + _begDateOut + " " + _begTimeOut).toAscii(), true));
           callScript(("Begin_Outage " + _begDateOut + " " + _begTimeOut).toAscii());
         }
@@ -978 +982 @@
       }
       
-      emit(newMessage(msg.toAscii()));
+      emit(newMessage(msg.toAscii(), false));
 #endif
     }