Changeset 369 in ntrip for trunk/BNC

Timestamp:

Jan 18, 2007, 2:17:43 PM (17 years ago)

Author:

mervart

Message:

* empty log message *

Location:

trunk/BNC

Files:

• bnccaster.cpp (modified) (1 diff)
• bnccaster.h (modified) (1 diff)
• bncgetthread.cpp (modified) (1 diff)
• bncrinex.cpp (modified) (2 diffs)
• bncrinex.h (modified) (2 diffs)

trunk/BNC/bnccaster.cpp

@@ -110 +110 @@
   delete _sockets;
   delete _epochs;
+}
+
+// Reconnecting
+////////////////////////////////////////////////////////////////////////////
+void bncCaster::reconnecting(const QByteArray& staID) {
+  if (_rinexWriters.find(staID) != _rinexWriters.end()) {
+    bncRinex* rnx = _rinexWriters.find(staID).value();
+    rnx->setReconnectFlag(true);
+  }
 }
 

trunk/BNC/bnccaster.h

@@ -48 +48 @@
                const QByteArray& latitude, const QByteArray& longitude,
                const QByteArray& nmea);
+   void reconnecting(const QByteArray& staID);
 
  signals:

trunk/BNC/bncgetthread.cpp

@@ -400 +400 @@
 ////////////////////////////////////////////////////////////////////////////
 void bncGetThread::tryReconnect() {
+  _global_caster->reconnecting(_staID);
   while (1) {
     delete _socket; _socket = 0;

trunk/BNC/bncrinex.cpp

@@ -71 +71 @@
   _nmea          = nmea;
   _headerWritten = false;
+  _reconnectFlag = false;
 
   QSettings settings;
@@ -309 +310 @@
   // ----------------------------------
   if ( QFile::exists(_fName) ) {
-//    QSettings settings;
-    if ( Qt::CheckState(settings.value("rnxAppend").toInt()) == Qt::Checked) {
+    if (_reconnectFlag ||
+        Qt::CheckState(settings.value("rnxAppend").toInt()) == Qt::Checked) {
       _out.open(_fName.data(), ios::app);
       _out.setf(ios::showpoint | ios::fixed);
       _headerWritten = true;
+      _reconnectFlag = false;
       return;
     }

trunk/BNC/bncrinex.h

@@ -44 +44 @@
    void deepCopy(const Observation* obs);
    void dumpEpoch(long maxTime);
+   void setReconnectFlag(bool flag){_reconnectFlag = flag;}
 
  private:
@@ -67 +68 @@
    QByteArray          _longitude;
    QByteArray          _nmea;
+   bool                _reconnectFlag;
 };