diff options
Diffstat (limited to 'plugins/CopyEngine/Ultracopier-0.3/TransferThread.h')
| -rw-r--r-- | plugins/CopyEngine/Ultracopier-0.3/TransferThread.h | 202 |
1 files changed, 202 insertions, 0 deletions
diff --git a/plugins/CopyEngine/Ultracopier-0.3/TransferThread.h b/plugins/CopyEngine/Ultracopier-0.3/TransferThread.h new file mode 100644 index 0000000..37aa608 --- /dev/null +++ b/plugins/CopyEngine/Ultracopier-0.3/TransferThread.h @@ -0,0 +1,202 @@ +/** \file TransferThread.h +\brief Thread changed to manage the inode operation, the signals, canceling, pre and post operations +\author alpha_one_x86 +\version 0.3 +\date 2011 */ + +#ifndef TRANSFERTHREAD_H +#define TRANSFERTHREAD_H + +#include <QThread> +#include <QFileInfo> +#include <QString> +#include <QList> +#include <QStringList> +#include <QDateTime> +#include <QDir> + +#include "ReadThread.h" +#include "WriteThread.h" +#include "Environment.h" +#include "StructEnumDefinition_CopyEngine.h" + +/// \brief Thread changed to manage the inode operation, the signals, canceling, pre and post operations +class TransferThread : public QThread +{ + Q_OBJECT +public: + explicit TransferThread(); + ~TransferThread(); + /// \brief to have the transfer status + enum TransferStat + { + Idle=0, + PreOperation=1, + WaitForTheTransfer=2, + Transfer=3, + PostTransfer=4, + PostOperation=5 + }; + /// \brief get transfer stat + TransferStat getStat(); + /// \brief get drive of an file or folder + QString getDrive(QString fileOrFolder); + /// \brief set drive list, used in getDrive() + void setDrive(QStringList drives); + #ifdef ULTRACOPIER_PLUGIN_DEBUG + /// \brief to set the id + void setId(int id); + /// \brief get the reading letter + QChar readingLetter(); + /// \brief get the writing letter + QChar writingLetter(); + #endif + /// \brief to have semaphore, and try create just one by one + void setMkpathTransfer(QSemaphore *mkpathTransfer); + /// \brief to store the transfer id + quint64 transferId; + /// \brief to store the transfer size + quint64 transferSize; +protected: + void run(); +signals: + //to send state + void preOperationStopped(); + void checkIfItCanBeResumed(); + //void transferStarted();//not sended (and not used then) + void readStopped(); + void writeStopped(); + void postOperationStopped(); + //get dialog + void fileAlreadyExists(QFileInfo,QFileInfo,bool isSame); + void errorOnFile(QFileInfo,QString); + //internal signal + void internalStartPostOperation(); + void internalStartPreOperation(); + void internalStartResumeAfterErrorAndSeek(); + /// \brief To debug source + void debugInformation(DebugLevel level,QString fonction,QString text,QString file,int ligne); + void tryPutAtBottom(); + //force into the right thread + void internalTryStartTheTransfer(); + /// \brief update the transfer stat + void pushStat(TransferStat,quint64); +public slots: + /// \brief to start the transfer of data + void startTheTransfer(); + /// \brief to set files to transfer + void setFiles(const QString &source,const qint64 &size,const QString &destination,const CopyMode &mode); + /// \brief to set file exists action to do + void setFileExistsAction(const FileExistsAction &action); + /// \brief to set the new name of the destination + void setFileRename(const QString &nameForRename); + /// \brief to start the transfer of data + void setAlwaysFileExistsAction(const FileExistsAction &action); + /// \brief set the copy info and options before runing + void setRightTransfer(const bool doRightTransfer); + /// \brief set keep date + void setKeepDate(const bool keepDate); + /// \brief set the current max speed in KB/s + void setMaxSpeed(int maxSpeed); + /// \brief set block size in KB + bool setBlockSize(const unsigned int blockSize); + /// \brief pause the copy + void pause(); + /// \brief resume the copy + void resume(); + /// \brief stop the copy + void stop(); + /// \brief skip the copy + void skip(); + /// \brief retry after error + void retryAfterError(); + /// \brief return info about the copied size + qint64 copiedSize(); + /// \brief put the current file at bottom + void putAtBottom(); +private slots: + void preOperation(); + void readIsReady(); + void writeIsReady(); + void readIsFinish(); + void readIsClosed(); + void writeIsClosed(); + void postOperation(); + void getWriteError(); + void getReadError(); + //void syncAfterErrorAndReadFinish(); + void readThreadIsSeekToZeroAndWait(); + void writeThreadIsReopened(); + void readThreadResumeAfterError(); + //to filter the emition of signal + void readIsStopped(); + void writeIsStopped(); + //speed limitation + void timeOfTheBlockCopyFinished(); + //force into the right thread + void internalStartTheTransfer(); +private: + enum MoveReturn + { + MoveReturn_skip=0, + MoveReturn_moved=1, + MoveReturn_error=2 + }; + TransferStat stat; + ReadThread readThread; + WriteThread writeThread; + QString source; + QString destination; + CopyMode mode; + QTimer clockForTheCopySpeed; ///< For the speed throttling + bool doRightTransfer; + bool keepDate; + bool readIsReadyVariable; + bool writeIsReadyVariable; + bool readIsOpenVariable; + bool writeIsOpenVariable; + bool readIsFinishVariable; + bool writeIsFinishVariable; + bool readIsClosedVariable; + bool writeIsClosedVariable; + bool canBeMovedDirectlyVariable; + volatile bool stopIt; + volatile bool canStartTransfer; + int blockSize; + bool retry; + QFileInfo sourceInfo; + QFileInfo destinationInfo; + QStringList mountSysPoint; + qint64 size; + FileExistsAction fileExistsAction; + FileExistsAction alwaysDoFileExistsAction; + bool needSkip,needRemove; + QDateTime maxTime; + int id; + QSemaphore *mkpathTransfer; + //error management + bool writeError,writeError_source_seeked,writeError_destination_reopened; + bool readError; + //different pre-operation + bool isSame(); + bool destinationExists(); + bool canBeMovedDirectly(); + void tryMoveDirectly(); + void ifCanStartTransfer(); + //fonction to edit the file date time + bool changeFileDateTime(const QString &source,const QString &destination); + void resetExtraVariable(); + //error management function + void resumeTransferAfterWriteError(); + //to send state + bool sended_state_preOperationStopped; + bool sended_state_readStopped; + bool sended_state_writeStopped; + //different post-operation + bool checkIfAllIsClosed(); + bool doFilePostOperation(); + //different pre-operation + void tryOpen(); +}; + +#endif // TRANSFERTHREAD_H |