Changeset 8161 in ntrip


Ignore:
Timestamp:
Oct 23, 2017, 10:24:24 AM (7 years ago)
Author:
stuerze
Message:

bug fixed in RTCM3MSM Decoder and file format is adapted to the format, which is used in the overall BNC project

File:
1 edited

Legend:

Unmodified
Added
Removed
  • branches/BNC_2.12/src/RTCM3/RTCM3Decoder.cpp

    r7875 r8161  
    6464////////////////////////////////////////////////////////////////////////////
    6565RTCM3Decoder::RTCM3Decoder(const QString& staID, bncRawFile* rawFile) :
    66                 GPSDecoder() {
    67 
    68   _staID   = staID;
     66    GPSDecoder() {
     67
     68  _staID = staID;
    6969  _rawFile = rawFile;
    7070
    71   connect(this, SIGNAL(newGPSEph(t_ephGPS)),     BNC_CORE, SLOT(slotNewGPSEph(t_ephGPS)));
    72   connect(this, SIGNAL(newGlonassEph(t_ephGlo)), BNC_CORE, SLOT(slotNewGlonassEph(t_ephGlo)));
    73   connect(this, SIGNAL(newGalileoEph(t_ephGal)), BNC_CORE, SLOT(slotNewGalileoEph(t_ephGal)));
    74   connect(this, SIGNAL(newSBASEph(t_ephSBAS)),   BNC_CORE, SLOT(slotNewSBASEph(t_ephSBAS)));
    75   connect(this, SIGNAL(newBDSEph(t_ephBDS)),     BNC_CORE, SLOT(slotNewBDSEph(t_ephBDS)));
     71  connect(this, SIGNAL(newGPSEph(t_ephGPS)), BNC_CORE,
     72      SLOT(slotNewGPSEph(t_ephGPS)));
     73  connect(this, SIGNAL(newGlonassEph(t_ephGlo)), BNC_CORE,
     74      SLOT(slotNewGlonassEph(t_ephGlo)));
     75  connect(this, SIGNAL(newGalileoEph(t_ephGal)), BNC_CORE,
     76      SLOT(slotNewGalileoEph(t_ephGal)));
     77  connect(this, SIGNAL(newSBASEph(t_ephSBAS)), BNC_CORE,
     78      SLOT(slotNewSBASEph(t_ephSBAS)));
     79  connect(this, SIGNAL(newBDSEph(t_ephBDS)), BNC_CORE,
     80      SLOT(slotNewBDSEph(t_ephBDS)));
    7681
    7782  _MessageSize = _SkipBytes = _BlockSize = _NeedBytes = 0;
     
    8287RTCM3Decoder::~RTCM3Decoder() {
    8388  QMapIterator<QByteArray, RTCM3coDecoder*> it(_coDecoders);
    84   while(it.hasNext())
     89  while (it.hasNext())
    8590  {
    8691    it.next();
     
    9196//
    9297////////////////////////////////////////////////////////////////////////////
    93 bool RTCM3Decoder::DecodeRTCM3GPS(unsigned char* data, int size)
    94 {
     98bool RTCM3Decoder::DecodeRTCM3GPS(unsigned char* data, int size) {
    9599  bool decoded = false;
    96100  bncTime CurrentObsTime;
     
    102106
    103107  GETBITS(type, 12)
    104   SKIPBITS(12) /* id */
    105   GETBITS(i,30)
     108  SKIPBITS(12)
     109  /* id */
     110  GETBITS(i, 30)
    106111
    107112  CurrentObsTime.set(i);
    108   if(_CurrentTime.valid() && CurrentObsTime != _CurrentTime)
    109   {
     113  if (_CurrentTime.valid() && CurrentObsTime != _CurrentTime) {
    110114    decoded = true;
    111     _obsList.append(_CurrentObsList);
     115    _obsList = _CurrentObsList;
    112116    _CurrentObsList.clear();
    113117  }
     
    115119  _CurrentTime = CurrentObsTime;
    116120
    117   GETBITS(syncf,1) /* sync */
    118   GETBITS(numsats,5)
    119   SKIPBITS(4) /* smind, smint */
    120 
    121   while(numsats--)
    122   {
    123     int sv, code, l1range, amb=0;
     121  GETBITS(syncf, 1)
     122  /* sync */
     123  GETBITS(numsats, 5)
     124  SKIPBITS(4)
     125  /* smind, smint */
     126
     127  while (numsats--) {
     128    int sv, code, l1range, amb = 0;
    124129    t_satObs CurrentObs;
    125130    CurrentObs._time = CurrentObsTime;
    126131
    127132    GETBITS(sv, 6)
    128     if(sv < 40)
     133    if (sv < 40)
    129134      CurrentObs._prn.set('G', sv);
    130135    else
    131       CurrentObs._prn.set('S', sv-20);
     136      CurrentObs._prn.set('S', sv - 20);
    132137
    133138    t_frqObs *frqObs = new t_frqObs;
    134139    /* L1 */
    135140    GETBITS(code, 1);
    136     (code) ? frqObs->_rnxType2ch.assign("1W") : frqObs->_rnxType2ch.assign("1C");
     141    (code) ?
     142        frqObs->_rnxType2ch.assign("1W") : frqObs->_rnxType2ch.assign("1C");
    137143    GETBITS(l1range, 24);
    138144    GETBITSSIGN(i, 20);
    139     if((i&((1<<20)-1)) != 0x80000)
    140     {
    141       frqObs->_code = l1range*0.02;
    142       frqObs->_phase = (l1range*0.02+i*0.0005)/GPS_WAVELENGTH_L1;
     145    if ((i & ((1 << 20) - 1)) != 0x80000) {
     146      frqObs->_code = l1range * 0.02;
     147      frqObs->_phase = (l1range * 0.02 + i * 0.0005) / GPS_WAVELENGTH_L1;
    143148      frqObs->_codeValid = frqObs->_phaseValid = true;
    144149    }
    145150    GETBITS(i, 7);
    146151    frqObs->_slipCounter = i;
    147     if(type == 1002 || type == 1004)
    148     {
    149       GETBITS(amb,8);
    150       if(amb)
    151       {
    152         frqObs->_code += amb*299792.458;
    153         frqObs->_phase += (amb*299792.458)/GPS_WAVELENGTH_L1;
     152    if (type == 1002 || type == 1004) {
     153      GETBITS(amb, 8);
     154      if (amb) {
     155        frqObs->_code += amb * 299792.458;
     156        frqObs->_phase += (amb * 299792.458) / GPS_WAVELENGTH_L1;
    154157      }
    155158      GETBITS(i, 8);
    156       if(i)
    157       {
    158         frqObs->_snr = i*0.25;
     159      if (i) {
     160        frqObs->_snr = i * 0.25;
    159161        frqObs->_snrValid = true;
    160162      }
    161163    }
    162164    CurrentObs._obs.push_back(frqObs);
    163     if(type == 1003 || type == 1004)
    164     {
     165    if (type == 1003 || type == 1004) {
    165166      frqObs = new t_frqObs;
    166167      /* L2 */
    167       GETBITS(code,2);
    168       switch(code)
    169       {
    170       case 3: frqObs->_rnxType2ch.assign("2W"); /* or "2Y"? */ break;
    171       case 2: frqObs->_rnxType2ch.assign("2W"); break;
    172       case 1: frqObs->_rnxType2ch.assign("2P"); break;
    173       case 0: frqObs->_rnxType2ch.assign("2X"); /* or "2S" or "2L"? */ break;
    174       }
    175       GETBITSSIGN(i,14);
    176       if((i&((1<<14)-1)) != 0x2000)
    177       {
    178         frqObs->_code = l1range*0.02+i*0.02+amb*299792.458;
     168      GETBITS(code, 2);
     169      switch (code) {
     170        case 3:
     171          frqObs->_rnxType2ch.assign("2W"); /* or "2Y"? */
     172          break;
     173        case 2:
     174          frqObs->_rnxType2ch.assign("2W");
     175          break;
     176        case 1:
     177          frqObs->_rnxType2ch.assign("2P");
     178          break;
     179        case 0:
     180          frqObs->_rnxType2ch.assign("2X"); /* or "2S" or "2L"? */
     181          break;
     182      }
     183      GETBITSSIGN(i, 14);
     184      if ((i & ((1 << 14) - 1)) != 0x2000) {
     185        frqObs->_code = l1range * 0.02 + i * 0.02 + amb * 299792.458;
    179186        frqObs->_codeValid = true;
    180187      }
    181       GETBITSSIGN(i,20);
    182       if((i&((1<<20)-1)) != 0x80000)
    183       {
    184         frqObs->_phase = (l1range*0.02+i*0.0005+amb*299792.458)/GPS_WAVELENGTH_L2;
     188      GETBITSSIGN(i, 20);
     189      if ((i & ((1 << 20) - 1)) != 0x80000) {
     190        frqObs->_phase = (l1range * 0.02 + i * 0.0005 + amb * 299792.458)
     191            / GPS_WAVELENGTH_L2;
    185192        frqObs->_phaseValid = true;
    186193      }
    187       GETBITS(i,7);
     194      GETBITS(i, 7);
    188195      frqObs->_slipCounter = i;
    189       if(type == 1004)
    190       {
     196      if (type == 1004) {
    191197        GETBITS(i, 8);
    192         if(i)
    193         {
    194           frqObs->_snr = i*0.25;
     198        if (i) {
     199          frqObs->_snr = i * 0.25;
    195200          frqObs->_snrValid = true;
    196201        }
     
    201206  }
    202207
    203   if(!syncf)
    204   {
     208  if (!syncf) {
    205209    decoded = true;
    206210    _obsList.append(_CurrentObsList);
     
    230234
    231235/** MSM signal types for GPS and SBAS */
    232 static struct CodeData gps[RTCM3_MSM_NUMSIG] =
    233 {
    234   {0.0,0},
    235   {GPS_WAVELENGTH_L1,"1C"},
    236   {GPS_WAVELENGTH_L1,"1P"},
    237   {GPS_WAVELENGTH_L1,"1W"},
    238   {0.0,0}/*{GPS_WAVELENGTH_L1,"1Y"}*/,
    239   {0.0,0},
    240   {0.0,0},
    241   {GPS_WAVELENGTH_L2,"2C"},
    242   {GPS_WAVELENGTH_L2,"2P"},
    243   {GPS_WAVELENGTH_L2,"2W"},
    244   {0.0,0}/*{GPS_WAVELENGTH_L2,"2Y"}*/,
    245   {0.0,0},
    246   {0.0,0},
    247   {0.0,0},
    248   {GPS_WAVELENGTH_L2,"2S"},
    249   {GPS_WAVELENGTH_L2,"2L"},
    250   {GPS_WAVELENGTH_L2,"2X"},
    251   {0.0,0},
    252   {0.0,0},
    253   {0.0,0},
    254   {0.0,0},
    255   {GPS_WAVELENGTH_L5,"5I"},
    256   {GPS_WAVELENGTH_L5,"5Q"},
    257   {GPS_WAVELENGTH_L5,"5X"},
    258   {0.0,0},
    259   {0.0,0},
    260   {0.0,0},
    261   {0.0,0},
    262   {0.0,0},
    263   {GPS_WAVELENGTH_L1,"1S"},
    264   {GPS_WAVELENGTH_L1,"1L"},
    265   {GPS_WAVELENGTH_L1,"1X"}
    266 };
     236static struct CodeData gps[RTCM3_MSM_NUMSIG] = {
     237        {0.0, 0},
     238        {GPS_WAVELENGTH_L1, "1C"},
     239        {GPS_WAVELENGTH_L1, "1P"},
     240        {GPS_WAVELENGTH_L1, "1W"},
     241        {0.0, 0}/*{GPS_WAVELENGTH_L1,"1Y"}*/,
     242        {0.0, 0},
     243        {0.0, 0},
     244        {GPS_WAVELENGTH_L2, "2C"},
     245        {GPS_WAVELENGTH_L2, "2P"},
     246        {GPS_WAVELENGTH_L2, "2W"},
     247        {0.0, 0}/*{GPS_WAVELENGTH_L2,"2Y"}*/,
     248        {0.0, 0},
     249        {0.0, 0},
     250        {0.0, 0},
     251        {GPS_WAVELENGTH_L2, "2S"},
     252        {GPS_WAVELENGTH_L2, "2L"},
     253        {GPS_WAVELENGTH_L2, "2X"},
     254        {0.0, 0},
     255        {0.0, 0},
     256        {0.0, 0},
     257        {0.0, 0},
     258        {GPS_WAVELENGTH_L5, "5I"},
     259        {GPS_WAVELENGTH_L5, "5Q"},
     260        {GPS_WAVELENGTH_L5, "5X"},
     261        {0.0, 0},
     262        {0.0, 0},
     263        {0.0, 0},
     264        {0.0, 0},
     265        {0.0, 0},
     266        {GPS_WAVELENGTH_L1, "1S"},
     267        {GPS_WAVELENGTH_L1, "1L"},
     268        {GPS_WAVELENGTH_L1, "1X"}
     269    };
    267270
    268271/**
     
    271274 * NOTE: Uses 0.0, 1.0 for wavelength as sat index dependence is done later!
    272275 */
    273 static struct CodeData glo[RTCM3_MSM_NUMSIG] =
    274 {
    275   {0.0,0},
    276   {0.0,"1C"},
    277   {0.0,"1P"},
    278   {0.0,0},
    279   {0.0,0},
    280   {0.0,0},
    281   {0.0,0},
    282   {1.0,"2C"},
    283   {1.0,"2P"},
    284   {0.0,0},
    285   {0.0,0},
    286   {0.0,0},
    287   {0.0,0},
    288   {0.0,0},
    289   {0.0,0},
    290   {0.0,0},
    291   {0.0,0},
    292   {0.0,0},
    293   {0.0,0},
    294   {0.0,0},
    295   {0.0,0},
    296   {0.0,0},
    297   {0.0,0},
    298   {0.0,0},
    299   {0.0,0},
    300   {0.0,0},
    301   {0.0,0},
    302   {0.0,0},
    303   {0.0,0},
    304   {0.0,0},
    305   {0.0,0},
    306   {0.0,0}
    307 };
     276static struct CodeData glo[RTCM3_MSM_NUMSIG] = {
     277        {0.0, 0},
     278        {0.0, "1C"},
     279        {0.0, "1P"},
     280        {0.0, 0},
     281        {0.0, 0},
     282        {0.0, 0},
     283        {0.0, 0},
     284        {1.0, "2C"},
     285        {1.0, "2P"},
     286        {0.0, 0},
     287        {0.0, 0},
     288        {0.0, 0},
     289        {0.0, 0},
     290        {0.0, 0},
     291        {0.0, 0},
     292        {0.0, 0},
     293        {0.0, 0},
     294        {0.0, 0},
     295        {0.0, 0},
     296        {0.0, 0},
     297        {0.0, 0},
     298        {0.0, 0},
     299        {0.0, 0},
     300        {0.0, 0},
     301        {0.0, 0},
     302        {0.0, 0},
     303        {0.0, 0},
     304        {0.0, 0},
     305        {0.0, 0},
     306        {0.0, 0},
     307        {0.0, 0},
     308        {0.0, 0}
     309    };
    308310
    309311/** MSM signal types for Galileo */
    310 static struct CodeData gal[RTCM3_MSM_NUMSIG] =
    311 {
    312   {0.0,0},
    313   {GAL_WAVELENGTH_E1,"1C"},
    314   {GAL_WAVELENGTH_E1,"1A"},
    315   {GAL_WAVELENGTH_E1,"1B"},
    316   {GAL_WAVELENGTH_E1,"1X"},
    317   {GAL_WAVELENGTH_E1,"1Z"},
    318   {0.0,0},
    319   {GAL_WAVELENGTH_E6,"6C"},
    320   {GAL_WAVELENGTH_E6,"6A"},
    321   {GAL_WAVELENGTH_E6,"6B"},
    322   {GAL_WAVELENGTH_E6,"6X"},
    323   {GAL_WAVELENGTH_E6,"6Z"},
    324   {0.0,0},
    325   {GAL_WAVELENGTH_E5B,"7I"},
    326   {GAL_WAVELENGTH_E5B,"7Q"},
    327   {GAL_WAVELENGTH_E5B,"7X"},
    328   {0.0,0},
    329   {GAL_WAVELENGTH_E5AB,"8I"},
    330   {GAL_WAVELENGTH_E5AB,"8Q"},
    331   {GAL_WAVELENGTH_E5AB,"8X"},
    332   {0.0,0},
    333   {GAL_WAVELENGTH_E5A,"5I"},
    334   {GAL_WAVELENGTH_E5A,"5Q"},
    335   {GAL_WAVELENGTH_E5A,"5X"},
    336   {0.0,0},
    337   {0.0,0},
    338   {0.0,0},
    339   {0.0,0},
    340   {0.0,0},
    341   {0.0,0},
    342   {0.0,0},
    343   {0.0,0},
    344 };
     312static struct CodeData gal[RTCM3_MSM_NUMSIG] = {
     313        {0.0, 0},
     314        {GAL_WAVELENGTH_E1, "1C"},
     315        {GAL_WAVELENGTH_E1, "1A"},
     316        {GAL_WAVELENGTH_E1, "1B"},
     317        {GAL_WAVELENGTH_E1, "1X"},
     318        {GAL_WAVELENGTH_E1, "1Z"},
     319        {0.0, 0},
     320        {GAL_WAVELENGTH_E6, "6C"},
     321        {GAL_WAVELENGTH_E6, "6A"},
     322        {GAL_WAVELENGTH_E6, "6B"},
     323        {GAL_WAVELENGTH_E6, "6X"},
     324        {GAL_WAVELENGTH_E6, "6Z"},
     325        {0.0, 0},
     326        {GAL_WAVELENGTH_E5B, "7I"},
     327        {GAL_WAVELENGTH_E5B, "7Q"},
     328        {GAL_WAVELENGTH_E5B, "7X"},
     329        {0.0, 0},
     330        {GAL_WAVELENGTH_E5AB, "8I"},
     331        {GAL_WAVELENGTH_E5AB, "8Q"},
     332        {GAL_WAVELENGTH_E5AB, "8X"},
     333        {0.0, 0},
     334        {GAL_WAVELENGTH_E5A, "5I"},
     335        {GAL_WAVELENGTH_E5A, "5Q"},
     336        {GAL_WAVELENGTH_E5A, "5X"},
     337        {0.0, 0},
     338        {0.0, 0},
     339        {0.0, 0},
     340        {0.0, 0},
     341        {0.0, 0},
     342        {0.0, 0},
     343        {0.0, 0},
     344        {0.0, 0},
     345    };
    345346
    346347/** MSM signal types for QZSS */
    347 static struct CodeData qzss[RTCM3_MSM_NUMSIG] =
    348 {
    349   {0.0,0},
    350   {GPS_WAVELENGTH_L1,"1C"},
    351   {0.0,0},
    352   {0.0,0},
    353   {0.0,0},
    354   {GPS_WAVELENGTH_L1,"1Z"},
    355   {0.0,0},
    356   {0.0,0},
    357   {QZSS_WAVELENGTH_LEX,"6S"},
    358   {QZSS_WAVELENGTH_LEX,"6L"},
    359   {QZSS_WAVELENGTH_LEX,"6X"},
    360   {0.0,0},
    361   {0.0,0},
    362   {0.0,0},
    363   {GPS_WAVELENGTH_L2,"2S"},
    364   {GPS_WAVELENGTH_L2,"2L"},
    365   {GPS_WAVELENGTH_L2,"2X"},
    366   {0.0,0},
    367   {0.0,0},
    368   {0.0,0},
    369   {0.0,0},
    370   {GPS_WAVELENGTH_L5,"5I"},
    371   {GPS_WAVELENGTH_L5,"5Q"},
    372   {GPS_WAVELENGTH_L5,"5X"},
    373   {0.0,0},
    374   {0.0,0},
    375   {0.0,0},
    376   {0.0,0},
    377   {0.0,0},
    378   {GPS_WAVELENGTH_L1,"1D"},
    379   {GPS_WAVELENGTH_L1,"1P"},
    380   {GPS_WAVELENGTH_L1,"1X"}
    381 };
     348static struct CodeData qzss[RTCM3_MSM_NUMSIG] = {
     349        {0.0, 0},
     350        {GPS_WAVELENGTH_L1, "1C"},
     351        {0.0, 0},
     352        {0.0, 0},
     353        {0.0, 0},
     354        {GPS_WAVELENGTH_L1, "1Z"},
     355        {0.0, 0},
     356        {0.0, 0},
     357        {QZSS_WAVELENGTH_LEX, "6S"},
     358        {QZSS_WAVELENGTH_LEX, "6L"},
     359        {QZSS_WAVELENGTH_LEX, "6X"},
     360        {0.0, 0},
     361        {0.0, 0},
     362        {0.0, 0},
     363        {GPS_WAVELENGTH_L2, "2S"},
     364        {GPS_WAVELENGTH_L2, "2L"},
     365        {GPS_WAVELENGTH_L2, "2X"},
     366        {0.0, 0},
     367        {0.0, 0},
     368        {0.0, 0},
     369        {0.0, 0},
     370        {GPS_WAVELENGTH_L5, "5I"},
     371        {GPS_WAVELENGTH_L5, "5Q"},
     372        {GPS_WAVELENGTH_L5, "5X"},
     373        {0.0, 0},
     374        {0.0, 0},
     375        {0.0, 0},
     376        {0.0, 0},
     377        {0.0, 0},
     378        {GPS_WAVELENGTH_L1, "1D"},
     379        {GPS_WAVELENGTH_L1, "1P"},
     380        {GPS_WAVELENGTH_L1, "1X"}
     381    };
    382382
    383383/** MSM signal types for Beidou/BDS */
    384 static struct CodeData bds[RTCM3_MSM_NUMSIG] =
    385 {
    386   {0.0,0},
    387   {BDS_WAVELENGTH_B1,"2I"},
    388   {0.0,0},
    389   {0.0,0},
    390   {0.0,0},
    391   {0.0,0},
    392   {0.0,0},
    393   {BDS_WAVELENGTH_B3,"6I"},
    394   {0.0,0},
    395   {0.0,0},
    396   {0.0,0},
    397   {0.0,0},
    398   {0.0,0},
    399   {BDS_WAVELENGTH_B2,"7I"},
    400   {0.0,0},
    401   {0.0,0},
    402   {0.0,0},
    403   {0.0,0},
    404   {0.0,0},
    405   {0.0,0},
    406   {0.0,0},
    407   {0.0,0},
    408   {0.0,0},
    409   {0.0,0},
    410   {0.0,0},
    411   {0.0,0},
    412   {0.0,0},
    413   {0.0,0},
    414   {0.0,0},
    415   {0.0,0},
    416   {0.0,0},
    417   {0.0,0},
    418 };
     384static struct CodeData bds[RTCM3_MSM_NUMSIG] = {
     385        {0.0, 0},
     386        {BDS_WAVELENGTH_B1, "2I"},
     387        {0.0, 0},
     388        {0.0, 0},
     389        {0.0, 0},
     390        {0.0, 0},
     391        {0.0, 0},
     392        {BDS_WAVELENGTH_B3, "6I"},
     393        {0.0, 0},
     394        {0.0, 0},
     395        {0.0, 0},
     396        {0.0, 0},
     397        {0.0, 0},
     398        {BDS_WAVELENGTH_B2, "7I"},
     399        {0.0, 0},
     400        {0.0, 0},
     401        {0.0, 0},
     402        {0.0, 0},
     403        {0.0, 0},
     404        {0.0, 0},
     405        {0.0, 0},
     406        {0.0, 0},
     407        {0.0, 0},
     408        {0.0, 0},
     409        {0.0, 0},
     410        {0.0, 0},
     411        {0.0, 0},
     412        {0.0, 0},
     413        {0.0, 0},
     414        {0.0, 0},
     415        {0.0, 0},
     416        {0.0, 0},
     417    };
    419418
    420419#define UINT64(c) c ## ULL
     
    423422////////////////////////////////////////////////////////////////////////////
    424423bool RTCM3Decoder::DecodeRTCM3MSM(unsigned char* data, int size)
    425 {
     424    {
    426425  bool decoded = false;
    427426  int type, syncf, i;
     
    432431
    433432  GETBITS(type, 12)
    434   SKIPBITS(12) /* id */
     433  SKIPBITS(12)
     434  /* id */
    435435  char sys;
    436   if(type >= 1121)
     436  if (type >= 1121)
    437437    sys = 'C';
    438   else if(type >= 1111)
     438  else if (type >= 1111)
    439439    sys = 'J';
    440   else if(type >= 1101)
     440  else if (type >= 1101)
    441441    sys = 'S';
    442   else if(type >= 1091)
     442  else if (type >= 1091)
    443443    sys = 'E';
    444   else if(type >= 1081)
     444  else if (type >= 1081)
    445445    sys = 'R';
    446446  else
     
    448448
    449449  bncTime CurrentObsTime;
    450   if(sys == 'C') /* BDS */
    451   {
    452     GETBITS(i,30)
     450  if (sys == 'C') /* BDS */ {
     451    GETBITS(i, 30)
    453452    CurrentObsTime.setBDS(i);
    454453  }
    455   else if(sys == 'R') /* GLONASS */
    456   {
     454  else if (sys == 'R') /* GLONASS */ {
    457455    SKIPBITS(3)
    458     GETBITS(i,27) /* tk */
     456    GETBITS(i, 27)
     457    /* tk */
    459458    CurrentObsTime.setTk(i);
    460459  }
    461   else /* GPS style date */
    462   {
    463     GETBITS(i,30)
     460  else /* GPS style date */ {
     461    GETBITS(i, 30)
    464462    CurrentObsTime.set(i);
    465463  }
    466   if(_CurrentTime.valid() && CurrentObsTime != _CurrentTime)
    467   {
     464  if (_CurrentTime.valid() && CurrentObsTime != _CurrentTime) {
    468465    decoded = true;
    469     _obsList = _CurrentObsList;
     466    _obsList.append(_CurrentObsList);
    470467    _CurrentObsList.clear();
    471468  }
     
    479476   * the full cycles and can't be used later we skip interpretation here already.
    480477   */
    481   if(type <= 1130 && (type % 10) >= 4 && (type % 10) <= 7)
    482   {
     478  if (type <= 1130 && (type % 10) >= 4 && (type % 10) <= 7) {
    483479    int sigmask, numsat = 0, numsig = 0;
    484480    uint64_t satmask, cellmask, ui;
    485481    double rrmod[RTCM3_MSM_NUMSAT];
    486482    int rrint[RTCM3_MSM_NUMSAT], rdop[RTCM3_MSM_NUMSAT],
    487     extsat[RTCM3_MSM_NUMSAT];
     483        extsat[RTCM3_MSM_NUMSAT];
    488484    int ll[RTCM3_MSM_NUMCELLS]/*, hc[RTCM3_MSM_NUMCELLS]*/;
    489485    double cnr[RTCM3_MSM_NUMCELLS];
    490486    double cp[RTCM3_MSM_NUMCELLS], psr[RTCM3_MSM_NUMCELLS],
    491     dop[RTCM3_MSM_NUMCELLS];
    492 
    493     SKIPBITS(3+7+2+2+1+3)
     487        dop[RTCM3_MSM_NUMCELLS];
     488
     489    SKIPBITS(3 + 7 + 2 + 2 + 1 + 3)
    494490    GETBITS64(satmask, RTCM3_MSM_NUMSAT)
    495491
    496492    /* http://gurmeetsingh.wordpress.com/2008/08/05/fast-bit-counting-routines/ */
    497     for(ui = satmask; ui; ui &= (ui - 1) /* remove rightmost bit */)
     493    for (ui = satmask; ui; ui &= (ui - 1) /* remove rightmost bit */)
    498494      ++numsat;
    499495    GETBITS(sigmask, RTCM3_MSM_NUMSIG)
    500     for(i = sigmask; i; i &= (i - 1) /* remove rightmost bit */)
     496    for (i = sigmask; i; i &= (i - 1) /* remove rightmost bit */)
    501497      ++numsig;
    502     for(i = 0; i < RTCM3_MSM_NUMSAT; ++i)
     498    for (i = 0; i < RTCM3_MSM_NUMSAT; ++i)
    503499      extsat[i] = 15;
    504500
    505     i = numsat*numsig;
    506     GETBITS64(cellmask, (unsigned)i)
    507 
    508     switch(type % 10)
    509     {
    510     case 1: case 2: case 3:
    511       /* partial data, already skipped above, but implemented for future expansion ! */
    512       for(int j = numsat; j--;)
    513         GETFLOAT(rrmod[j], 10, 1.0/1024.0)
    514       break;
    515     case 4: case 6:
    516       for(int j = numsat; j--;)
    517         GETBITS(rrint[j], 8)
    518       for(int j = numsat; j--;)
    519         GETFLOAT(rrmod[j], 10, 1.0/1024.0)
    520       break;
    521     case 5: case 7:
    522       for(int j = numsat; j--;)
    523         GETBITS(rrint[j], 8)
    524       for(int j = numsat; j--;)
    525         GETBITS(extsat[j], 4)
    526       for(int j = numsat; j--;)
    527         GETFLOAT(rrmod[j], 10, 1.0/1024.0)
    528       for(int j = numsat; j--;)
    529         GETBITSSIGN(rdop[j], 14)
    530       break;
     501    i = numsat * numsig;
     502    GETBITS64(cellmask, (unsigned )i)
     503
     504    switch (type % 10) {
     505      case 1:
     506      case 2:
     507      case 3:
     508        /* partial data, already skipped above, but implemented for future expansion ! */
     509        for (int j = numsat; j--;)
     510          GETFLOAT(rrmod[j], 10, 1.0 / 1024.0)
     511        break;
     512      case 4:
     513      case 6:
     514        for (int j = numsat; j--;)
     515          GETBITS(rrint[j], 8)
     516        for (int j = numsat; j--;)
     517          GETFLOAT(rrmod[j], 10, 1.0 / 1024.0)
     518        break;
     519      case 5:
     520      case 7:
     521        for (int j = numsat; j--;)
     522          GETBITS(rrint[j], 8)
     523        for (int j = numsat; j--;)
     524          GETBITS(extsat[j], 4)
     525        for (int j = numsat; j--;)
     526          GETFLOAT(rrmod[j], 10, 1.0 / 1024.0)
     527        for (int j = numsat; j--;)
     528          GETBITSSIGN(rdop[j], 14)
     529        break;
    531530    }
    532531
    533     int numcells = numsat*numsig;
     532    int numcells = numsat * numsig;
    534533    /** Drop anything which exceeds our cell limit. Increase limit definition
    535534     * when that happens. */
    536     if(numcells <= RTCM3_MSM_NUMCELLS)
    537     {
    538       switch(type % 10)
    539       {
    540       case 1:
    541         for(int count = numcells; count--;)
    542           if(cellmask & (UINT64(1)<<count))
    543             GETFLOATSIGN(psr[count], 15, 1.0/(1<<24))
    544         break;
    545       case 2:
    546         for(int count = numcells; count--;)
    547           if(cellmask & (UINT64(1)<<count))
    548             GETFLOATSIGN(cp[count], 22, 1.0/(1<<29))
    549         for(int count = numcells; count--;)
    550           if(cellmask & (UINT64(1)<<count))
    551             GETBITS(ll[count], 4)
    552         for(int count = numcells; count--;)
    553           if(cellmask & (UINT64(1)<<count))
    554             SKIPBITS(1)/*GETBITS(hc[count], 1)*/
    555         break;
    556       case 3:
    557         for(int count = numcells; count--;)
    558           if(cellmask & (UINT64(1)<<count))
    559             GETFLOATSIGN(psr[count], 15, 1.0/(1<<24))
    560         for(int count = numcells; count--;)
    561           if(cellmask & (UINT64(1)<<count))
    562             GETFLOATSIGN(cp[count], 22, 1.0/(1<<29))
    563         for(int count = numcells; count--;)
    564           if(cellmask & (UINT64(1)<<count))
    565             GETBITS(ll[count], 4)
    566         for(int count = numcells; count--;)
    567           if(cellmask & (UINT64(1)<<count))
    568             SKIPBITS(1)/*GETBITS(hc[count], 1)*/
    569         break;
    570       case 4:
    571         for(int count = numcells; count--;)
    572           if(cellmask & (UINT64(1)<<count))
    573             GETFLOATSIGN(psr[count], 15, 1.0/(1<<24))
    574         for(int count = numcells; count--;)
    575           if(cellmask & (UINT64(1)<<count))
    576             GETFLOATSIGN(cp[count], 22, 1.0/(1<<29))
    577         for(int count = numcells; count--;)
    578           if(cellmask & (UINT64(1)<<count))
    579             GETBITS(ll[count], 4)
    580         for(int count = numcells; count--;)
    581           if(cellmask & (UINT64(1)<<count))
    582             SKIPBITS(1)/*GETBITS(hc[count], 1)*/
    583         for(int count = numcells; count--;)
    584           if(cellmask & (UINT64(1)<<count))
    585             GETBITS(cnr[count], 6)
    586         break;
    587       case 5:
    588         for(int count = numcells; count--;)
    589           if(cellmask & (UINT64(1)<<count))
    590             GETFLOATSIGN(psr[count], 15, 1.0/(1<<24))
    591         for(int count = numcells; count--;)
    592           if(cellmask & (UINT64(1)<<count))
    593             GETFLOATSIGN(cp[count], 22, 1.0/(1<<29))
    594         for(int count = numcells; count--;)
    595           if(cellmask & (UINT64(1)<<count))
    596             GETBITS(ll[count], 4)
    597         for(int count = numcells; count--;)
    598           if(cellmask & (UINT64(1)<<count))
    599             SKIPBITS(1)/*GETBITS(hc[count], 1)*/
    600         for(int count = numcells; count--;)
    601           if(cellmask & (UINT64(1)<<count))
    602             GETFLOAT(cnr[count], 6, 1.0)
    603         for(int count = numcells; count--;)
    604           if(cellmask & (UINT64(1)<<count))
    605             GETFLOATSIGN(dop[count], 15, 0.0001)
    606         break;
    607       case 6:
    608         for(int count = numcells; count--;)
    609           if(cellmask & (UINT64(1)<<count))
    610             GETFLOATSIGN(psr[count], 20, 1.0/(1<<29))
    611         for(int count = numcells; count--;)
    612           if(cellmask & (UINT64(1)<<count))
    613             GETFLOATSIGN(cp[count], 24, 1.0/(1U<<31))
    614         for(int count = numcells; count--;)
    615           if(cellmask & (UINT64(1)<<count))
    616             GETBITS(ll[count], 10)
    617         for(int count = numcells; count--;)
    618           if(cellmask & (UINT64(1)<<count))
    619             SKIPBITS(1)/*GETBITS(hc[count], 1)*/
    620         for(int count = numcells; count--;)
    621           if(cellmask & (UINT64(1)<<count))
    622             GETFLOAT(cnr[count], 10, 1.0/(1<<4))
    623         break;
    624       case 7:
    625         for(int count = numcells; count--;)
    626           if(cellmask & (UINT64(1)<<count))
    627             GETFLOATSIGN(psr[count], 20, 1.0/(1<<29))
    628         for(int count = numcells; count--;)
    629           if(cellmask & (UINT64(1)<<count))
    630             GETFLOATSIGN(cp[count], 24, 1.0/(1U<<31))
    631         for(int count = numcells; count--;)
    632           if(cellmask & (UINT64(1)<<count))
    633             GETBITS(ll[count], 10)
    634         for(int count = numcells; count--;)
    635           if(cellmask & (UINT64(1)<<count))
    636             SKIPBITS(1)/*GETBITS(hc[count], 1)*/
    637         for(int count = numcells; count--;)
    638           if(cellmask & (UINT64(1)<<count))
    639             GETFLOAT(cnr[count], 10, 1.0/(1<<4))
    640         for(int count = numcells; count--;)
    641           if(cellmask & (UINT64(1)<<count))
    642             GETFLOATSIGN(dop[count], 15, 0.0001)
    643         break;
     535    if (numcells <= RTCM3_MSM_NUMCELLS) {
     536      switch (type % 10) {
     537        case 1:
     538          for (int count = numcells; count--;)
     539            if (cellmask & (UINT64(1) << count))
     540              GETFLOATSIGN(psr[count], 15, 1.0 / (1 << 24))
     541          break;
     542        case 2:
     543          for (int count = numcells; count--;)
     544            if (cellmask & (UINT64(1) << count))
     545              GETFLOATSIGN(cp[count], 22, 1.0 / (1 << 29))
     546          for (int count = numcells; count--;)
     547            if (cellmask & (UINT64(1) << count))
     548              GETBITS(ll[count], 4)
     549          for (int count = numcells; count--;)
     550            if (cellmask & (UINT64(1) << count))
     551              SKIPBITS(1)/*GETBITS(hc[count], 1)*/
     552          break;
     553        case 3:
     554          for (int count = numcells; count--;)
     555            if (cellmask & (UINT64(1) << count))
     556              GETFLOATSIGN(psr[count], 15, 1.0 / (1 << 24))
     557          for (int count = numcells; count--;)
     558            if (cellmask & (UINT64(1) << count))
     559              GETFLOATSIGN(cp[count], 22, 1.0 / (1 << 29))
     560          for (int count = numcells; count--;)
     561            if (cellmask & (UINT64(1) << count))
     562              GETBITS(ll[count], 4)
     563          for (int count = numcells; count--;)
     564            if (cellmask & (UINT64(1) << count))
     565              SKIPBITS(1)/*GETBITS(hc[count], 1)*/
     566          break;
     567        case 4:
     568          for (int count = numcells; count--;)
     569            if (cellmask & (UINT64(1) << count))
     570              GETFLOATSIGN(psr[count], 15, 1.0 / (1 << 24))
     571          for (int count = numcells; count--;)
     572            if (cellmask & (UINT64(1) << count))
     573              GETFLOATSIGN(cp[count], 22, 1.0 / (1 << 29))
     574          for (int count = numcells; count--;)
     575            if (cellmask & (UINT64(1) << count))
     576              GETBITS(ll[count], 4)
     577          for (int count = numcells; count--;)
     578            if (cellmask & (UINT64(1) << count))
     579              SKIPBITS(1)/*GETBITS(hc[count], 1)*/
     580          for (int count = numcells; count--;)
     581            if (cellmask & (UINT64(1) << count))
     582              GETBITS(cnr[count], 6)
     583          break;
     584        case 5:
     585          for (int count = numcells; count--;)
     586            if (cellmask & (UINT64(1) << count))
     587              GETFLOATSIGN(psr[count], 15, 1.0 / (1 << 24))
     588          for (int count = numcells; count--;)
     589            if (cellmask & (UINT64(1) << count))
     590              GETFLOATSIGN(cp[count], 22, 1.0 / (1 << 29))
     591          for (int count = numcells; count--;)
     592            if (cellmask & (UINT64(1) << count))
     593              GETBITS(ll[count], 4)
     594          for (int count = numcells; count--;)
     595            if (cellmask & (UINT64(1) << count))
     596              SKIPBITS(1)/*GETBITS(hc[count], 1)*/
     597          for (int count = numcells; count--;)
     598            if (cellmask & (UINT64(1) << count))
     599              GETFLOAT(cnr[count], 6, 1.0)
     600          for (int count = numcells; count--;)
     601            if (cellmask & (UINT64(1) << count))
     602              GETFLOATSIGN(dop[count], 15, 0.0001)
     603          break;
     604        case 6:
     605          for (int count = numcells; count--;)
     606            if (cellmask & (UINT64(1) << count))
     607              GETFLOATSIGN(psr[count], 20, 1.0 / (1 << 29))
     608          for (int count = numcells; count--;)
     609            if (cellmask & (UINT64(1) << count))
     610              GETFLOATSIGN(cp[count], 24, 1.0 / (1U << 31))
     611          for (int count = numcells; count--;)
     612            if (cellmask & (UINT64(1) << count))
     613              GETBITS(ll[count], 10)
     614          for (int count = numcells; count--;)
     615            if (cellmask & (UINT64(1) << count))
     616              SKIPBITS(1)/*GETBITS(hc[count], 1)*/
     617          for (int count = numcells; count--;)
     618            if (cellmask & (UINT64(1) << count))
     619              GETFLOAT(cnr[count], 10, 1.0 / (1 << 4))
     620          break;
     621        case 7:
     622          for (int count = numcells; count--;)
     623            if (cellmask & (UINT64(1) << count))
     624              GETFLOATSIGN(psr[count], 20, 1.0 / (1 << 29))
     625          for (int count = numcells; count--;)
     626            if (cellmask & (UINT64(1) << count))
     627              GETFLOATSIGN(cp[count], 24, 1.0 / (1U << 31))
     628          for (int count = numcells; count--;)
     629            if (cellmask & (UINT64(1) << count))
     630              GETBITS(ll[count], 10)
     631          for (int count = numcells; count--;)
     632            if (cellmask & (UINT64(1) << count))
     633              SKIPBITS(1)/*GETBITS(hc[count], 1)*/
     634          for (int count = numcells; count--;)
     635            if (cellmask & (UINT64(1) << count))
     636              GETFLOAT(cnr[count], 10, 1.0 / (1 << 4))
     637          for (int count = numcells; count--;)
     638            if (cellmask & (UINT64(1) << count))
     639              GETFLOATSIGN(dop[count], 15, 0.0001)
     640          break;
    644641      }
    645642      i = RTCM3_MSM_NUMSAT;
    646643      int j = -1;
    647644      t_satObs CurrentObs;
    648       for(int count = numcells; count--;)
    649       {
    650         while(j >= 0 && !(sigmask&(1<<--j)))
     645      for (int count = numcells; count--;) {
     646        while (j >= 0 && !(sigmask & (1 << --j)))
    651647          ;
    652         if(j < 0)
    653         {
    654           while(!(satmask&(UINT64(1)<<(--i)))) /* next satellite */
     648        if (j < 0) {
     649          while (!(satmask & (UINT64(1) << (--i))))
     650            /* next satellite */
    655651            ;
    656           if(CurrentObs._obs.size() > 0)
     652          if (CurrentObs._obs.size() > 0)
    657653            _CurrentObsList.push_back(CurrentObs);
    658654          CurrentObs.clear();
    659655          CurrentObs._time = CurrentObsTime;
    660           if(sys == 'S')
    661             CurrentObs._prn.set(sys, 20-1+RTCM3_MSM_NUMSAT-i);
     656          if (sys == 'S')
     657            CurrentObs._prn.set(sys, 20 - 1 + RTCM3_MSM_NUMSAT - i);
    662658          else
    663             CurrentObs._prn.set(sys, RTCM3_MSM_NUMSAT-i);
     659            CurrentObs._prn.set(sys, RTCM3_MSM_NUMSAT - i);
    664660          j = RTCM3_MSM_NUMSIG;
    665           while(!(sigmask&(1<<--j)))
     661          while (!(sigmask & (1 << --j)))
    666662            ;
    667663          --numsat;
    668664        }
    669         if(cellmask & (UINT64(1)<<count))
    670         {
    671           struct CodeData cd = {0.0,0};
    672           switch(sys)
    673           {
    674           case 'J':
    675             cd = qzss[RTCM3_MSM_NUMSIG-j-1];
    676             break;
    677           case 'C':
    678             cd = bds[RTCM3_MSM_NUMSIG-j-1];
    679             break;
    680           case 'G': case 'S':
    681             cd = gps[RTCM3_MSM_NUMSIG-j-1];
    682             break;
    683           case 'R':
    684             cd = glo[RTCM3_MSM_NUMSIG-j-1];
    685             {
    686               int k = GLOFreq[RTCM3_MSM_NUMSAT-i-1];
    687               if(extsat[numsat] < 14)
     665        if (cellmask & (UINT64(1) << count)) {
     666          struct CodeData cd = {0.0, 0};
     667          switch (sys) {
     668            case 'J':
     669              cd = qzss[RTCM3_MSM_NUMSIG - j - 1];
     670              break;
     671            case 'C':
     672              cd = bds[RTCM3_MSM_NUMSIG - j - 1];
     673              break;
     674            case 'G':
     675            case 'S':
     676              cd = gps[RTCM3_MSM_NUMSIG - j - 1];
     677              break;
     678            case 'R':
     679              cd = glo[RTCM3_MSM_NUMSIG - j - 1];
    688680              {
    689                 k = GLOFreq[RTCM3_MSM_NUMSAT-i-1] = 100+extsat[numsat]-7;
     681                int k = GLOFreq[RTCM3_MSM_NUMSAT - i - 1];
     682                if (extsat[numsat] < 14) {
     683                  k = GLOFreq[RTCM3_MSM_NUMSAT - i - 1] = 100 + extsat[numsat]
     684                      - 7;
     685                }
     686                if (k)
     687                  cd.wl = (
     688                      cd.wl == 0.0 ?
     689                          GLO_WAVELENGTH_L1(k - 100) :
     690                          GLO_WAVELENGTH_L2(k - 100));
     691                else
     692                  cd.code = 0;
    690693              }
    691               if(k)
    692                 cd.wl = (cd.wl == 0.0 ? GLO_WAVELENGTH_L1(k-100) : GLO_WAVELENGTH_L2(k-100));
    693               else
    694                 cd.code = 0;
    695             }
    696             break;
    697           case 'E':
    698             cd = gal[RTCM3_MSM_NUMSIG-j-1];
    699             break;
     694              break;
     695            case 'E':
     696              cd = gal[RTCM3_MSM_NUMSIG - j - 1];
     697              break;
    700698          }
    701           if(cd.code)
    702           {
     699          if (cd.code) {
    703700            t_frqObs *frqObs = new t_frqObs;
    704701            frqObs->_rnxType2ch.assign(cd.code);
    705702
    706             switch(type % 10)
    707             {
    708             case 1:
    709               if(psr[count] > -1.0/(1<<10))
    710               {
    711                 frqObs->_code = psr[count]*LIGHTSPEED/1000.0
    712                 +(rrmod[numsat])*LIGHTSPEED/1000.0;
    713                 frqObs->_codeValid = true;
    714               }
    715               break;
    716             case 2:
    717               if(cp[count] > -1.0/(1<<8))
    718               {
    719                 frqObs->_phase = cp[count]*LIGHTSPEED/1000.0/cd.wl
    720                 +(rrmod[numsat])*LIGHTSPEED/1000.0/cd.wl;
    721                 frqObs->_phaseValid = true;
    722                 frqObs->_slipCounter = ll[count];
    723               }
    724               break;
    725             case 3:
    726               if(psr[count] > -1.0/(1<<10))
    727               {
    728                 frqObs->_code = psr[count]*LIGHTSPEED/1000.0
    729                 +(rrmod[numsat])*LIGHTSPEED/1000.0;
    730                 frqObs->_codeValid = true;
    731               }
    732 
    733               if(cp[count] > -1.0/(1<<8))
    734               {
    735                 frqObs->_phase = cp[count]*LIGHTSPEED/1000.0/cd.wl
    736                 +rrmod[numsat]*LIGHTSPEED/1000.0/cd.wl;
    737                 frqObs->_phaseValid = true;
    738                 frqObs->_slipCounter = ll[count];
    739               }
    740               break;
    741             case 4:
    742               if(psr[count] > -1.0/(1<<10))
    743               {
    744                 frqObs->_code = psr[count]*LIGHTSPEED/1000.0
    745                 +(rrmod[numsat]+rrint[numsat])*LIGHTSPEED/1000.0;
    746                 frqObs->_codeValid = true;
    747               }
    748 
    749               if(cp[count] > -1.0/(1<<8))
    750               {
    751                 frqObs->_phase = cp[count]*LIGHTSPEED/1000.0/cd.wl
    752                 +(rrmod[numsat]+rrint[numsat])*LIGHTSPEED/1000.0/cd.wl;
    753                 frqObs->_phaseValid = true;
    754                 frqObs->_slipCounter = ll[count];
    755               }
    756 
    757               frqObs->_snr = cnr[count];
    758               frqObs->_snrValid = true;
    759               break;
    760             case 5:
    761               if(psr[count] > -1.0/(1<<10))
    762               {
    763                 frqObs->_code = psr[count]*LIGHTSPEED/1000.0
    764                 +(rrmod[numsat]+rrint[numsat])*LIGHTSPEED/1000.0;
    765                 frqObs->_codeValid = true;
    766               }
    767 
    768               if(cp[count] > -1.0/(1<<8))
    769               {
    770                 frqObs->_phase = cp[count]*LIGHTSPEED/1000.0/cd.wl
    771                 +(rrmod[numsat]+rrint[numsat])*LIGHTSPEED/1000.0/cd.wl;
    772                 frqObs->_phaseValid = true;
    773                 frqObs->_slipCounter = ll[count];
    774               }
    775 
    776               frqObs->_snr = cnr[count];
    777               frqObs->_snrValid = true;
    778 
    779               if(dop[count] > -1.6384)
    780               {
    781                 frqObs->_doppler = -(dop[count]+rdop[numsat])/cd.wl;
    782                 frqObs->_dopplerValid = true;
    783               }
    784               break;
    785             case 6:
    786               if(psr[count] > -1.0/(1<<10))
    787               {
    788                 frqObs->_code = psr[count]*LIGHTSPEED/1000.0
    789                 +(rrmod[numsat]+rrint[numsat])*LIGHTSPEED/1000.0;
    790                 frqObs->_codeValid = true;
    791               }
    792 
    793               if(cp[count] > -1.0/(1<<8))
    794               {
    795                 frqObs->_phase = cp[count]*LIGHTSPEED/1000.0/cd.wl
    796                 +(rrmod[numsat]+rrint[numsat])*LIGHTSPEED/1000.0/cd.wl;
    797                 frqObs->_phaseValid = true;
    798                 frqObs->_slipCounter = ll[count];
    799               }
    800 
    801               frqObs->_snr = cnr[count];
    802               frqObs->_snrValid = true;
    803               break;
    804             case 7:
    805               if(psr[count] > -1.0/(1<<10))
    806               {
    807                 frqObs->_code = psr[count]*LIGHTSPEED/1000.0
    808                 +(rrmod[numsat]+rrint[numsat])*LIGHTSPEED/1000.0;
    809                 frqObs->_codeValid = true;
    810               }
    811 
    812               if(cp[count] > -1.0/(1<<8))
    813               {
    814                 frqObs->_phase = cp[count]*LIGHTSPEED/1000.0/cd.wl
    815                 +(rrmod[numsat]+rrint[numsat])*LIGHTSPEED/1000.0/cd.wl;
    816                 frqObs->_phaseValid = true;
    817                 frqObs->_slipCounter = ll[count];
    818               }
    819 
    820               frqObs->_snr = cnr[count];
    821               frqObs->_snrValid = true;
    822 
    823               if(dop[count] > -1.6384)
    824               {
    825                 frqObs->_doppler = -(dop[count]+rdop[numsat])/cd.wl;
    826                 frqObs->_dopplerValid = true;
    827               }
    828               break;
     703            switch (type % 10) {
     704              case 1:
     705                if (psr[count] > -1.0 / (1 << 10)) {
     706                  frqObs->_code = psr[count] * LIGHTSPEED / 1000.0
     707                      + (rrmod[numsat]) * LIGHTSPEED / 1000.0;
     708                  frqObs->_codeValid = true;
     709                }
     710                break;
     711              case 2:
     712                if (cp[count] > -1.0 / (1 << 8)) {
     713                  frqObs->_phase = cp[count] * LIGHTSPEED / 1000.0 / cd.wl
     714                      + (rrmod[numsat]) * LIGHTSPEED / 1000.0 / cd.wl;
     715                  frqObs->_phaseValid = true;
     716                  frqObs->_slipCounter = ll[count];
     717                }
     718                break;
     719              case 3:
     720                if (psr[count] > -1.0 / (1 << 10)) {
     721                  frqObs->_code = psr[count] * LIGHTSPEED / 1000.0
     722                      + (rrmod[numsat]) * LIGHTSPEED / 1000.0;
     723                  frqObs->_codeValid = true;
     724                }
     725
     726                if (cp[count] > -1.0 / (1 << 8)) {
     727                  frqObs->_phase = cp[count] * LIGHTSPEED / 1000.0 / cd.wl
     728                      + rrmod[numsat] * LIGHTSPEED / 1000.0 / cd.wl;
     729                  frqObs->_phaseValid = true;
     730                  frqObs->_slipCounter = ll[count];
     731                }
     732                break;
     733              case 4:
     734                if (psr[count] > -1.0 / (1 << 10)) {
     735                  frqObs->_code = psr[count] * LIGHTSPEED / 1000.0
     736                      + (rrmod[numsat] + rrint[numsat]) * LIGHTSPEED / 1000.0;
     737                  frqObs->_codeValid = true;
     738                }
     739
     740                if (cp[count] > -1.0 / (1 << 8)) {
     741                  frqObs->_phase = cp[count] * LIGHTSPEED / 1000.0 / cd.wl
     742                      + (rrmod[numsat] + rrint[numsat]) * LIGHTSPEED / 1000.0
     743                          / cd.wl;
     744                  frqObs->_phaseValid = true;
     745                  frqObs->_slipCounter = ll[count];
     746                }
     747
     748                frqObs->_snr = cnr[count];
     749                frqObs->_snrValid = true;
     750                break;
     751              case 5:
     752                if (psr[count] > -1.0 / (1 << 10)) {
     753                  frqObs->_code = psr[count] * LIGHTSPEED / 1000.0
     754                      + (rrmod[numsat] + rrint[numsat]) * LIGHTSPEED / 1000.0;
     755                  frqObs->_codeValid = true;
     756                }
     757
     758                if (cp[count] > -1.0 / (1 << 8)) {
     759                  frqObs->_phase = cp[count] * LIGHTSPEED / 1000.0 / cd.wl
     760                      + (rrmod[numsat] + rrint[numsat]) * LIGHTSPEED / 1000.0
     761                          / cd.wl;
     762                  frqObs->_phaseValid = true;
     763                  frqObs->_slipCounter = ll[count];
     764                }
     765
     766                frqObs->_snr = cnr[count];
     767                frqObs->_snrValid = true;
     768
     769                if (dop[count] > -1.6384) {
     770                  frqObs->_doppler = -(dop[count] + rdop[numsat]) / cd.wl;
     771                  frqObs->_dopplerValid = true;
     772                }
     773                break;
     774              case 6:
     775                if (psr[count] > -1.0 / (1 << 10)) {
     776                  frqObs->_code = psr[count] * LIGHTSPEED / 1000.0
     777                      + (rrmod[numsat] + rrint[numsat]) * LIGHTSPEED / 1000.0;
     778                  frqObs->_codeValid = true;
     779                }
     780
     781                if (cp[count] > -1.0 / (1 << 8)) {
     782                  frqObs->_phase = cp[count] * LIGHTSPEED / 1000.0 / cd.wl
     783                      + (rrmod[numsat] + rrint[numsat]) * LIGHTSPEED / 1000.0
     784                          / cd.wl;
     785                  frqObs->_phaseValid = true;
     786                  frqObs->_slipCounter = ll[count];
     787                }
     788
     789                frqObs->_snr = cnr[count];
     790                frqObs->_snrValid = true;
     791                break;
     792              case 7:
     793                if (psr[count] > -1.0 / (1 << 10)) {
     794                  frqObs->_code = psr[count] * LIGHTSPEED / 1000.0
     795                      + (rrmod[numsat] + rrint[numsat]) * LIGHTSPEED / 1000.0;
     796                  frqObs->_codeValid = true;
     797                }
     798
     799                if (cp[count] > -1.0 / (1 << 8)) {
     800                  frqObs->_phase = cp[count] * LIGHTSPEED / 1000.0 / cd.wl
     801                      + (rrmod[numsat] + rrint[numsat]) * LIGHTSPEED / 1000.0
     802                          / cd.wl;
     803                  frqObs->_phaseValid = true;
     804                  frqObs->_slipCounter = ll[count];
     805                }
     806
     807                frqObs->_snr = cnr[count];
     808                frqObs->_snrValid = true;
     809
     810                if (dop[count] > -1.6384) {
     811                  frqObs->_doppler = -(dop[count] + rdop[numsat]) / cd.wl;
     812                  frqObs->_dopplerValid = true;
     813                }
     814                break;
    829815            }
    830816            CurrentObs._obs.push_back(frqObs);
     
    832818        }
    833819      }
    834       if(CurrentObs._obs.size() > 0)
     820      if (CurrentObs._obs.size() > 0)
    835821        _CurrentObsList.push_back(CurrentObs);
    836822    }
    837823  }
    838   else if((type % 10) < 3)
    839   {
     824  else if ((type % 10) < 3) {
    840825    emit(newMessage(QString("%1: Block %2 contain partial data! Ignored!")
    841     .arg(_staID).arg(type).toAscii(), true));
    842   }
    843   if(!syncf)
    844   {
     826        .arg(_staID).arg(type).toAscii(), true));
     827  }
     828  if (!syncf) {
    845829    decoded = true;
    846830    _obsList = _CurrentObsList;
     
    853837//
    854838////////////////////////////////////////////////////////////////////////////
    855 bool RTCM3Decoder::DecodeRTCM3GLONASS(unsigned char* data, int size)
    856 {
     839bool RTCM3Decoder::DecodeRTCM3GLONASS(unsigned char* data, int size) {
    857840  bool decoded = false;
    858841  bncTime CurrentObsTime;
     
    864847
    865848  GETBITS(type, 12)
    866   SKIPBITS(12) /* id */
    867   GETBITS(i,27) /* tk */
     849  SKIPBITS(12)
     850  /* id */
     851  GETBITS(i, 27)
     852  /* tk */
    868853
    869854  CurrentObsTime.setTk(i);
    870   if(_CurrentTime.valid() && CurrentObsTime != _CurrentTime)
    871   {
     855  if (_CurrentTime.valid() && CurrentObsTime != _CurrentTime) {
    872856    decoded = true;
    873857    _obsList.append(_CurrentObsList);
     
    876860  _CurrentTime = CurrentObsTime;
    877861
    878   GETBITS(syncf,1) /* sync */
    879   GETBITS(numsats,5)
    880   SKIPBITS(4) /* smind, smint */
    881 
    882   while(numsats--)
    883   {
    884     int sv, code, l1range, amb=0, freq;
     862  GETBITS(syncf, 1)
     863  /* sync */
     864  GETBITS(numsats, 5)
     865  SKIPBITS(4)
     866  /* smind, smint */
     867
     868  while (numsats--) {
     869    int sv, code, l1range, amb = 0, freq;
    885870    t_satObs CurrentObs;
    886871    CurrentObs._time = CurrentObsTime;
     
    890875    GETBITS(code, 1)
    891876    GETBITS(freq, 5)
    892     GLOFreq[sv-1] = 100+freq-7; /* store frequency for other users (MSM) */
     877    GLOFreq[sv - 1] = 100 + freq - 7; /* store frequency for other users (MSM) */
    893878
    894879    t_frqObs *frqObs = new t_frqObs;
    895880    /* L1 */
    896     (code) ? frqObs->_rnxType2ch.assign("1P") : frqObs->_rnxType2ch.assign("1C");
     881    (code) ?
     882        frqObs->_rnxType2ch.assign("1P") : frqObs->_rnxType2ch.assign("1C");
    897883    GETBITS(l1range, 25);
    898884    GETBITSSIGN(i, 20);
    899     if((i&((1<<20)-1)) != 0x80000)
    900     {
    901       frqObs->_code = l1range*0.02;
    902       frqObs->_phase = (l1range*0.02+i*0.0005)/GLO_WAVELENGTH_L1(freq-7);
     885    if ((i & ((1 << 20) - 1)) != 0x80000) {
     886      frqObs->_code = l1range * 0.02;
     887      frqObs->_phase = (l1range * 0.02 + i * 0.0005)
     888          / GLO_WAVELENGTH_L1(freq - 7);
    903889      frqObs->_codeValid = frqObs->_phaseValid = true;
    904890    }
    905891    GETBITS(i, 7);
    906892    frqObs->_slipCounter = i;
    907     if(type == 1010 || type == 1012)
    908     {
    909       GETBITS(amb,7);
    910       if(amb)
    911       {
    912         frqObs->_code += amb*599584.916;
    913         frqObs->_phase += (amb*599584.916)/GLO_WAVELENGTH_L1(freq-7);
     893    if (type == 1010 || type == 1012) {
     894      GETBITS(amb, 7);
     895      if (amb) {
     896        frqObs->_code += amb * 599584.916;
     897        frqObs->_phase += (amb * 599584.916) / GLO_WAVELENGTH_L1(freq - 7);
    914898      }
    915899      GETBITS(i, 8);
    916       if(i)
    917       {
    918         frqObs->_snr = i*0.25;
     900      if (i) {
     901        frqObs->_snr = i * 0.25;
    919902        frqObs->_snrValid = true;
    920903      }
    921904    }
    922905    CurrentObs._obs.push_back(frqObs);
    923     if(type == 1011 || type == 1012)
    924     {
     906    if (type == 1011 || type == 1012) {
    925907      frqObs = new t_frqObs;
    926908      /* L2 */
    927       GETBITS(code,2);
    928       switch(code)
    929       {
    930       case 3: frqObs->_rnxType2ch.assign("2P"); break;
    931       case 2: frqObs->_rnxType2ch.assign("2P"); break;
    932       case 1: frqObs->_rnxType2ch.assign("2P"); break;
    933       case 0: frqObs->_rnxType2ch.assign("2C"); break;
    934       }
    935       GETBITSSIGN(i,14);
    936       if((i&((1<<14)-1)) != 0x2000)
    937       {
    938         frqObs->_code = l1range*0.02+i*0.02+amb*599584.916;
     909      GETBITS(code, 2);
     910      switch (code) {
     911        case 3:
     912          frqObs->_rnxType2ch.assign("2P");
     913          break;
     914        case 2:
     915          frqObs->_rnxType2ch.assign("2P");
     916          break;
     917        case 1:
     918          frqObs->_rnxType2ch.assign("2P");
     919          break;
     920        case 0:
     921          frqObs->_rnxType2ch.assign("2C");
     922          break;
     923      }
     924      GETBITSSIGN(i, 14);
     925      if ((i & ((1 << 14) - 1)) != 0x2000) {
     926        frqObs->_code = l1range * 0.02 + i * 0.02 + amb * 599584.916;
    939927        frqObs->_codeValid = true;
    940928      }
    941       GETBITSSIGN(i,20);
    942       if((i&((1<<20)-1)) != 0x80000)
    943       {
    944         frqObs->_phase = (l1range*0.02+i*0.0005+amb*599584.916)/GLO_WAVELENGTH_L2(freq-7);
     929      GETBITSSIGN(i, 20);
     930      if ((i & ((1 << 20) - 1)) != 0x80000) {
     931        frqObs->_phase = (l1range * 0.02 + i * 0.0005 + amb * 599584.916)
     932            / GLO_WAVELENGTH_L2(freq - 7);
    945933        frqObs->_phaseValid = true;
    946934      }
    947       GETBITS(i,7);
     935      GETBITS(i, 7);
    948936      frqObs->_slipCounter = i;
    949       if(type == 1012)
    950       {
     937      if (type == 1012) {
    951938        GETBITS(i, 8);
    952         if(i)
    953         {
    954           frqObs->_snr = i*0.25;
     939        if (i) {
     940          frqObs->_snr = i * 0.25;
    955941          frqObs->_snrValid = true;
    956942        }
     
    960946    _CurrentObsList.push_back(CurrentObs);
    961947  }
    962   if(!syncf)
    963   {
     948  if (!syncf) {
    964949    decoded = true;
    965950    _obsList.append(_CurrentObsList);
     
    972957//
    973958////////////////////////////////////////////////////////////////////////////
    974 bool RTCM3Decoder::DecodeGPSEphemeris(unsigned char* data, int size)
    975 {
     959bool RTCM3Decoder::DecodeGPSEphemeris(unsigned char* data, int size) {
    976960  bool decoded = false;
    977961
    978   if(size == 67)
    979   {
     962  if (size == 67) {
    980963    t_ephGPS eph;
    981964    int i, week;
     
    999982    GETBITS(i, 16)
    1000983    i <<= 4;
    1001     eph._TOC.set(i*1000);
    1002     GETFLOATSIGN(eph._clock_driftrate, 8, 1.0/(double)(1<<30)/(double)(1<<25))
    1003     GETFLOATSIGN(eph._clock_drift, 16, 1.0/(double)(1<<30)/(double)(1<<13))
    1004     GETFLOATSIGN(eph._clock_bias, 22, 1.0/(double)(1<<30)/(double)(1<<1))
     984    eph._TOC.set(i * 1000);
     985    GETFLOATSIGN(eph._clock_driftrate, 8,
     986        1.0 / (double )(1 << 30) / (double )(1 << 25))
     987    GETFLOATSIGN(eph._clock_drift, 16,
     988        1.0 / (double )(1 << 30) / (double )(1 << 13))
     989    GETFLOATSIGN(eph._clock_bias, 22,
     990        1.0 / (double )(1 << 30) / (double )(1 << 1))
    1005991    GETBITS(eph._IODC, 10)
    1006     GETFLOATSIGN(eph._Crs, 16, 1.0/(double)(1<<5))
     992    GETFLOATSIGN(eph._Crs, 16, 1.0 / (double )(1 << 5))
    1007993    GETFLOATSIGN(eph._Delta_n, 16, R2R_PI/(double)(1<<30)/(double)(1<<13))
    1008994    GETFLOATSIGN(eph._M0, 32, R2R_PI/(double)(1<<30)/(double)(1<<1))
    1009     GETFLOATSIGN(eph._Cuc, 16, 1.0/(double)(1<<29))
    1010     GETFLOAT(eph._e, 32, 1.0/(double)(1<<30)/(double)(1<<3))
    1011     GETFLOATSIGN(eph._Cus, 16, 1.0/(double)(1<<29))
    1012     GETFLOAT(eph._sqrt_A, 32, 1.0/(double)(1<<19))
     995    GETFLOATSIGN(eph._Cuc, 16, 1.0 / (double )(1 << 29))
     996    GETFLOAT(eph._e, 32, 1.0 / (double )(1 << 30) / (double )(1 << 3))
     997    GETFLOATSIGN(eph._Cus, 16, 1.0 / (double )(1 << 29))
     998    GETFLOAT(eph._sqrt_A, 32, 1.0 / (double )(1 << 19))
    1013999    GETBITS(i, 16)
    10141000    i <<= 4;
    10151001    eph._TOEsec = i;
    10161002    bncTime t;
    1017     t.set(i*1000);
     1003    t.set(i * 1000);
    10181004    eph._TOEweek = t.gpsw();
    10191005    /* week from HOW, differs from TOC, TOE week, we use adapted value instead */
    1020     if(eph._TOEweek > week + 1 || eph._TOEweek < week-1) /* invalid week */
     1006    if (eph._TOEweek > week + 1 || eph._TOEweek < week - 1) /* invalid week */
    10211007      return false;
    1022     GETFLOATSIGN(eph._Cic, 16, 1.0/(double)(1<<29))
     1008    GETFLOATSIGN(eph._Cic, 16, 1.0 / (double )(1 << 29))
    10231009    GETFLOATSIGN(eph._OMEGA0, 32, R2R_PI/(double)(1<<30)/(double)(1<<1))
    1024     GETFLOATSIGN(eph._Cis, 16, 1.0/(double)(1<<29))
     1010    GETFLOATSIGN(eph._Cis, 16, 1.0 / (double )(1 << 29))
    10251011    GETFLOATSIGN(eph._i0, 32, R2R_PI/(double)(1<<30)/(double)(1<<1))
    1026     GETFLOATSIGN(eph._Crc, 16, 1.0/(double)(1<<5))
     1012    GETFLOATSIGN(eph._Crc, 16, 1.0 / (double )(1 << 5))
    10271013    GETFLOATSIGN(eph._omega, 32, R2R_PI/(double)(1<<30)/(double)(1<<1))
    10281014    GETFLOATSIGN(eph._OMEGADOT, 24, R2R_PI/(double)(1<<30)/(double)(1<<13))
    1029     GETFLOATSIGN(eph._TGD, 8, 1.0/(double)(1<<30)/(double)(1<<1))
     1015    GETFLOATSIGN(eph._TGD, 8, 1.0 / (double )(1 << 30) / (double )(1 << 1))
    10301016    GETBITS(eph._health, 6)
    10311017    GETBITS(eph._L2PFlag, 1)
     
    10411027//
    10421028////////////////////////////////////////////////////////////////////////////
    1043 bool RTCM3Decoder::DecodeGLONASSEphemeris(unsigned char* data, int size)
    1044 {
     1029bool RTCM3Decoder::DecodeGLONASSEphemeris(unsigned char* data, int size) {
    10451030  bool decoded = false;
    10461031
    1047   if(size == 51)
    1048   {
     1032  if (size == 51) {
    10491033    t_ephGlo eph;
    10501034    int sv, i, tk;
     
    10611045
    10621046    GETBITS(i, 5)
    1063     eph._frequency_number = i-7;
    1064     GLOFreq[sv-1] = 100+i-7; /* store frequency for other users (MSM) */
    1065     _gloFrq = QString("%1 %2").arg(eph._prn.toString().c_str()).arg(eph._frequency_number,2,'f',0);
    1066     SKIPBITS(4) /* almanac healthy, almanac health ok, P1 */
     1047    eph._frequency_number = i - 7;
     1048    GLOFreq[sv - 1] = 100 + i - 7; /* store frequency for other users (MSM) */
     1049    _gloFrq = QString("%1 %2").arg(eph._prn.toString().c_str()).arg(
     1050        eph._frequency_number, 2, 'f', 0);
     1051    SKIPBITS(4)
     1052    /* almanac healthy, almanac health ok, P1 */
    10671053    GETBITS(i, 5)
    1068     tk = i*60*60;
     1054    tk = i * 60 * 60;
    10691055    GETBITS(i, 6)
    1070     tk += i*60;
     1056    tk += i * 60;
    10711057    GETBITS(i, 1)
    1072     tk += i*30;
    1073     eph._tki = tk < 3*60*60 ? tk-3*60*60+86400 : tk-3*60*60;
     1058    tk += i * 30;
     1059    eph._tki = tk < 3 * 60 * 60 ? tk - 3 * 60 * 60 + 86400 : tk - 3 * 60 * 60;
    10741060    GETBITS(eph._health, 1)
    1075     SKIPBITS(1) /* P2 */
     1061    SKIPBITS(1)
     1062    /* P2 */
    10761063    GETBITS(i, 7)
    1077     eph._TOC.setTk(i*15*60*1000); /* tb */
    1078 
    1079     GETFLOATSIGNM(eph._x_velocity, 24, 1.0/(double)(1<<20))
    1080     GETFLOATSIGNM(eph._x_pos, 27, 1.0/(double)(1<<11))
    1081     GETFLOATSIGNM(eph._x_acceleration, 5, 1.0/(double)(1<<30))
    1082     GETFLOATSIGNM(eph._y_velocity, 24, 1.0/(double)(1<<20))
    1083     GETFLOATSIGNM(eph._y_pos, 27, 1.0/(double)(1<<11))
    1084     GETFLOATSIGNM(eph._y_acceleration, 5, 1.0/(double)(1<<30))
    1085     GETFLOATSIGNM(eph._z_velocity, 24, 1.0/(double)(1<<20))
    1086     GETFLOATSIGNM(eph._z_pos, 27, 1.0/(double)(1<<11))
    1087     GETFLOATSIGNM(eph._z_acceleration, 5, 1.0/(double)(1<<30))
    1088     SKIPBITS(1) /* P3 */
    1089     GETFLOATSIGNM(eph._gamma, 11, 1.0/(double)(1<<30)/(double)(1<<10))
    1090     SKIPBITS(3) /* GLONASS-M P, GLONASS-M ln (third string) */
    1091     GETFLOATSIGNM(eph._tau, 22, 1.0/(double)(1<<30)) /* GLONASS tau n(tb) */
    1092     SKIPBITS(5) /* GLONASS-M delta tau n(tb) */
     1064    eph._TOC.setTk(i * 15 * 60 * 1000); /* tb */
     1065
     1066    GETFLOATSIGNM(eph._x_velocity, 24, 1.0 / (double )(1 << 20))
     1067    GETFLOATSIGNM(eph._x_pos, 27, 1.0 / (double )(1 << 11))
     1068    GETFLOATSIGNM(eph._x_acceleration, 5, 1.0 / (double )(1 << 30))
     1069    GETFLOATSIGNM(eph._y_velocity, 24, 1.0 / (double )(1 << 20))
     1070    GETFLOATSIGNM(eph._y_pos, 27, 1.0 / (double )(1 << 11))
     1071    GETFLOATSIGNM(eph._y_acceleration, 5, 1.0 / (double )(1 << 30))
     1072    GETFLOATSIGNM(eph._z_velocity, 24, 1.0 / (double )(1 << 20))
     1073    GETFLOATSIGNM(eph._z_pos, 27, 1.0 / (double )(1 << 11))
     1074    GETFLOATSIGNM(eph._z_acceleration, 5, 1.0 / (double )(1 << 30))
     1075    SKIPBITS(1)
     1076    /* P3 */
     1077    GETFLOATSIGNM(eph._gamma, 11, 1.0 / (double )(1 << 30) / (double )(1 << 10))
     1078    SKIPBITS(3)
     1079    /* GLONASS-M P, GLONASS-M ln (third string) */
     1080    GETFLOATSIGNM(eph._tau, 22, 1.0 / (double )(1 << 30))
     1081    /* GLONASS tau n(tb) */
     1082    SKIPBITS(5)
     1083    /* GLONASS-M delta tau n(tb) */
    10931084    GETBITS(eph._E, 5)
    10941085    /* GETBITS(i, 1) / * GLONASS-M P4 */
     
    11231114//
    11241115////////////////////////////////////////////////////////////////////////////
    1125 bool RTCM3Decoder::DecodeQZSSEphemeris(unsigned char* data, int size)
    1126 {
     1116bool RTCM3Decoder::DecodeQZSSEphemeris(unsigned char* data, int size) {
    11271117  bool decoded = false;
    11281118
    1129   if(size == 67)
    1130   {
     1119  if (size == 67) {
    11311120    t_ephGPS eph;
    11321121    int i, week;
     
    11441133    GETBITS(i, 16)
    11451134    i <<= 4;
    1146     eph._TOC.set(i*1000);
    1147 
    1148     GETFLOATSIGN(eph._clock_driftrate, 8, 1.0/(double)(1<<30)/(double)(1<<25))
    1149     GETFLOATSIGN(eph._clock_drift, 16, 1.0/(double)(1<<30)/(double)(1<<13))
    1150     GETFLOATSIGN(eph._clock_bias, 22, 1.0/(double)(1<<30)/(double)(1<<1))
     1135    eph._TOC.set(i * 1000);
     1136
     1137    GETFLOATSIGN(eph._clock_driftrate, 8,
     1138        1.0 / (double )(1 << 30) / (double )(1 << 25))
     1139    GETFLOATSIGN(eph._clock_drift, 16,
     1140        1.0 / (double )(1 << 30) / (double )(1 << 13))
     1141    GETFLOATSIGN(eph._clock_bias, 22,
     1142        1.0 / (double )(1 << 30) / (double )(1 << 1))
    11511143    GETBITS(eph._IODE, 8)
    1152     GETFLOATSIGN(eph._Crs, 16, 1.0/(double)(1<<5))
     1144    GETFLOATSIGN(eph._Crs, 16, 1.0 / (double )(1 << 5))
    11531145    GETFLOATSIGN(eph._Delta_n, 16, R2R_PI/(double)(1<<30)/(double)(1<<13))
    11541146    GETFLOATSIGN(eph._M0, 32, R2R_PI/(double)(1<<30)/(double)(1<<1))
    1155     GETFLOATSIGN(eph._Cuc, 16, 1.0/(double)(1<<29))
    1156     GETFLOAT(eph._e, 32, 1.0/(double)(1<<30)/(double)(1<<3))
    1157     GETFLOATSIGN(eph._Cus, 16, 1.0/(double)(1<<29))
    1158     GETFLOAT(eph._sqrt_A, 32, 1.0/(double)(1<<19))
     1147    GETFLOATSIGN(eph._Cuc, 16, 1.0 / (double )(1 << 29))
     1148    GETFLOAT(eph._e, 32, 1.0 / (double )(1 << 30) / (double )(1 << 3))
     1149    GETFLOATSIGN(eph._Cus, 16, 1.0 / (double )(1 << 29))
     1150    GETFLOAT(eph._sqrt_A, 32, 1.0 / (double )(1 << 19))
    11591151    GETBITS(i, 16)
    11601152    i <<= 4;
     
    11631155    t.set(i);
    11641156
    1165     GETFLOATSIGN(eph._Cic, 16, 1.0/(double)(1<<29))
     1157    GETFLOATSIGN(eph._Cic, 16, 1.0 / (double )(1 << 29))
    11661158    GETFLOATSIGN(eph._OMEGA0, 32, R2R_PI/(double)(1<<30)/(double)(1<<1))
    1167     GETFLOATSIGN(eph._Cis, 16, 1.0/(double)(1<<29))
     1159    GETFLOATSIGN(eph._Cis, 16, 1.0 / (double )(1 << 29))
    11681160    GETFLOATSIGN(eph._i0, 32, R2R_PI/(double)(1<<30)/(double)(1<<1))
    1169     GETFLOATSIGN(eph._Crc, 16, 1.0/(double)(1<<5))
     1161    GETFLOATSIGN(eph._Crc, 16, 1.0 / (double )(1 << 5))
    11701162    GETFLOATSIGN(eph._omega, 32, R2R_PI/(double)(1<<30)/(double)(1<<1))
    11711163    GETFLOATSIGN(eph._OMEGADOT, 24, R2R_PI/(double)(1<<30)/(double)(1<<13))
     
    11761168    eph._TOEweek = t.gpsw();
    11771169    /* week from HOW, differs from TOC, TOE week, we use adapted value instead */
    1178     if(eph._TOEweek > week + 1 || eph._TOEweek < week-1) /* invalid week */
     1170    if (eph._TOEweek > week + 1 || eph._TOEweek < week - 1) /* invalid week */
    11791171      return false;
    11801172
    11811173    GETBITS(i, 4)
    1182     if(i <= 6)
    1183       eph._ura = ceil(10.0*pow(2.0, 1.0+i/2.0))/10.0;
     1174    if (i <= 6)
     1175      eph._ura = ceil(10.0 * pow(2.0, 1.0 + i / 2.0)) / 10.0;
    11841176    else
    1185       eph._ura = ceil(10.0*pow(2.0, i/2.0))/10.0;
     1177      eph._ura = ceil(10.0 * pow(2.0, i / 2.0)) / 10.0;
    11861178    GETBITS(eph._health, 6)
    1187     GETFLOATSIGN(eph._TGD, 8, 1.0/(double)(1<<30)/(double)(1<<1))
     1179    GETFLOATSIGN(eph._TGD, 8, 1.0 / (double )(1 << 30) / (double )(1 << 1))
    11881180    GETBITS(eph._IODC, 10)
    11891181    GETBITS(eph._fitInterval, 1)
     
    11991191//
    12001192////////////////////////////////////////////////////////////////////////////
    1201 bool RTCM3Decoder::DecodeSBASEphemeris(unsigned char* data, int size)
    1202 {
     1193bool RTCM3Decoder::DecodeSBASEphemeris(unsigned char* data, int size) {
    12031194  bool decoded = false;
    12041195
    1205   if(size == 35)
    1206   {
     1196  if (size == 35) {
    12071197    t_ephSBAS eph;
    12081198    int i;
     
    12161206
    12171207    GETBITS(i, 6)
    1218     eph._prn.set('S', 20+i);
     1208    eph._prn.set('S', 20 + i);
    12191209    GETBITS(eph._IODN, 8)
    12201210    GETBITS(i, 13)
    12211211    i <<= 4;
    1222     eph._TOC.setTOD(i*1000);
     1212    eph._TOC.setTOD(i * 1000);
    12231213    GETBITS(i, 4)
    12241214    eph._ura = accuracyFromIndex(i, eph.type());
     
    12321222    GETFLOATSIGN(eph._y_acceleration, 10, 0.0000125)
    12331223    GETFLOATSIGN(eph._z_acceleration, 10, 0.0000625)
    1234     GETFLOATSIGN(eph._agf0, 12, 1.0/(1<<30)/(1<<1))
    1235     GETFLOATSIGN(eph._agf1, 8, 1.0/(1<<30)/(1<<10))
     1224    GETFLOATSIGN(eph._agf0, 12, 1.0 / (1 << 30) / (1 << 1))
     1225    GETFLOATSIGN(eph._agf1, 8, 1.0 / (1 << 30) / (1 << 10))
    12361226
    12371227    eph._TOW = 0.9999E9;
     
    12461236//
    12471237////////////////////////////////////////////////////////////////////////////
    1248 bool RTCM3Decoder::DecodeGalileoEphemeris(unsigned char* data, int size)
    1249 {
     1238bool RTCM3Decoder::DecodeGalileoEphemeris(unsigned char* data, int size) {
    12501239  bool decoded = false;
    12511240  uint64_t numbits = 0, bitfield = 0;
     
    12561245  GETBITS(i, 12)
    12571246
    1258   if((i == 1046 && size == 61) || (i == 1045 && size == 60))
    1259   {
     1247  if ((i == 1046 && size == 61) || (i == 1045 && size == 60)) {
    12601248    t_ephGal eph;
    12611249
     
    12731261    GETFLOATSIGN(eph._IDOT, 14, R2R_PI/(double)(1<<30)/(double)(1<<13))
    12741262    GETBITSFACTOR(i, 14, 60)
    1275     eph._TOC.set(1024+eph._TOEweek, i);
    1276     GETFLOATSIGN(eph._clock_driftrate, 6, 1.0/(double)(1<<30)/(double)(1<<29))
    1277     GETFLOATSIGN(eph._clock_drift, 21, 1.0/(double)(1<<30)/(double)(1<<16))
    1278     GETFLOATSIGN(eph._clock_bias, 31, 1.0/(double)(1<<30)/(double)(1<<4))
    1279     GETFLOATSIGN(eph._Crs, 16, 1.0/(double)(1<<5))
     1263    eph._TOC.set(1024 + eph._TOEweek, i);
     1264    GETFLOATSIGN(eph._clock_driftrate, 6,
     1265        1.0 / (double )(1 << 30) / (double )(1 << 29))
     1266    GETFLOATSIGN(eph._clock_drift, 21,
     1267        1.0 / (double )(1 << 30) / (double )(1 << 16))
     1268    GETFLOATSIGN(eph._clock_bias, 31,
     1269        1.0 / (double )(1 << 30) / (double )(1 << 4))
     1270    GETFLOATSIGN(eph._Crs, 16, 1.0 / (double )(1 << 5))
    12801271    GETFLOATSIGN(eph._Delta_n, 16, R2R_PI/(double)(1<<30)/(double)(1<<13))
    12811272    GETFLOATSIGN(eph._M0, 32, R2R_PI/(double)(1<<30)/(double)(1<<1))
    1282     GETFLOATSIGN(eph._Cuc, 16, 1.0/(double)(1<<29))
    1283     GETFLOAT(eph._e, 32, 1.0/(double)(1<<30)/(double)(1<<3))
    1284     GETFLOATSIGN(eph._Cus, 16, 1.0/(double)(1<<29))
    1285     GETFLOAT(eph._sqrt_A, 32, 1.0/(double)(1<<19))
     1273    GETFLOATSIGN(eph._Cuc, 16, 1.0 / (double )(1 << 29))
     1274    GETFLOAT(eph._e, 32, 1.0 / (double )(1 << 30) / (double )(1 << 3))
     1275    GETFLOATSIGN(eph._Cus, 16, 1.0 / (double )(1 << 29))
     1276    GETFLOAT(eph._sqrt_A, 32, 1.0 / (double )(1 << 19))
    12861277    GETBITSFACTOR(eph._TOEsec, 14, 60)
    12871278    /* FIXME: overwrite value, copied from old code */
    12881279    eph._TOEsec = eph._TOC.gpssec();
    1289     GETFLOATSIGN(eph._Cic, 16, 1.0/(double)(1<<29))
     1280    GETFLOATSIGN(eph._Cic, 16, 1.0 / (double )(1 << 29))
    12901281    GETFLOATSIGN(eph._OMEGA0, 32, R2R_PI/(double)(1<<30)/(double)(1<<1))
    1291     GETFLOATSIGN(eph._Cis, 16, 1.0/(double)(1<<29))
     1282    GETFLOATSIGN(eph._Cis, 16, 1.0 / (double )(1 << 29))
    12921283    GETFLOATSIGN(eph._i0, 32, R2R_PI/(double)(1<<30)/(double)(1<<1))
    1293     GETFLOATSIGN(eph._Crc, 16, 1.0/(double)(1<<5))
     1284    GETFLOATSIGN(eph._Crc, 16, 1.0 / (double )(1 << 5))
    12941285    GETFLOATSIGN(eph._omega, 32, R2R_PI/(double)(1<<30)/(double)(1<<1))
    12951286    GETFLOATSIGN(eph._OMEGADOT, 24, R2R_PI/(double)(1<<30)/(double)(1<<13))
    1296     GETFLOATSIGN(eph._BGD_1_5A, 10, 1.0/(double)(1<<30)/(double)(1<<2))
    1297     if(eph._inav)
    1298     {
     1287    GETFLOATSIGN(eph._BGD_1_5A, 10,
     1288        1.0 / (double )(1 << 30) / (double )(1 << 2))
     1289    if (eph._inav) {
    12991290      /* set unused F/NAV values */
    13001291      eph._E5aHS = 0.0;
    13011292      eph._e5aDataInValid = false;
    13021293
    1303       GETFLOATSIGN(eph._BGD_1_5B, 10, 1.0/(double)(1<<30)/(double)(1<<2))
     1294      GETFLOATSIGN(eph._BGD_1_5B, 10,
     1295          1.0 / (double )(1 << 30) / (double )(1 << 2))
    13041296      GETBITS(eph._E5bHS, 2)
    13051297      GETBITS(eph._e5bDataInValid, 1)
     
    13071299      GETBITS(eph._e1DataInValid, 1)
    13081300    }
    1309     else
    1310     {
     1301    else {
    13111302      /* set unused I/NAV values */
    13121303      eph._BGD_1_5B = 0.0;
     
    13291320//
    13301321////////////////////////////////////////////////////////////////////////////
    1331 bool RTCM3Decoder::DecodeBDSEphemeris(unsigned char* data, int size)
    1332 {
     1322bool RTCM3Decoder::DecodeBDSEphemeris(unsigned char* data, int size) {
    13331323  bool decoded = false;
    13341324
    1335   if(size == 70)
    1336   {
     1325  if (size == 70) {
    13371326    t_ephBDS eph;
    13381327    int i;
     
    13481337    eph._prn.set('C', i);
    13491338
    1350     SKIPBITS(13) /* week */
     1339    SKIPBITS(13)
     1340    /* week */
    13511341    GETBITS(i, 4)
    13521342    eph._URA = accuracyFromIndex(i, eph.type());
     
    13551345    GETBITS(i, 17)
    13561346    i <<= 3;
    1357     eph._TOC.setBDS(i*1000);
    1358     GETFLOATSIGN(eph._clock_driftrate, 11, 1.0/(double)(1<<30)/(double)(1<<30)/(double)(1<<6))
    1359     GETFLOATSIGN(eph._clock_drift, 22, 1.0/(double)(1<<30)/(double)(1<<20))
    1360     GETFLOATSIGN(eph._clock_bias, 24, 1.0/(double)(1<<30)/(double)(1<<3))
     1347    eph._TOC.setBDS(i * 1000);
     1348    GETFLOATSIGN(eph._clock_driftrate, 11,
     1349        1.0 / (double )(1 << 30) / (double )(1 << 30) / (double )(1 << 6))
     1350    GETFLOATSIGN(eph._clock_drift, 22,
     1351        1.0 / (double )(1 << 30) / (double )(1 << 20))
     1352    GETFLOATSIGN(eph._clock_bias, 24,
     1353        1.0 / (double )(1 << 30) / (double )(1 << 3))
    13611354    GETBITS(eph._AODC, 5)
    1362     GETFLOATSIGN(eph._Crs, 18, 1.0/(double)(1<<6))
     1355    GETFLOATSIGN(eph._Crs, 18, 1.0 / (double )(1 << 6))
    13631356    GETFLOATSIGN(eph._Delta_n, 16, R2R_PI/(double)(1<<30)/(double)(1<<13))
    13641357    GETFLOATSIGN(eph._M0, 32, R2R_PI/(double)(1<<30)/(double)(1<<1))
    1365     GETFLOATSIGN(eph._Cuc, 18, 1.0/(double)(1<<30)/(double)(1<<1))
    1366     GETFLOAT(eph._e, 32, 1.0/(double)(1<<30)/(double)(1<<3))
    1367     GETFLOATSIGN(eph._Cus, 18, 1.0/(double)(1<<30)/(double)(1<<1))
    1368     GETFLOAT(eph._sqrt_A, 32, 1.0/(double)(1<<19))
     1358    GETFLOATSIGN(eph._Cuc, 18, 1.0 / (double )(1 << 30) / (double )(1 << 1))
     1359    GETFLOAT(eph._e, 32, 1.0 / (double )(1 << 30) / (double )(1 << 3))
     1360    GETFLOATSIGN(eph._Cus, 18, 1.0 / (double )(1 << 30) / (double )(1 << 1))
     1361    GETFLOAT(eph._sqrt_A, 32, 1.0 / (double )(1 << 19))
    13691362    GETBITS(i, 17)
    13701363    i <<= 3;
    13711364    eph._TOEsec = i;
    1372     eph._TOE.setBDS(i*1000);
    1373     GETFLOATSIGN(eph._Cic, 18, 1.0/(double)(1<<30)/(double)(1<<1))
     1365    eph._TOE.setBDS(i * 1000);
     1366    GETFLOATSIGN(eph._Cic, 18, 1.0 / (double )(1 << 30) / (double )(1 << 1))
    13741367    GETFLOATSIGN(eph._OMEGA0, 32, R2R_PI/(double)(1<<30)/(double)(1<<1))
    1375     GETFLOATSIGN(eph._Cis, 18, 1.0/(double)(1<<30)/(double)(1<<1))
     1368    GETFLOATSIGN(eph._Cis, 18, 1.0 / (double )(1 << 30) / (double )(1 << 1))
    13761369    GETFLOATSIGN(eph._i0, 32, R2R_PI/(double)(1<<30)/(double)(1<<1))
    1377     GETFLOATSIGN(eph._Crc, 18, 1.0/(double)(1<<6))
     1370    GETFLOATSIGN(eph._Crc, 18, 1.0 / (double )(1 << 6))
    13781371    GETFLOATSIGN(eph._omega, 32, R2R_PI/(double)(1<<30)/(double)(1<<1))
    13791372    GETFLOATSIGN(eph._OMEGADOT, 24, R2R_PI/(double)(1<<30)/(double)(1<<13))
     
    13911384//
    13921385////////////////////////////////////////////////////////////////////////////
    1393 bool RTCM3Decoder::DecodeAntenna(unsigned char* data, int size)
    1394 {
     1386bool RTCM3Decoder::DecodeAntenna(unsigned char* data, int size) {
    13951387  char *antenna, type[256];
    13961388  int antnum = -1;
     
    14141406//
    14151407////////////////////////////////////////////////////////////////////////////
    1416 bool RTCM3Decoder::DecodeAntennaPosition(unsigned char* data, int size)
    1417 {
     1408bool RTCM3Decoder::DecodeAntennaPosition(unsigned char* data, int size) {
    14181409  int type;
    14191410  uint64_t numbits = 0, bitfield = 0;
     
    14351426  GETBITSSIGN(z, 38)
    14361427  _antList.back().zz = z * 1e-4;
    1437   if(type == 1006)
    1438   {
     1428  if (type == 1006)
     1429      {
    14391430    double h;
    14401431    GETBITS(h, 16)
     
    14421433    _antList.back().height_f = true;
    14431434  }
    1444   _antList.back().message  = type;
     1435  _antList.back().message = type;
    14451436
    14461437  return true;
     
    14491440//
    14501441////////////////////////////////////////////////////////////////////////////
    1451 t_irc RTCM3Decoder::Decode(char* buffer, int bufLen, vector<string>& errmsg)
    1452 {
     1442t_irc RTCM3Decoder::Decode(char* buffer, int bufLen, vector<string>& errmsg) {
    14531443  bool decoded = false;
    14541444
    14551445  errmsg.clear();
    14561446
    1457   while(bufLen && _MessageSize < sizeof(_Message))
    1458   {
     1447  while (bufLen && _MessageSize < sizeof(_Message)) {
    14591448    int l = sizeof(_Message) - _MessageSize;
    1460     if(l > bufLen)
     1449    if (l > bufLen)
    14611450      l = bufLen;
    1462     memcpy(_Message+_MessageSize, buffer, l);
     1451    memcpy(_Message + _MessageSize, buffer, l);
    14631452    _MessageSize += l;
    14641453    bufLen -= l;
    14651454    buffer += l;
    14661455    int id;
    1467     while((id = GetMessage()))
    1468     {
     1456    while ((id = GetMessage())) {
    14691457      /* reset station ID for file loading as it can change */
    1470       if(_rawFile)
     1458      if (_rawFile)
    14711459        _staID = _rawFile->staID();
    14721460      /* store the id into the list of loaded blocks */
     
    14761464       * extracted data block. That does no harm, as it anyway skip everything
    14771465       * else. */
    1478       if((id >= 1057 && id <= 1068) || (id >= 1240 && id <= 1270))
    1479       {
     1466      if ((id >= 1057 && id <= 1068) || (id >= 1240 && id <= 1270)) {
    14801467        if (!_coDecoders.contains(_staID.toAscii()))
    14811468          _coDecoders[_staID.toAscii()] = new RTCM3coDecoder(_staID);
    14821469        RTCM3coDecoder* coDecoder = _coDecoders[_staID.toAscii()];
    1483         if(coDecoder->Decode(reinterpret_cast<char *>(_Message), _BlockSize,
    1484         errmsg) == success)
    1485         {
     1470        if (coDecoder->Decode(reinterpret_cast<char *>(_Message), _BlockSize,
     1471            errmsg) == success) {
    14861472          decoded = true;
    14871473        }
    14881474      }
    1489       else if(id >= 1070 && id <= 1229) /* MSM */
    1490       {
    1491         if(DecodeRTCM3MSM(_Message, _BlockSize))
     1475      else if (id >= 1070 && id <= 1229) /* MSM */ {
     1476        if (DecodeRTCM3MSM(_Message, _BlockSize))
    14921477          decoded = true;
    14931478      }
    1494       else
    1495       {
    1496         switch(id)
    1497         {
    1498         case 1001: case 1003:
    1499           emit(newMessage(QString("%1: Block %2 contain partial data! Ignored!")
    1500           .arg(_staID).arg(id).toAscii(), true));
    1501           break; /* no use decoding partial data ATM, remove break when data can be used */
    1502         case 1002: case 1004:
    1503           if(DecodeRTCM3GPS(_Message, _BlockSize))
    1504             decoded = true;
    1505           break;
    1506         case 1009: case 1011:
    1507           emit(newMessage(QString("%1: Block %2 contain partial data! Ignored!")
    1508           .arg(_staID).arg(id).toAscii(), true));
    1509           break; /* no use decoding partial data ATM, remove break when data can be used */
    1510         case 1010: case 1012:
    1511           if(DecodeRTCM3GLONASS(_Message, _BlockSize))
    1512             decoded = true;
    1513           break;
    1514         case 1019:
    1515           if(DecodeGPSEphemeris(_Message, _BlockSize))
    1516             decoded = true;
    1517           break;
    1518         case 1020:
    1519           if(DecodeGLONASSEphemeris(_Message, _BlockSize))
    1520             decoded = true;
    1521           break;
    1522         case 1043:
    1523           if(DecodeSBASEphemeris(_Message, _BlockSize))
    1524             decoded = true;
    1525           break;
    1526         case 1044:
    1527           if(DecodeQZSSEphemeris(_Message, _BlockSize))
    1528             decoded = true;
    1529           break;
    1530         case 1045: case 1046:
    1531           if(DecodeGalileoEphemeris(_Message, _BlockSize))
    1532             decoded = true;
    1533           break;
    1534         case RTCM3ID_BDS:
    1535           if(DecodeBDSEphemeris(_Message, _BlockSize))
    1536             decoded = true;
    1537           break;
    1538         case 1007: case 1008: case 1033:
    1539           DecodeAntenna(_Message, _BlockSize);
    1540           break;
    1541         case 1005: case 1006:
    1542           DecodeAntennaPosition(_Message, _BlockSize);
    1543           break;
     1479      else {
     1480        switch (id) {
     1481          case 1001:
     1482          case 1003:
     1483            emit(newMessage(
     1484                QString("%1: Block %2 contain partial data! Ignored!")
     1485                    .arg(_staID).arg(id).toAscii(), true));
     1486            break; /* no use decoding partial data ATM, remove break when data can be used */
     1487          case 1002:
     1488          case 1004:
     1489            if (DecodeRTCM3GPS(_Message, _BlockSize))
     1490              decoded = true;
     1491            break;
     1492          case 1009:
     1493          case 1011:
     1494            emit(newMessage(
     1495                QString("%1: Block %2 contain partial data! Ignored!")
     1496                    .arg(_staID).arg(id).toAscii(), true));
     1497            break; /* no use decoding partial data ATM, remove break when data can be used */
     1498          case 1010:
     1499          case 1012:
     1500            if (DecodeRTCM3GLONASS(_Message, _BlockSize))
     1501              decoded = true;
     1502            break;
     1503          case 1019:
     1504            if (DecodeGPSEphemeris(_Message, _BlockSize))
     1505              decoded = true;
     1506            break;
     1507          case 1020:
     1508            if (DecodeGLONASSEphemeris(_Message, _BlockSize))
     1509              decoded = true;
     1510            break;
     1511          case 1043:
     1512            if (DecodeSBASEphemeris(_Message, _BlockSize))
     1513              decoded = true;
     1514            break;
     1515          case 1044:
     1516            if (DecodeQZSSEphemeris(_Message, _BlockSize))
     1517              decoded = true;
     1518            break;
     1519          case 1045:
     1520          case 1046:
     1521            if (DecodeGalileoEphemeris(_Message, _BlockSize))
     1522              decoded = true;
     1523            break;
     1524          case RTCM3ID_BDS:
     1525            if (DecodeBDSEphemeris(_Message, _BlockSize))
     1526              decoded = true;
     1527            break;
     1528          case 1007:
     1529          case 1008:
     1530          case 1033:
     1531            DecodeAntenna(_Message, _BlockSize);
     1532            break;
     1533          case 1005:
     1534          case 1006:
     1535            DecodeAntennaPosition(_Message, _BlockSize);
     1536            break;
    15441537        }
    15451538      }
     
    15471540  }
    15481541  return decoded ? success : failure;
    1549 };
     1542}
     1543;
    15501544
    15511545//
    15521546////////////////////////////////////////////////////////////////////////////
    1553 uint32_t RTCM3Decoder::CRC24(long size, const unsigned char *buf)
    1554 {
     1547uint32_t RTCM3Decoder::CRC24(long size, const unsigned char *buf) {
    15551548  uint32_t crc = 0;
    15561549  int i;
    15571550
    1558   while(size--)
    1559   {
     1551  while (size--) {
    15601552    crc ^= (*buf++) << (16);
    1561     for(i = 0; i < 8; i++)
    1562     {
     1553    for (i = 0; i < 8; i++)
     1554        {
    15631555      crc <<= 1;
    1564       if(crc & 0x1000000)
     1556      if (crc & 0x1000000)
    15651557        crc ^= 0x01864cfb;
    15661558    }
     
    15711563//
    15721564////////////////////////////////////////////////////////////////////////////
    1573 int RTCM3Decoder::GetMessage(void)
    1574 {
     1565int RTCM3Decoder::GetMessage(void) {
    15751566  unsigned char *m, *e;
    15761567  int i;
    15771568
    1578   m = _Message+_SkipBytes;
    1579   e = _Message+_MessageSize;
     1569  m = _Message + _SkipBytes;
     1570  e = _Message + _MessageSize;
    15801571  _NeedBytes = _SkipBytes = 0;
    1581   while(e-m >= 3)
    1582   {
    1583     if(m[0] == 0xD3)
    1584     {
    1585       _BlockSize = ((m[1]&3)<<8)|m[2];
    1586       if(e-m >= static_cast<int>(_BlockSize+6))
    1587       {
    1588         if(static_cast<uint32_t>((m[3+_BlockSize]<<16)|(m[3+_BlockSize+1]<<8)
    1589         |(m[3+_BlockSize+2])) == CRC24(_BlockSize+3, m))
    1590         {
    1591           _BlockSize +=6;
     1572  while (e - m >= 3) {
     1573    if (m[0] == 0xD3) {
     1574      _BlockSize = ((m[1] & 3) << 8) | m[2];
     1575      if (e - m >= static_cast<int>(_BlockSize + 6)) {
     1576        if (static_cast<uint32_t>((m[3 + _BlockSize] << 16)
     1577            | (m[3 + _BlockSize + 1] << 8)
     1578            | (m[3 + _BlockSize + 2])) == CRC24(_BlockSize + 3, m)) {
     1579          _BlockSize += 6;
    15921580          _SkipBytes = _BlockSize;
    15931581          break;
     
    15961584          ++m;
    15971585      }
    1598       else
    1599       {
     1586      else {
    16001587        _NeedBytes = _BlockSize;
    16011588        break;
     
    16051592      ++m;
    16061593  }
    1607   if(e-m < 3)
     1594  if (e - m < 3)
    16081595    _NeedBytes = 3;
    16091596
    16101597  /* copy buffer to front */
    16111598  i = m - _Message;
    1612   if(i && m < e)
    1613     memmove(_Message, m, static_cast<size_t>(_MessageSize-i));
     1599  if (i && m < e)
     1600    memmove(_Message, m, static_cast<size_t>(_MessageSize - i));
    16141601  _MessageSize -= i;
    16151602
    1616   return !_NeedBytes ? ((_Message[3]<<4)|(_Message[4]>>4)) : 0;
     1603  return !_NeedBytes ? ((_Message[3] << 4) | (_Message[4] >> 4)) : 0;
    16171604}
    16181605
     
    16201607//////////////////////////////////////////////////////////////////////////////
    16211608int RTCM3Decoder::corrGPSEpochTime() const {
    1622   return _coDecoders.size() > 0 ? _coDecoders.begin().value()->corrGPSEpochTime() : -1;
    1623 }
     1609  return
     1610      _coDecoders.size() > 0 ?
     1611          _coDecoders.begin().value()->corrGPSEpochTime() : -1;
     1612}
Note: See TracChangeset for help on using the changeset viewer.