diff options
Diffstat (limited to 'LogThread.cpp')
| -rw-r--r-- | LogThread.cpp | 397 |
1 files changed, 233 insertions, 164 deletions
diff --git a/LogThread.cpp b/LogThread.cpp index 9064b07..4af7550 100644 --- a/LogThread.cpp +++ b/LogThread.cpp @@ -1,222 +1,291 @@ /** \file LogThread.cpp \brief The thread to do the log but not block the main thread \author alpha_one_x86 -\version 0.3 -\date 2010 \licence GPL3, see the file COPYING */ #include "LogThread.h" +#include "ResourcesManager.h" +#include "OptionEngine.h" +#ifdef Q_OS_WIN32 + #ifndef NOMINMAX + #define NOMINMAX + #endif + #include <windows.h> +#endif #include <QMessageBox> +QString LogThread::text_header_copy=QStringLiteral("[Copy] "); +QString LogThread::text_header_move=QStringLiteral("[Move] "); +QString LogThread::text_header_skip=QStringLiteral("[Skip] "); +QString LogThread::text_header_stop=QStringLiteral("[Stop] "); +QString LogThread::text_header_error=QStringLiteral("[Error] "); +QString LogThread::text_header_MkPath=QStringLiteral("[MkPath] "); +QString LogThread::text_header_RmPath=QStringLiteral("[RmPath] "); + +QString LogThread::text_var_source=QStringLiteral("%source%"); +QString LogThread::text_var_size=QStringLiteral("%size%"); +QString LogThread::text_var_destination=QStringLiteral("%destination%"); +QString LogThread::text_var_path=QStringLiteral("%path%"); +QString LogThread::text_var_error=QStringLiteral("%error%"); +QString LogThread::text_var_mtime=QStringLiteral("%mtime%"); +QString LogThread::text_var_time=QStringLiteral("%time%"); +QString LogThread::text_var_timestring=QStringLiteral("%dd.MM.yyyy h:m:s%"); +#ifdef Q_OS_WIN32 +QString LogThread::text_var_computer=QStringLiteral("%computer%"); +QString LogThread::text_var_user=QStringLiteral("%user%"); +#endif +QString LogThread::text_var_operation=QStringLiteral("%operation%"); +QString LogThread::text_var_rmPath=QStringLiteral("%rmPath%"); +QString LogThread::text_var_mkPath=QStringLiteral("%mkPath%"); + LogThread::LogThread() { - sync=false; - - //load the GUI option - QString defaultLogFile=""; - if(resources->getWritablePath()!="") - defaultLogFile=resources->getWritablePath()+"ultracopier-files.log"; - QList<QPair<QString, QVariant> > KeysList; - KeysList.append(qMakePair(QString("enabled"),QVariant(false))); - KeysList.append(qMakePair(QString("file"),QVariant(defaultLogFile))); - KeysList.append(qMakePair(QString("transfer"),QVariant(true))); - KeysList.append(qMakePair(QString("error"),QVariant(true))); - KeysList.append(qMakePair(QString("folder"),QVariant(true))); - KeysList.append(qMakePair(QString("sync"),QVariant(true))); - KeysList.append(qMakePair(QString("transfer_format"),QVariant("[%time%] %source% (%size%) %destination%"))); - KeysList.append(qMakePair(QString("error_format"),QVariant("[%time%] %path%, %error%"))); - KeysList.append(qMakePair(QString("folder_format"),QVariant("[%time%] %operation% %path%"))); - options->addOptionGroup("Write_log",KeysList); - - connect(options,SIGNAL(newOptionValue(QString,QString,QVariant)), this, SLOT(newOptionValue(QString,QString,QVariant))); - - enabled=false; - - moveToThread(this); - start(QThread::IdlePriority); - - connect(this, SIGNAL(newData(QString)), this,SLOT(realDataWrite(QString)),Qt::QueuedConnection); - - newOptionValue("Write_log", "transfer", options->getOptionValue("Write_log","transfer")); - newOptionValue("Write_log", "error", options->getOptionValue("Write_log","error")); - newOptionValue("Write_log", "folder", options->getOptionValue("Write_log","folder")); - newOptionValue("Write_log", "sync", options->getOptionValue("Write_log","sync")); - newOptionValue("Write_log", "transfer_format", options->getOptionValue("Write_log","transfer_format")); - newOptionValue("Write_log", "error_format", options->getOptionValue("Write_log","error_format")); - newOptionValue("Write_log", "folder_format", options->getOptionValue("Write_log","folder_format")); - newOptionValue("Write_log", "sync", options->getOptionValue("Write_log","sync")); - newOptionValue("Write_log", "enabled", options->getOptionValue("Write_log","enabled")); + sync=false; + + connect(OptionEngine::optionEngine,&OptionEngine::newOptionValue, this, &LogThread::newOptionValue); + + enabled=false; + + moveToThread(this); + start(QThread::IdlePriority); + + connect(this, &LogThread::newData, this,&LogThread::realDataWrite,Qt::QueuedConnection); + + newOptionValue(QStringLiteral("Write_log"), QStringLiteral("transfer"), OptionEngine::optionEngine->getOptionValue(QStringLiteral("Write_log"),QStringLiteral("transfer"))); + newOptionValue(QStringLiteral("Write_log"), QStringLiteral("error"), OptionEngine::optionEngine->getOptionValue(QStringLiteral("Write_log"),QStringLiteral("error"))); + newOptionValue(QStringLiteral("Write_log"), QStringLiteral("folder"), OptionEngine::optionEngine->getOptionValue(QStringLiteral("Write_log"),QStringLiteral("folder"))); + newOptionValue(QStringLiteral("Write_log"), QStringLiteral("sync"), OptionEngine::optionEngine->getOptionValue(QStringLiteral("Write_log"),QStringLiteral("sync"))); + newOptionValue(QStringLiteral("Write_log"), QStringLiteral("transfer_format"), OptionEngine::optionEngine->getOptionValue(QStringLiteral("Write_log"),QStringLiteral("transfer_format"))); + newOptionValue(QStringLiteral("Write_log"), QStringLiteral("error_format"), OptionEngine::optionEngine->getOptionValue(QStringLiteral("Write_log"),QStringLiteral("error_format"))); + newOptionValue(QStringLiteral("Write_log"), QStringLiteral("folder_format"), OptionEngine::optionEngine->getOptionValue(QStringLiteral("Write_log"),QStringLiteral("folder_format"))); + newOptionValue(QStringLiteral("Write_log"), QStringLiteral("sync"), OptionEngine::optionEngine->getOptionValue(QStringLiteral("Write_log"),QStringLiteral("sync"))); + newOptionValue(QStringLiteral("Write_log"), QStringLiteral("enabled"), OptionEngine::optionEngine->getOptionValue(QStringLiteral("Write_log"),QStringLiteral("enabled"))); + #ifdef Q_OS_WIN32 + DWORD size=0; + WCHAR * computerNameW=new WCHAR[size]; + if(GetComputerNameW(computerNameW,&size)) + computer=QString::fromWCharArray(computerNameW,size-1); + else + computer=QStringLiteral("Unknown computer"); + delete computerNameW; + + WCHAR * userNameW=new WCHAR[size]; + if(GetUserNameW(userNameW,&size)) + user=QString::fromWCharArray(userNameW,size-1); + else + user=QStringLiteral("Unknown user"); + delete userNameW; + #endif + + #ifdef Q_OS_WIN32 + lineReturn=QStringLiteral("\r\n"); + #else + lineReturn=QStringLiteral("\n"); + #endif } LogThread::~LogThread() { - closeLogs(); - quit(); - wait(); + closeLogs(); + quit(); + wait(); +} + +bool LogThread::logTransfer() const +{ + return enabled && log_enable_transfer; } void LogThread::openLogs() { - if(options->getOptionValue("Write_log","enabled").toBool()==false) - return; - if(log.isOpen()) - { - QMessageBox::critical(NULL,tr("Error"),tr("Log file already open, error: %1").arg(log.errorString())); - ULTRACOPIER_DEBUGCONSOLE(DebugLevel_Warning,QString("log file already open, error: %1").arg(log.errorString())); - return; - } - log.setFileName(options->getOptionValue("Write_log","file").toString()); - if(sync) - { - if(!log.open(QIODevice::WriteOnly|QIODevice::Unbuffered)) - { - QMessageBox::critical(NULL,tr("Error"),tr("Unable to open file to keep the log file, error: %1").arg(log.errorString())); - ULTRACOPIER_DEBUGCONSOLE(DebugLevel_Warning,QString("Unable to open file to keep the log file, error: %1").arg(log.errorString())); - } - else - ULTRACOPIER_DEBUGCONSOLE(DebugLevel_Notice,"opened log: "+options->getOptionValue("Write_log","file").toString()); - } - else - { - if(!log.open(QIODevice::WriteOnly)) - { - QMessageBox::critical(NULL,tr("Error"),tr("Unable to open file to keep the log file, error: %1").arg(log.errorString())); - ULTRACOPIER_DEBUGCONSOLE(DebugLevel_Warning,QString("Unable to open file to keep the log file, error: %1").arg(log.errorString())); - } - else - ULTRACOPIER_DEBUGCONSOLE(DebugLevel_Notice,"opened log: "+options->getOptionValue("Write_log","file").toString()); - } + if(OptionEngine::optionEngine->getOptionValue(QStringLiteral("Write_log"),QStringLiteral("enabled")).toBool()==false) + return; + if(log.isOpen()) + { + QMessageBox::critical(NULL,tr("Error"),tr("Log file already open, error: %1").arg(log.errorString())); + ULTRACOPIER_DEBUGCONSOLE(Ultracopier::DebugLevel_Warning,QString("log file already open, error: %1").arg(log.errorString())); + return; + } + log.setFileName(OptionEngine::optionEngine->getOptionValue("Write_log","file").toString()); + if(sync) + { + if(!log.open(QIODevice::WriteOnly|QIODevice::Unbuffered)) + { + QMessageBox::critical(NULL,tr("Error"),tr("Unable to open the log file, error: %1").arg(log.errorString())); + ULTRACOPIER_DEBUGCONSOLE(Ultracopier::DebugLevel_Warning,QString("Unable to open the log file, error: %1").arg(log.errorString())); + } + else + ULTRACOPIER_DEBUGCONSOLE(Ultracopier::DebugLevel_Notice,"opened log: "+OptionEngine::optionEngine->getOptionValue("Write_log","file").toString()); + } + else + { + if(!log.open(QIODevice::WriteOnly)) + { + QMessageBox::critical(NULL,tr("Error"),tr("Unable to open the log file, error: %1").arg(log.errorString())); + ULTRACOPIER_DEBUGCONSOLE(Ultracopier::DebugLevel_Warning,QString("Unable to open the log file, error: %1").arg(log.errorString())); + } + else + ULTRACOPIER_DEBUGCONSOLE(Ultracopier::DebugLevel_Notice,QStringLiteral("opened log: ")+OptionEngine::optionEngine->getOptionValue(QStringLiteral("Write_log"),QStringLiteral("file")).toString()); + } } void LogThread::closeLogs() { - if(log.isOpen() && data.size()>0) - log.write(data.toUtf8()); - log.close(); + if(log.isOpen() && data.size()>0) + log.write(data.toUtf8()); + log.close(); } -void LogThread::newTransferStart(const ItemOfCopyList &item) +void LogThread::newTransferStart(const Ultracopier::ItemOfCopyList &item) { - if(!log_enable_transfer) - return; - QString text=transfer_format+"\n"; - text=replaceBaseVar(text); - //Variable is %source%, %size%, %destination% - text=text.replace("%source%",item.sourceFullPath); - text=text.replace("%size%",QString::number(item.size)); - text=text.replace("%destination%",item.destinationFullPath); - emit newData(text); + if(!logTransfer()) + return; + QString text; + if(item.mode==Ultracopier::Copy) + text=LogThread::text_header_copy+transfer_format+lineReturn; + else + text=LogThread::text_header_move+transfer_format+lineReturn; + text=replaceBaseVar(text); + //Variable is %source%, %size%, %destination% + text=text.replace(LogThread::text_var_source,item.sourceFullPath); + text=text.replace(LogThread::text_var_size,QString::number(item.size)); + text=text.replace(LogThread::text_var_destination,item.destinationFullPath); + emit newData(text); } -void LogThread::newTransferStop(const quint64 &id) +/** method called when new transfer is started */ +void LogThread::transferSkip(const Ultracopier::ItemOfCopyList &item) { - if(!log_enable_transfer) - return; - Q_UNUSED(id) + if(!logTransfer()) + return; + QString text=LogThread::text_header_skip+transfer_format+lineReturn; + text=replaceBaseVar(text); + //Variable is %source%, %size%, %destination% + text=text.replace(LogThread::text_var_source,item.sourceFullPath); + text=text.replace(LogThread::text_var_size,QString::number(item.size)); + text=text.replace(LogThread::text_var_destination,item.destinationFullPath); + emit newData(text); +} + +void LogThread::newTransferStop(const Ultracopier::ItemOfCopyList &item) +{ + if(!logTransfer()) + return; + QString text=LogThread::text_header_stop+transfer_format+lineReturn; + text=replaceBaseVar(text); + //Variable is %source%, %size%, %destination% + text=text.replace(LogThread::text_var_source,item.sourceFullPath); + text=text.replace(LogThread::text_var_size,QString::number(item.size)); + text=text.replace(LogThread::text_var_destination,item.destinationFullPath); + emit newData(text); } void LogThread::error(const QString &path,const quint64 &size,const QDateTime &mtime,const QString &error) { - if(!log_enable_error) - return; - QString text=error_format+"\n"; - text=replaceBaseVar(text); - //Variable is %path%, %size%, %mtime%, %error% - text=text.replace("%path%",path); - text=text.replace("%size%",QString::number(size)); - text=text.replace("%mtime%",mtime.toString(Qt::ISODate)); - text=text.replace("%error%",error); - emit newData(text); + if(!log_enable_error) + return; + QString text=LogThread::text_header_error+error_format+lineReturn; + text=replaceBaseVar(text); + //Variable is %path%, %size%, %mtime%, %error% + text=text.replace(LogThread::text_var_path,path); + text=text.replace(LogThread::text_var_size,QString::number(size)); + text=text.replace(LogThread::text_var_mtime,mtime.toString(Qt::ISODate)); + text=text.replace(LogThread::text_var_error,error); + emit newData(text); } void LogThread::run() { - exec(); + exec(); } void LogThread::realDataWrite(const QString &text) { - #ifdef ULTRACOPIER_DEBUG - if(!log.isOpen()) - { - ULTRACOPIER_DEBUGCONSOLE(DebugLevel_Critical,"transfer log not open"); - return; - } - #endif // ULTRACOPIER_DEBUG - ULTRACOPIER_DEBUGCONSOLE(DebugLevel_Notice,"start"); - if(log.write(text.toUtf8())==-1) - { - ULTRACOPIER_DEBUGCONSOLE(DebugLevel_Warning,QString("unable to write into transfer log: %1").arg(log.errorString())); - return; - } - if(sync) - log.flush(); + #ifdef ULTRACOPIER_DEBUG + if(!log.isOpen()) + { + ULTRACOPIER_DEBUGCONSOLE(Ultracopier::DebugLevel_Critical,"transfer log not open"); + return; + } + #endif // ULTRACOPIER_DEBUG + ULTRACOPIER_DEBUGCONSOLE(Ultracopier::DebugLevel_Notice,QStringLiteral("start")); + if(log.write(text.toUtf8())==-1) + { + ULTRACOPIER_DEBUGCONSOLE(Ultracopier::DebugLevel_Warning,QString("unable to write into transfer log: %1").arg(log.errorString())); + return; + } + if(sync) + log.flush(); } void LogThread::newOptionValue(const QString &group,const QString &name,const QVariant &value) { - if(group!="Write_log") - return; - - if(name=="transfer_format") - transfer_format=value.toString(); - else if(name=="error_format") - error_format=value.toString(); - else if(name=="folder_format") - folder_format=value.toString(); - else if(name=="sync") - { - sync=value.toBool(); - ULTRACOPIER_DEBUGCONSOLE(DebugLevel_Notice,QString("sync flag is set on: %1").arg(sync)); - if(sync) - { - if(log.isOpen()) - log.flush(); - } - } - else if(name=="transfer") - log_enable_transfer=options->getOptionValue("Write_log","enabled").toBool() && value.toBool(); - else if(name=="error") - log_enable_error=options->getOptionValue("Write_log","enabled").toBool() && value.toBool(); - else if(name=="folder") - log_enable_folder=options->getOptionValue("Write_log","enabled").toBool() && value.toBool(); - if(name=="enabled") - { - enabled=value.toBool(); - if(enabled) - openLogs(); - else - closeLogs(); - } + if(group!=QStringLiteral("Write_log")) + return; + + if(name==QStringLiteral("transfer_format")) + transfer_format=value.toString(); + else if(name==QStringLiteral("error_format")) + error_format=value.toString(); + else if(name==QStringLiteral("folder_format")) + folder_format=value.toString(); + else if(name==QStringLiteral("sync")) + { + sync=value.toBool(); + ULTRACOPIER_DEBUGCONSOLE(Ultracopier::DebugLevel_Notice,QString("sync flag is set on: %1").arg(sync)); + if(sync) + { + if(log.isOpen()) + log.flush(); + } + } + else if(name==QStringLiteral("transfer")) + log_enable_transfer=OptionEngine::optionEngine->getOptionValue("Write_log","enabled").toBool() && value.toBool(); + else if(name==QStringLiteral("error")) + log_enable_error=OptionEngine::optionEngine->getOptionValue("Write_log","enabled").toBool() && value.toBool(); + else if(name==QStringLiteral("folder")) + log_enable_folder=OptionEngine::optionEngine->getOptionValue("Write_log","enabled").toBool() && value.toBool(); + if(name==QStringLiteral("enabled")) + { + enabled=value.toBool(); + if(enabled) + openLogs(); + else + closeLogs(); + } } QString LogThread::replaceBaseVar(QString text) { - text=text.replace("%time%",QDateTime::currentDateTime().toString("dd.MM.yyyy h:m:s")); - return text; + text=text.replace(LogThread::text_var_time,QDateTime::currentDateTime().toString(LogThread::text_var_timestring)); + #ifdef Q_OS_WIN32 + text=text.replace(LogThread::text_var_computer,computer); + text=text.replace(LogThread::text_var_user,user); + #endif + return text; } void LogThread::rmPath(const QString &path) { - if(!log_enable_folder) - return; - QString text=folder_format+"\n"; - text=replaceBaseVar(text); - //Variable is %operation% %path% - text=text.replace("%path%",path); - text=text.replace("%operation%","rmPath"); - emit newData(text); + if(!logTransfer()) + return; + QString text=LogThread::text_header_RmPath+folder_format+lineReturn; + text=replaceBaseVar(text); + //Variable is %operation% %path% + text=text.replace(LogThread::text_var_path,path); + text=text.replace(LogThread::text_var_operation,LogThread::text_var_rmPath); + emit newData(text); } void LogThread::mkPath(const QString &path) { - if(!log_enable_folder) - return; - QString text=folder_format+"\n"; - text=replaceBaseVar(text); - //Variable is %operation% %path% - text=text.replace("%path%",path); - text=text.replace("%operation%","mkPath"); - emit newData(text); + if(!logTransfer()) + return; + QString text=LogThread::text_header_MkPath+folder_format+lineReturn; + text=replaceBaseVar(text); + //Variable is %operation% %path% + text=text.replace(LogThread::text_var_path,path); + text=text.replace(LogThread::text_var_operation,LogThread::text_var_mkPath); + emit newData(text); } |