Changeset 9730 in ntrip

Timestamp:

May 23, 2022, 10:11:47 PM (2 years ago)

Author:

stuerze

Message:

minor changes

File:

• trunk/BNC/src/upload/bncuploadcaster.cpp (modified) (6 diffs)

trunk/BNC/src/upload/bncuploadcaster.cpp

@@ -234 +234 @@
   connect(_outSocket, SIGNAL(sslErrors(QList<QSslError>)), this, SLOT(slotSslErrors(QList<QSslError>)));
 
-  if (_proxy) {
+  if (!_proxy) {
+    if (!connectToHost(_casterOutHost, _casterOutPort, _secure)) {
+      return;
+    }
+  } else {
     if (_ntripVersion == "1") {
       emit(newMessage("No proxy support in Ntrip Version 1 upload!", true));
-      delete _outSocket;
-      _outSocket=0;
+      _outSocket->close();
       return;
     }
@@ -274 +277 @@
         if (!_outSocket->waitForEncrypted(timeOut)) {
           emit(newMessage(
-              "Proxy: Encrypt timeout for " + _mountpoint.toLatin1() + " ("
+              "Proxy/Caster: Encrypt timeout for " + _mountpoint.toLatin1() + " ("
                   + _casterOutHost.toLatin1() + ":"
                   + QString("%1) ").arg(_casterOutPort).toLatin1()
@@ -284 +287 @@
       }
     }
-  } else {
-    if (!connectToHost(_casterOutHost, _casterOutPort, _secure)) {
-      return;
-    }
   }
 
@@ -306 +305 @@
   _outSocket->waitForReadyRead();
 
-  QByteArray ans = _outSocket->readLine();  cout << "ans: " << ans.toStdString().c_str() << endl;
+   QByteArray ans = "";
+  if (_outSocket->canReadLine()) {
+    ans = _outSocket->readLine();  cout << "ans: " << ans.toStdString().c_str() << endl;
+  }
 
   if (ans.indexOf("200") == -1) {
@@ -333 +335 @@
               + QString("%1) ").arg(outPort).toLatin1()
               + _outSocket->errorString().toLatin1(), true));
-      //delete _outSocket;
-      //_outSocket=0;
       return false;
     } else {
@@ -347 +347 @@
               + QString("%1) ").arg(outPort).toLatin1()
               + _outSocket->errorString().toLatin1(), true));
-      //delete _outSocket;
-      //_outSocket=0;
       return false;
     }