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
|
/*
# Copyright (c) 2009 - OpenSLX Project, Computer Center University of Freiburg
#
# This program is free software distributed under the GPL version 2.
# See http://openslx.org/COPYING
#
# If you have any feedback please consult http://openslx.org/feedback and
# send your suggestions, praise, or complaints to feedback@openslx.org
#
# General information about OpenSLX can be found at http://openslx.org/
# -----------------------------------------------------------------------------
# src/net/pcsIncomingMulticastTransfer.h
# - wrap McastReceiver functionality in PVS daemon
# -----------------------------------------------------------------------------
*/
#ifndef PVSINCOMINGMULTICASTTRANSFER_H_
#define PVSINCOMINGMULTICASTTRANSFER_H_
#include <QObject>
#include <QString>
#include <src/net/pvsMsg.h>
class McastConfiguration;
class McastReceiver;
class QFile;
class QTimer;
class PVSIncomingMulticastTransfer : public QObject
{
Q_OBJECT
public:
PVSIncomingMulticastTransfer(QString const& sender, qulonglong transferID, qulonglong size, QString const& filename, ushort port,
McastConfiguration const* configTemplate, QObject* parent = 0);
virtual ~PVSIncomingMulticastTransfer();
void setFinalFile(QString const& filename);
signals:
void retry(QString const& sender, qulonglong transferID);
void started(qulonglong transferID);
void progress(qulonglong transferID, qulonglong bytes, qulonglong of);
void finished(qulonglong transferID);
void failed(qulonglong transferID, QString const& reason);
public slots:
void updatePort(ushort port);
bool start();
void abort();
private slots:
void receiverProgressed(quint64 bytes);
void receiverFinished(int reason);
void updateProgress();
void removeFile();
private:
QString _sender;
qulonglong _transferID;
qulonglong _bytes;
qulonglong _size;
ushort _port;
QFile* _file;
McastReceiver* _receiver;
McastConfiguration* _config;
bool _started;
QTimer* _progressTimer;
};
#endif /* PVSINCOMINGMULTICASTTRANSFER_H_ */
|
