blob: 537134aa5661888dee7021ed7023a5779b5b28fe (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
|
/** \file ReadThread.h
\brief Thread changed to open/close and read the source file
\author alpha_one_x86
\version 0.3
\date 2011 */
#ifndef READTHREAD_H
#define READTHREAD_H
#include <QThread>
#include <QByteArray>
#include <QSemaphore>
#include <QTimer>
#include <QDateTime>
#include <QFileInfo>
#include "WriteThread.h"
#include "Environment.h"
#include "StructEnumDefinition_CopyEngine.h"
#include "AvancedQFile.h"
/// \todo do fake open/close
/// \brief Thread changed to open/close and read the source file
class ReadThread : public QThread
{
Q_OBJECT
public:
explicit ReadThread();
~ReadThread();
protected:
void run();
public:
/// \brief open with the name and copy mode
void open(const QString &name,const CopyMode &mode);
/// \brief return the error string
QString errorString();
//QByteArray read(qint64 position,qint64 maxSize);
/// \brief stop the copy
void stop();
/// \brief put the copy in pause
bool pause();
/// \brief resume the copy
void resume();
/// \brief get the size of the source file
qint64 size();
/// \brief get the last good position
qint64 getLastGoodPosition();
/// \brief start the reading of the source file
void startRead();
/// \brief set the current max speed in KB/s
int setMaxSpeed(int maxSpeed);
/// \brief set block size in KB
bool setBlockSize(const int blockSize);
/// \brief reopen after an error
void reopen();
/// \brief set the write thread
void setWriteThread(WriteThread * writeThread);
#ifdef ULTRACOPIER_PLUGIN_DEBUG
/// \brief to set the id
void setId(int id);
/// \brief stat
enum ReadStat
{
Idle=0,
InodeOperation=1,
Read=2,
WaitWritePipe=3
};
ReadStat stat;
#endif
/// \brief return if it's reading
bool isReading();
/// \brief executed at regular interval to do a speed throling
void timeOfTheBlockCopyFinished();
/// \brief do the fake open
void fakeOpen();
/// \brief do the fake readIsStarted
void fakeReadIsStarted();
/// \brief do the fake readIsStopped
void fakeReadIsStopped();
public slots:
/// \brief to reset the copy, and put at the same state when it just open
void seekToZeroAndWait();
signals:
void error();
void isInPause();
void opened();
void readIsStarted();
void readIsStopped();
void closed();
void isSeekToZeroAndWait();
void checkIfIsWait();
void resumeAfterErrorByRestartAll();
void resumeAfterErrorByRestartAtTheLastPosition();
// internal signals
void internalStartOpen();
void internalStartReopen();
void internalStartRead();
void internalStartClose();
/// \brief To debug source
void debugInformation(DebugLevel level,QString fonction,QString text,QString file,int ligne);
private:
QString name;
QString errorString_internal;
AvancedQFile file;
volatile bool stopIt;
CopyMode mode;
qint64 lastGoodPosition;
volatile int blockSize;
volatile int maxSpeed; ///< The max speed in KB/s, 0 for no limit
QSemaphore waitNewClockForSpeed;
volatile int numberOfBlockCopied; ///< Multiple for count the number of block copied
volatile int multiplicatorForBigSpeed; ///< Multiple for count the number of block needed
volatile int MultiForBigSpeed;
WriteThread* writeThread;
int id;
QSemaphore isOpen;
volatile bool putInPause;
volatile bool isInReadLoop;
volatile bool seekToZero;
volatile bool tryStartRead;
qint64 size_at_open;
QDateTime mtime_at_open;
bool fakeMode;
//internal function
bool seek(qint64 position);/// \todo search if is use full
private slots:
bool internalOpen(bool resetLastGoodPosition=true);
bool internalReopen();
void internalRead();
void internalClose(bool callByTheDestructor=false);
void postOperation();
void isInWait();
};
#endif // READTHREAD_H
|
