Changeset 1348 in ntrip for trunk/BNC/bncrinex.cpp


Ignore:
Timestamp:
Dec 27, 2008, 1:09:16 PM (15 years ago)
Author:
mervart
Message:

* empty log message *

File:
1 edited

Legend:

Unmodified
Added
Removed
  • trunk/BNC/bncrinex.cpp

    r1346 r1348  
    157157    QByteArray _longitude;
    158158    QByteArray _nmea;
    159     bncSocket* socket = bncSocket::request(url, _latitude, _longitude, _nmea, timeOut, msg);
    160 
    161     if (socket) {
    162       _headerLines.clear();
    163       bool firstLineRead = false;
    164       while (true) {
    165         if (socket->canReadLine()) {
    166           QString line = socket->readLine();
    167           line.chop(1);
    168           if (line.indexOf("MARKER NAME") != -1) {
    169             irc = success;
    170           }
    171           if (line.indexOf("RINEX VERSION") != -1) {
    172             if (_rinexVers == 3) {
    173               _headerLines.append("     3.00           OBSERVATION DATA"
    174                                   "    M (MIXED)"
    175                                   "           RINEX VERSION / TYPE");
    176             }
    177             else {
    178               _headerLines.append("     2.11           OBSERVATION DATA"
    179                                   "    M (MIXED)"
    180                                   "           RINEX VERSION / TYPE");
    181             }
    182             _headerLines.append("PGM / RUN BY / DATE");
    183             firstLineRead = true;
    184           }
    185           else if (firstLineRead) {
    186             if (line.indexOf("END OF HEADER") != -1) {
    187               _headerLines.append("# / TYPES OF OBSERV");
    188               if (_rinexVers == 2) {
    189                 _headerLines.append(
    190                       QString("     1     1").leftJustified(60, ' ', true) +
    191                       "WAVELENGTH FACT L1/2");
    192               }
    193               _headerLines.append("TIME OF FIRST OBS");
    194               _headerLines.append( line );
    195               break;
    196             }
    197             else {
    198               _headerLines.append( line );
    199             }
    200           }
    201         }
    202         else {
    203           socket->waitForReadyRead(timeOut);
    204           if (socket->bytesAvailable() > 0) {
    205             continue;
     159    bncSocket* socket = new bncSocket();
     160    if (socket->request(url, _latitude, _longitude,
     161                        _nmea, timeOut, msg) != success) {
     162      delete socket;
     163      return failure;
     164    }
     165
     166    _headerLines.clear();
     167    bool firstLineRead = false;
     168    while (true) {
     169      if (socket->canReadLine()) {
     170        QString line = socket->readLine();
     171        line.chop(1);
     172        if (line.indexOf("MARKER NAME") != -1) {
     173          irc = success;
     174        }
     175        if (line.indexOf("RINEX VERSION") != -1) {
     176          if (_rinexVers == 3) {
     177            _headerLines.append("     3.00           OBSERVATION DATA"
     178                                "    M (MIXED)"
     179                                "           RINEX VERSION / TYPE");
    206180          }
    207181          else {
     182            _headerLines.append("     2.11           OBSERVATION DATA"
     183                                "    M (MIXED)"
     184                                "           RINEX VERSION / TYPE");
     185          }
     186          _headerLines.append("PGM / RUN BY / DATE");
     187          firstLineRead = true;
     188        }
     189        else if (firstLineRead) {
     190          if (line.indexOf("END OF HEADER") != -1) {
     191            _headerLines.append("# / TYPES OF OBSERV");
     192            if (_rinexVers == 2) {
     193              _headerLines.append(
     194                    QString("     1     1").leftJustified(60, ' ', true) +
     195                    "WAVELENGTH FACT L1/2");
     196            }
     197            _headerLines.append("TIME OF FIRST OBS");
     198            _headerLines.append( line );
    208199            break;
    209200          }
    210         }
    211       }
    212       delete socket;
     201          else {
     202            _headerLines.append( line );
     203          }
     204        }
     205      }
     206      else {
     207        socket->waitForReadyRead(timeOut);
     208        if (socket->bytesAvailable() > 0) {
     209          continue;
     210        }
     211        else {
     212          break;
     213        }
     214      }
    213215    }
    214216  }
Note: See TracChangeset for help on using the changeset viewer.