source: ntrip/trunk/BNC/upload/bncephuploadcaster.cpp@ 3256

/* -------------------------------------------------------------------------
 * BKG NTRIP Server
 * -------------------------------------------------------------------------
 *
 * Class:      bncEphUploadCaster
 *
 * Purpose:    Connection to NTRIP Caster for Ephemeris
 *
 * Author:     L. Mervart
 *
 * Created:    03-Apr-2011
 *
 * Changes:    
 *
 * -----------------------------------------------------------------------*/

#include <math.h>
#include "bncephuploadcaster.h" 
#include "bncsettings.h"

using namespace std;

// Constructor
////////////////////////////////////////////////////////////////////////////
bncEphUploadCaster::bncEphUploadCaster() {
  bncSettings settings;

  QString mountpoint = settings.value("uploadEphMountpoint").toString();
  if (mountpoint.isEmpty()) {
    _ephUploadCaster = 0;
  }
  else {
    QString outHost    = settings.value("uploadEphHost").toString();
    int     outPort    = settings.value("uploadEphPort").toInt();
    QString password   = settings.value("uploadEphPassword").toString();

    _ephUploadCaster = new bncUploadCaster(mountpoint, outHost, outPort, 
                                         password, -1);

    connect(_ephUploadCaster, SIGNAL(newBytes(QByteArray,double)), 
          this, SIGNAL(newBytes(QByteArray,double)));

    _ephUploadCaster->start();
  }
}

// Destructor
////////////////////////////////////////////////////////////////////////////
bncEphUploadCaster::~bncEphUploadCaster() {
  if (_ephUploadCaster) {
    _ephUploadCaster->deleteSafely();
  }
}

// List of Stored Ephemeris changed (virtual)
////////////////////////////////////////////////////////////////////////////
void bncEphUploadCaster::ephBufferChanged() {
  if (_ephUploadCaster) {
    QMutexLocker locker(&_mutex);

    QMapIterator<QString, t_ephPair*> it(_eph);
    while (it.hasNext()) {
      it.next();
      QByteArray outBuffer;

      t_eph* eph = it.value()->last;
      unsigned char Array[67];
      int size = eph->RTCM3(Array);
      if (size > 0) {
        outBuffer += QByteArray((char*) Array, size);
      }
   
      if (outBuffer.size() > 0) {
        _ephUploadCaster->setOutBuffer(outBuffer);
      }
    }
  }
}