source: ntrip/trunk/BNC/src/upload/bncuploadcaster.h@ 11060

#ifndef BNCUPLOADCASTER_H
#define BNCUPLOADCASTER_H

#include <QDateTime>
#include <QMutex>
#include <QSslSocket>
#include <QNetworkProxy>
#include <QThread>
#include <QSslError>
#include <QSslKey>
#include <iostream>


class bncUploadCaster : public QThread {
 Q_OBJECT
 public:
  bncUploadCaster(const QString& mountpoint,
      const QString& outHost, int outPort,
      const QString& ntripVersion,
      const QString& userName, const QString& password,
      int iRow, int rate);
  virtual void deleteSafely();
  void setOutBuffer(const QByteArray& outBuffer) {
    QMutexLocker locker(&_mutex);
    _outBuffer = outBuffer;
  }
  // Append data for streams forwarded chunk by chunk (raw upload): several
  // chunks may arrive between two sends of the upload thread (every 0.1 s)
  void appendOutBuffer(const QByteArray& data) {
    QMutexLocker locker(&_mutex);
    _outBuffer += data;
  }

 protected:
  virtual    ~bncUploadCaster();
  QMutex     _mutex;
  QByteArray _outBuffer;

 signals:
  void newMessage(const QByteArray msg, bool showOnScreen);
  void newBytes(QByteArray staID, double nbyte);

 private slots:
  void slotProxyAuthenticationRequired(const QNetworkProxy&, QAuthenticator*);
  void slotSslErrors(QList<QSslError>);

 private:
  void         open();
  bool         connectToHost(QString outHost, int outPort, bool encrypted);
  virtual void run();
  bool        _isToBeDeleted;
  QString     _mountpoint;
  QString     _outHost;
  int         _outPort;
  QString     _casterOutHost;
  int         _casterOutPort;
  QString     _proxyOutHost;
  int         _proxyOutPort;
  QString     _crtFileName;
  QString     _keyFileName;
  QString     _userName;
  QString     _password;
  QString     _ntripVersion;
  QString     _postExtension;
  bool        _secure;
  bool        _sslIgnoreErrors;
  bool        _proxy;
  QSslSocket* _outSocket;
  int         _sOpenTrial;
  QDateTime   _outSocketOpenTime;
  int         _iRow;
  int         _rate;
};

#endif