1 ///////////////////////////////////////////////////////////////////////////////
2 // LameXP - Audio Encoder Front-End
3 // Copyright (C) 2004-2012 LoRd_MuldeR <MuldeR2@GMX.de>
5 // This program is free software; you can redistribute it and/or modify
6 // it under the terms of the GNU General Public License as published by
7 // the Free Software Foundation; either version 2 of the License, or
8 // (at your option) any later version.
10 // This program is distributed in the hope that it will be useful,
11 // but WITHOUT ANY WARRANTY; without even the implied warranty of
12 // MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
13 // GNU General Public License for more details.
15 // You should have received a copy of the GNU General Public License along
16 // with this program; if not, write to the Free Software Foundation, Inc.,
17 // 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA.
19 // http://www.gnu.org/licenses/gpl-2.0.txt
20 ///////////////////////////////////////////////////////////////////////////////
22 #include "Thread_FileAnalyzer.h"
25 #include "LockedFile.h"
26 #include "Model_AudioFile.h"
27 #include "Thread_FileAnalyzer_Task.h"
36 #include <QThreadPool>
39 ////////////////////////////////////////////////////////////
41 ////////////////////////////////////////////////////////////
43 FileAnalyzer::FileAnalyzer(const QStringList &inputFiles)
46 m_inputFiles(inputFiles),
53 FileAnalyzer::~FileAnalyzer(void)
57 QString templatePath = m_templateFile->filePath();
58 LAMEXP_DELETE(m_templateFile);
59 if(QFile::exists(templatePath)) QFile::remove(templatePath);
65 ////////////////////////////////////////////////////////////
67 ////////////////////////////////////////////////////////////
69 const char *FileAnalyzer::g_tags_gen[] =
78 "Artist", "Performer",
81 "Released_Date", "Recorded_Date",
90 const char *FileAnalyzer::g_tags_aud[] =
105 ////////////////////////////////////////////////////////////
107 ////////////////////////////////////////////////////////////
109 void FileAnalyzer::run()
116 int nFiles = m_inputFiles.count();
118 emit progressMaxChanged(nFiles);
119 emit progressValChanged(0);
125 if(!createTemplate())
127 qWarning("Failed to create template file!");
132 AnalyzeTask::reset();
133 QThreadPool *pool = new QThreadPool();
134 QThread::msleep(333);
136 if(QThread::idealThreadCount() > 1)
138 pool->setMaxThreadCount((QThread::idealThreadCount() * 3) / 2);
142 pool->setMaxThreadCount(2);
145 while(!(m_inputFiles.isEmpty() || m_bAborted))
147 while(!(m_inputFiles.isEmpty() || m_bAborted))
149 const QString currentFile = QDir::fromNativeSeparators(m_inputFiles.takeFirst());
151 AnalyzeTask *task = new AnalyzeTask(currentFile, m_templateFile->filePath(), &m_abortFlag);
152 connect(task, SIGNAL(fileSelected(QString)), this, SIGNAL(fileSelected(QString)), Qt::DirectConnection);
153 connect(task, SIGNAL(progressValChanged(unsigned int)), this, SIGNAL(progressValChanged(unsigned int)), Qt::DirectConnection);
154 connect(task, SIGNAL(progressMaxChanged(unsigned int)), this, SIGNAL(progressMaxChanged(unsigned int)), Qt::DirectConnection);
155 connect(task, SIGNAL(fileAnalyzed(AudioFileModel)), this, SIGNAL(fileAnalyzed(AudioFileModel)), Qt::DirectConnection);
157 while(!pool->tryStart(task))
159 if(!AnalyzeTask::waitForOneThread(1250))
161 qWarning("FileAnalyzer: Timeout, retrying!");
170 QThread::yieldCurrentThread();
175 MessageBeep(MB_ICONERROR);
180 if(int count = AnalyzeTask::getAdditionalFiles(m_inputFiles))
182 emit progressMaxChanged(nFiles += count);
188 //One of the Analyze tasks may have gathered additional files from a playlist!
192 if(int count = AnalyzeTask::getAdditionalFiles(m_inputFiles))
194 emit progressMaxChanged(nFiles += count);
204 qWarning("Operation cancelled by user!");
208 qDebug("All files added.\n");
212 ////////////////////////////////////////////////////////////
214 ////////////////////////////////////////////////////////////
216 bool FileAnalyzer::createTemplate(void)
220 qWarning("Template file already exists!");
224 QString templatePath = QString("%1/%2.txt").arg(lamexp_temp_folder2(), lamexp_rand_str());
226 QFile templateFile(templatePath);
227 if(!templateFile.open(QIODevice::WriteOnly))
232 templateFile.write("General;");
233 for(size_t i = 0; g_tags_gen[i]; i++)
235 templateFile.write(QString("Gen_%1=%%1%\\n").arg(g_tags_gen[i]).toLatin1().constData());
237 templateFile.write("\\n\r\n");
239 templateFile.write("Audio;");
240 for(size_t i = 0; g_tags_aud[i]; i++)
242 templateFile.write(QString("Aud_%1=%%1%\\n").arg(g_tags_aud[i]).toLatin1().constData());
244 templateFile.write("\\n\r\n");
246 bool success = (templateFile.error() == QFile::NoError);
247 templateFile.close();
251 QFile::remove(templatePath);
257 m_templateFile = new LockedFile(templatePath);
261 qWarning("Failed to lock template file!");
268 ////////////////////////////////////////////////////////////
270 ////////////////////////////////////////////////////////////
272 unsigned int FileAnalyzer::filesAccepted(void)
274 return AnalyzeTask::filesAccepted();
277 unsigned int FileAnalyzer::filesRejected(void)
279 return AnalyzeTask::filesRejected();
282 unsigned int FileAnalyzer::filesDenied(void)
284 return AnalyzeTask::filesDenied();
287 unsigned int FileAnalyzer::filesDummyCDDA(void)
289 return AnalyzeTask::filesDummyCDDA();
292 unsigned int FileAnalyzer::filesCueSheet(void)
294 return AnalyzeTask::filesCueSheet();
297 ////////////////////////////////////////////////////////////
299 ////////////////////////////////////////////////////////////