QFTP commandFinished отправлено слишком рано

QT версия 5.4.

Я пытаюсь загрузить все файлы из определенного каталога с помощью QFtp.

Иногда сигнал commandFinished (int, bool) отправляется слишком рано.

Я использую сигнал dataTransferProgress (qint64, qint64), чтобы проверить мой прогресс загрузки.

Когда это работает, у меня есть вывод, как:

Download 1
dataTransferProgress 0/150
dataTransferProgress 150/150
commandFinished
Dowload 2
dataTransferProgress 0/250
dataTransferProgress 250/250
commandFinished

И мои файлы в порядке

Когда это не работает, у меня есть:

Download 1
dataTransferProgress 0/150
commandFinished
Dowload 2
150/150
0/250
commandFinished

Файл 1 пуст.
Файл 2 содержит файл 1 данных.

Мой объект FTP

class ActionFTP : public QFtp
{

Q_OBJECT
public:ParamConnexion parametres;
QString FTP_export="exportX3_OFT/";
QString FTP_import="exportOFT_X3/";
QString FTP_historique="historique/";
QString OFT_export;
QString OFT_import;
QString OFT_historique;
QString ficConfig;
QFile *file;
QSettings *settings;

ActionFTP(QObject *parent = 0, QString fichierConfig = "config.ini", int detail = 0);
~ActionFTP();

bool recupFichier_X3_OFT(const QString&); // Function to download the File
bool ftpestdeconnecte(); // Check if my ftp is deconnected
void connecter(); // Connect me to the FTP
void deconnecter(); // Disconnect me from the FTP
void ContenuRepertoireFTP(); // List all the files in the FTP directory
bool getCommandEnCours(){return commandEnCours;} // Check if a command is already running
QList<QUrlInfo> getListePrete(){return listeFichiers;} // Return if the list of the
bool commandEnCours;

private :
int idEnCours;
QList<QUrlInfo> listeFichiers;

private slots:
void slot_append(QString info); // Get some informations
void ftpCommandFinished(int id, bool err);
void ftpCommandStarted(int id);
void remplirList(QUrlInfo);
void ftpdatatransferprogress(qint64, qint64);

signals :
void signal_connexionFaite(bool); // Send when I'm connected
void signal_deconnexionFaite(bool); // Send when I'm disconnected
void signal_append(QString infos); // Send some informations
void signal_listePrete(bool); // List ready
void fintransfertfichierrecup(); // When the get command is finished.
};

#endif // ACTIONFTP_H

.CPP

// I use a QSettings to get the different Path and the FTP Username/Login/Port/Host/TransferMode
ActionFTP::ActionFTP(QObject *parent, QString fichierConfig, int detail ) : QFtp(parent)
{
settings = new QSettings(fichierConfig, QSettings::IniFormat);
OFT_export=settings->value("Echange/DossierOFT").toString();
OFT_import=settings->value("Echange/DossierX3").toString();
OFT_historique=settings->value("Echange/DossierHistorique").toString();
connect(this, SIGNAL(signal_append(QString)),this,SLOT(slot_append(QString)));
connect(this, SIGNAL(commandFinished(int, bool)),this, SLOT(ftpCommandFinished(int, bool)));
connect(this,SIGNAL(commandStarted(int)), this, SLOT(ftpCommandStarted(int)));
connect(this, SIGNAL(listInfo(QUrlInfo)), this, SLOT(remplirList(QUrlInfo)));
connect(this, SIGNAL(dataTransferProgress(qint64,qint64)), this, SLOT(ftpdatatransferprogress(qint64, qint64)));
ficConfig=fichierConfig;
majParametres();

}void ActionFTP::ftpdatatransferprogress(qint64 un, qint64 deux){
qDebug()<<un<<deux;
}

ActionFTP::~ActionFTP()
{

}

bool ActionFTP::recupFichier_X3_OFT(const QString &fichier){
if(commandEnCours){ // A command is already running
QString infos = "Une commande est déjà en cours.";
emit signal_append(infos);
}
else{
file = new QFile(OFT_import+fichier);
if(file->exists())file->remove();

QString infos = "Demande de r�cup�ration du fichier " + FTP_export+fichier;
emit signal_append(infos);

qDebug()<<"return de file->open "<<file->open(QIODevice::ReadWrite); // Always return TRUE
get(FTP_export+fichier, file, Binary); // Get command
}
return true;
}void ActionFTP::slot_append(QString info){
qDebug()<<info;
}

bool ActionFTP::ftpestdeconnecte()
{
if (state()==QFtp::Unconnected)
return true;
return false;
}void ActionFTP::connecter() {
setTransferMode((QFtp::TransferMode)parametres.TransfertMode);
if(!commandEnCours)
connectToHost(parametres.Hostname, parametres.Port);
else{
QString infos = "Une commande est déjà en cours.";
emit signal_append(infos);
}
}

void ActionFTP::deconnecter() {
if(commandEnCours){
QString infos = "Une commande est déjà en cours.";
emit signal_append(infos);
}
else{
close();
}
}

void ActionFTP::remplirList(QUrlInfo t){
listeFichiers.push_back(t);
}

void ActionFTP::ContenuRepertoireFTP(){ //Ask the list of files name in the directory
if(commandEnCours){
QString infos = "Une commande est déjà en cours.";
emit signal_append(infos);
}
else{
listeFichiers.clear();
list(FTP_export);
}
}

void ActionFTP::ftpCommandStarted(int id){
idEnCours = id;
commandEnCours=true;
qDebug()<<"dans commandStarted "<<id;
}

void ActionFTP::ftpCommandFinished(int id, bool err) {
qDebug()<<"dans ftpCommandFinished"<<id<<err;
QString infos;
if(err) {
infos = QString(" Erreur lors de la commande %i de type %i").arg(id, currentCommand());
erreurFTP(infos);
}
else {
infos += " OK";
}
emit signal_append(infos);
if(idEnCours==id){
QString infos;

switch(currentCommand()) {
case QFtp::None :
break;
case QFtp::SetTransferMode :
break;
case QFtp::SetProxy :
break;
case QFtp::ConnectToHost :
if(!err)
login(parametres.UserName, parametres.Password);
else
emit signal_connexionFaite(err);
break;
case QFtp::Login :
commandEnCours = false;
emit signal_connexionFaite(err);
break;
case QFtp::Close :
commandEnCours = false; // Signifier qu'il n'y a plus de transfert en cours
emit signal_deconnexionFaite(err);
break;
case QFtp::List :
commandEnCours=false;
emit signal_listePrete(err);
break;
case QFtp::Cd :
break;
case QFtp::Get :
file->close();
file = 0;
commandEnCours = false; // Signifier qu'il n'y a plus de transfert en cours
emit fintransfertfichierrecup();
qDebug()<<"signal get emit";
break;
case QFtp::Put :
commandEnCours = false; // Signifier qu'il n'y a plus de transfert en cours
emit fintransfertfichierenvoi();
break;
case QFtp::Remove :
commandEnCours = false;
emit fintransfertfichiersuppr();
break;
case QFtp::Mkdir :
break;
case QFtp::Rmdir :
break;
case QFtp::Rename :
break;
case QFtp::RawCommand :
break;
default :
infos = "Commande inconnue !!";
}
idEnCours = 0;
}
}

Мой объект, который вызывает мой объект FTP

  class TacheEchanges : public QTimer
{
Q_OBJECT
public:
explicit TacheEchanges(QObject *parent = 0);

signals:

public slots:

private slots:
virtual void slot_check();

protected:

private:
ActionFTP *ftp; // My FTP object
QList<QUrlInfo> listDownload; // List of the files name
int indiceDownload; // Iteratorprivate slots:
void continuerDownload();  // When one file is downloaded
void connexionFaite(bool); // When I am connected to the FTP
void listePrete(bool); // When my command list is done

};

#endif // TACHEECHANGES_H

.CPP

TacheEchanges::TacheEchanges(GestionBdD_Hizkia* bdd, QObject *parent)
: QTimer(parent)
{

settings =new QSettings(FICHIERCONFIG, QSettings::IniFormat);try{

path_fichiersreference="";
path_poursage="";
path_historique="";
jobs = QList<Job>();
ftp = new ActionFTP(this, FICHIERCONFIG);

connect(this, SIGNAL(timeout()), this, SLOT(slot_check()));
connect(ftp,SIGNAL(fintransfertfichierenvoi()),this,SLOT(continuerUpload()));
connect(ftp, SIGNAL(signal_connexionFaite(bool)), this, SLOT(connexionFaite(bool)));
connect(ftp, SIGNAL(signal_listePrete(bool)), this, SLOT(listePrete(bool)));//Differente path
path_fichiersreference =settings->value("Echange/DossierX3").toString();
path_historique =settings->value("Echange/DossierHistorique").toString();
path_poursage=settings->value("Echange/DossierOFT").toString();
indiceDownload=0;

}

catch(ErreurGeneriqueException &e) {
desc.message = "TacheEchanges\n"+ e.what();
desc.niveau = NIVEAU_CRITIQUE;
InterfaceBdD::historiser(desc);
qDebug() << desc.message;

}

catch(...) {
//   QDebug() << "TacheEchanges\n" << e.get_message();desc.message = "TacheEchanges ERREUR INCONNUE";

desc.niveau = NIVEAU_CRITIQUE;
InterfaceBdD::historiser(desc);
qDebug() << desc.message;

}
}

// If i am connected, i try to get the list of files name
void TacheEchanges::connexionFaite(bool err){
if(err)
throw new ErreurGeneriqueException("Impossible de se connecter");
else
ftp->ContenuRepertoireFTP();
}

void TacheEchanges::slot_check()
{
ftp->connecter();
}

// I take the list and start the download
void TacheEchanges::listePrete(bool err){
if(!err){
listDownload = ftp->getListePrete();
continuerDownload();
}
else{
throw new ErreurBasiqueException("Un problème est survenu lors de la récupération de la liste des fichiers présents sur le FTP.");
}
}

void TacheEchanges::continuerDownload(){
if(indiceDownload==listDownload.size()){
indiceDownload=0;
continuerSuppression();
return;
}
else{
ftp->recupFichier_X3_OFT(listDownload.at(indiceDownload).name());
indiceDownload++;
}
}