remotefile.h

Go to the documentation of this file.

#ifndef REMOTEFILE_H_
#define REMOTEFILE_H_

#include <sys/stat.h>

#include <QDateTime>
#include <QStringList>
#include <QMutex>

#include "mythbaseexp.h"
#include "mythtimer.h"

class MythSocket;
class QFile;
class ThreadedFileWriter;

class MBASE_PUBLIC RemoteFile
{
  public:
    RemoteFile(QString url = "",
               bool write = false,
               bool usereadahead = true,
               int timeout_ms = 2000/*RingBuffer::kDefaultOpenTimeout*/,
               const QStringList *possibleAuxiliaryFiles = nullptr);
   ~RemoteFile();

    bool ReOpen(const QString& newFilename);

    long long Seek(long long pos, int whence, long long curpos = -1);

    static bool DeleteFile(const QString &url);
    static bool Exists(const QString &url, struct stat *fileinfo);
    static bool Exists(const QString &url);
    static QString GetFileHash(const QString &url);
    static QDateTime LastModified(const QString &url);
    QDateTime LastModified(void) const;
    static QString FindFile(const QString &filename, const QString &host,
                            const QString &storageGroup, bool useRegex = false,
                            bool allowFallback = false);

    static QStringList FindFileList(const QString &filename, const QString &host,
                                    const QString &storageGroup, bool useRegex = false,
                                    bool allowFallback = false);
    static bool CopyFile(const QString &src, const QString &dst,
                         bool overwrite = false, bool verify = false);
    static bool MoveFile(const QString &src, const QString &dst,
                         bool overwrite = false);

    int Write(const void *data, int size);
    int Read(void *data, int size);
    void Reset(void);
    bool SetBlocking(bool m_block = true);

    bool SaveAs(QByteArray &data);

    void SetTimeout(bool fast);

    bool isOpen(void) const;
    static bool isLocal(const QString &path);
    bool isLocal(void) const;
    long long GetFileSize(void) const;
    long long GetRealFileSize(void);

    QStringList GetAuxiliaryFiles(void) const
        { return m_auxFiles; }

  private:
    bool Open(void);
    bool OpenInternal(void);
    void Close(bool haslock = false);
    bool CheckConnection(bool repos = true);
    bool IsConnected(void);
    bool Resume(bool repos = true);
    long long SeekInternal(long long pos, int whence, long long curpos = -1);

    MythSocket     *openSocket(bool control);

    QString         m_path;
    bool            m_useReadAhead     {true};
    int             m_timeoutMs        {2000};
    long long       m_fileSize         {-1};
    bool            m_timeoutIsFast    {false};
    long long       m_readPosition     {0LL};
    long long       m_lastPosition     {0LL};
    bool            m_canResume        {false};
    int             m_recorderNum      {0};

    mutable QMutex  m_lock             {QMutex::NonRecursive};
    MythSocket     *m_controlSock      {nullptr};
    MythSocket     *m_sock             {nullptr};
    QString         m_query            {"QUERY_FILETRANSFER %1"};

    bool            m_writeMode        {false};
    bool            m_completed        {false};
    MythTimer       m_lastSizeCheck;

    QStringList     m_possibleAuxFiles;
    QStringList     m_auxFiles;
    int             m_localFile        {-1};
    ThreadedFileWriter *m_fileWriter   {nullptr};
};

#endif