]> git.sesse.net Git - kdenlive/blob - src/kthumb.cpp
Fix crash on thumb generation:
[kdenlive] / src / kthumb.cpp
1 /***************************************************************************
2                         krender.cpp  -  description
3                            -------------------
4   begin                : Fri Nov 22 2002
5   copyright            : (C) 2002 by Jason Wood
6   email                : jasonwood@blueyonder.co.uk
7   copyright            : (C) 2005 Lcio Fl�io Corr�
8   email                : lucio.correa@gmail.com
9   copyright            : (C) Marco Gittler
10   email                : g.marco@freenet.de
11
12 ***************************************************************************/
13
14 /***************************************************************************
15  *                                                                         *
16  *   This program is free software; you can redistribute it and/or modify  *
17  *   it under the terms of the GNU General Public License as published by  *
18  *   the Free Software Foundation; either version 2 of the License, or     *
19  *   (at your option) any later version.                                   *
20  *                                                                         *
21  ***************************************************************************/
22
23 #include "kthumb.h"
24 #include "clipmanager.h"
25 #include "renderer.h"
26 #include "kdenlivesettings.h"
27
28 #include <mlt++/Mlt.h>
29
30 #include <kio/netaccess.h>
31 #include <kdebug.h>
32 #include <klocale.h>
33 #include <kfileitem.h>
34 #include <kmessagebox.h>
35 #include <KStandardDirs>
36
37 #include <qxml.h>
38 #include <QImage>
39 #include <QApplication>
40 #include <QtConcurrentRun>
41
42 void MyThread::init(KUrl url, QString target, double frame, double frameLength, int frequency, int channels, int arrayWidth)
43 {
44     stop_me = false;
45     m_isWorking = false;
46     f.setFileName(target);
47     m_url = url;
48     m_frame = frame;
49     m_frameLength = frameLength;
50     m_frequency = frequency;
51     m_channels = channels;
52     m_arrayWidth = arrayWidth;
53 }
54
55 bool MyThread::isWorking()
56 {
57     return m_isWorking;
58 }
59
60 void MyThread::run()
61 {
62     if (!f.open(QIODevice::WriteOnly)) {
63         kDebug() << "++++++++  ERROR WRITING TO FILE: " << f.fileName() << endl;
64         kDebug() << "++++++++  DISABLING AUDIO THUMBS" << endl;
65         KdenliveSettings::setAudiothumbnails(false);
66         return;
67     }
68     m_isWorking = true;
69     Mlt::Profile prof((char*) KdenliveSettings::current_profile().toUtf8().data());
70     Mlt::Producer m_producer(prof, m_url.path().toUtf8().data());
71
72
73     if (KdenliveSettings::normaliseaudiothumbs()) {
74         Mlt::Filter m_convert(prof, "volume");
75         m_convert.set("gain", "normalise");
76         m_producer.attach(m_convert);
77     }
78
79     int last_val = 0;
80     int val = 0;
81     kDebug() << "for " << m_frame << " " << m_frameLength << " " << m_producer.is_valid();
82     for (int z = (int) m_frame; z < (int)(m_frame + m_frameLength) && m_producer.is_valid(); z++) {
83         if (stop_me) break;
84         val = (int)((z - m_frame) / (m_frame + m_frameLength) * 100.0);
85         if (last_val != val && val > 1) {
86             emit audioThumbProgress(val);
87             last_val = val;
88         }
89         m_producer.seek(z);
90         Mlt::Frame *mlt_frame = m_producer.get_frame();
91         if (mlt_frame && mlt_frame->is_valid()) {
92             double m_framesPerSecond = mlt_producer_get_fps(m_producer.get_producer());
93             int m_samples = mlt_sample_calculator(m_framesPerSecond, m_frequency, mlt_frame_get_position(mlt_frame->get_frame()));
94             mlt_audio_format m_audioFormat = mlt_audio_pcm;
95             qint16* m_pcm = static_cast<qint16*>(mlt_frame->get_audio(m_audioFormat, m_frequency, m_channels, m_samples));
96
97             for (int c = 0; c < m_channels; c++) {
98                 QByteArray m_array;
99                 m_array.resize(m_arrayWidth);
100                 for (int i = 0; i < m_array.size(); i++) {
101                     m_array[i] = ((*(m_pcm + c + i * m_samples / m_array.size())) >> 9) + 127 / 2 ;
102                 }
103                 f.write(m_array);
104
105             }
106         } else {
107             f.write(QByteArray(m_arrayWidth, '\x00'));
108         }
109         delete mlt_frame;
110     }
111     //kDebug() << "done";
112     f.close();
113     m_isWorking = false;
114     if (stop_me) {
115         f.remove();
116     } else emit audioThumbOver();
117 }
118
119
120 KThumb::KThumb(ClipManager *clipManager, KUrl url, const QString &id, const QString &hash, QObject * parent, const char */*name*/) :
121         QObject(parent),
122         m_audioThumbProducer(),
123         m_url(url),
124         m_thumbFile(),
125         m_dar(1),
126         m_producer(NULL),
127         m_clipManager(clipManager),
128         m_id(id)
129 {
130     m_thumbFile = clipManager->projectFolder() + "/thumbs/" + hash + ".thumb";
131     connect(&m_audioThumbProducer, SIGNAL(audioThumbProgress(const int)), this, SLOT(slotAudioThumbProgress(const int)));
132     connect(&m_audioThumbProducer, SIGNAL(audioThumbOver()), this, SLOT(slotAudioThumbOver()));
133 }
134
135 KThumb::~KThumb()
136 {
137     m_requestedThumbs.clear();
138     if (m_audioThumbProducer.isRunning()) {
139         m_audioThumbProducer.stop_me = true;
140         m_audioThumbProducer.wait();
141         slotAudioThumbOver();
142     }
143     m_future.waitForFinished();
144 }
145
146 void KThumb::setProducer(Mlt::Producer *producer)
147 {
148     m_requestedThumbs.clear();
149     m_future.waitForFinished();
150     m_producer = producer;
151     // FIXME: the profile() call leaks an object, but trying to free
152     // it leads to a double-free in Profile::~Profile()
153     m_dar = producer->profile()->dar();
154 }
155
156 void KThumb::clearProducer()
157 {
158     m_producer = NULL;
159 }
160
161 bool KThumb::hasProducer() const
162 {
163     return m_producer != NULL;
164 }
165
166 void KThumb::updateThumbUrl(const QString &hash)
167 {
168     m_thumbFile = m_clipManager->projectFolder() + "/thumbs/" + hash + ".thumb";
169 }
170
171 void KThumb::updateClipUrl(KUrl url, const QString &hash)
172 {
173     m_url = url;
174     if (m_producer) {
175         char *tmp = Render::decodedString(url.path());
176         m_producer->set("resource", tmp);
177         delete[] tmp;
178     }
179     m_thumbFile = m_clipManager->projectFolder() + "/thumbs/" + hash + ".thumb";
180 }
181
182 //static
183 QPixmap KThumb::getImage(KUrl url, int width, int height)
184 {
185     if (url.isEmpty()) return QPixmap();
186     return getImage(url, 0, width, height);
187 }
188
189 void KThumb::extractImage(int frame, int frame2)
190 {
191     if (!KdenliveSettings::videothumbnails() || m_producer == NULL) return;
192     if (frame != -1 && !m_requestedThumbs.contains(frame)) m_requestedThumbs.append(frame);
193     if (frame2 != -1 && !m_requestedThumbs.contains(frame2)) m_requestedThumbs.append(frame2);
194     if (!m_future.isRunning()) m_future = QtConcurrent::run(this, &KThumb::doGetThumbs);
195 }
196
197 void KThumb::doGetThumbs()
198 {
199     const int theight = KdenliveSettings::trackheight();
200     const int twidth = (int)(theight * m_dar + 0.5);
201
202     while (!m_requestedThumbs.isEmpty()) {
203         int frame = m_requestedThumbs.takeFirst();
204         if (frame != -1) {
205             QImage img = getFrame(m_producer, frame, twidth, theight);
206             emit thumbReady(frame, img);
207         }
208     }
209 }
210
211 QPixmap KThumb::extractImage(int frame, int width, int height)
212 {
213     return QPixmap::fromImage(getFrame(m_producer, frame, width, height));
214 }
215
216 //static
217 QPixmap KThumb::getImage(KUrl url, int frame, int width, int height)
218 {
219     char *tmp = Render::decodedString(KdenliveSettings::current_profile());
220     Mlt::Profile profile(tmp);
221     delete[] tmp;
222     QPixmap pix(width, height);
223     if (url.isEmpty()) return pix;
224
225     tmp = Render::decodedString(url.path());
226     //"<mlt><playlist><producer resource=\"" + url.path() + "\" /></playlist></mlt>");
227     //Mlt::Producer producer(profile, "xml-string", tmp);
228     Mlt::Producer *producer = new Mlt::Producer(profile, tmp);
229     delete[] tmp;
230
231     pix = QPixmap::fromImage(getFrame(producer, frame, width, height));
232     delete producer;
233     return pix;
234 }
235
236
237 //static
238 QImage KThumb::getFrame(Mlt::Producer *producer, int framepos, int width, int height)
239 {
240     QImage p(width, height, QImage::Format_ARGB32);
241     if (producer == NULL) {
242         p.fill(Qt::red);
243         return p;
244     }
245
246     if (producer->is_blank()) {
247         p.fill(Qt::black);
248         return p;
249     }
250
251     producer->seek(framepos);
252     Mlt::Frame *frame = producer->get_frame();
253     if (!frame) {
254         kDebug() << "///// BROKEN FRAME";
255         p.fill(Qt::red);
256         return p;
257     }
258
259     /*Mlt::Producer parentProd(producer->parent());
260     Mlt::Service service(parentProd.get_service());
261     mlt_service_lock(service.get_service());*/
262
263     mlt_image_format format = mlt_image_rgb24a;
264     uint8_t *data = frame->get_image(format, width, height, 0);
265     QImage image((uchar *)data, width, height, QImage::Format_ARGB32);
266     //mlt_service_unlock(service.get_service());
267
268     if (!image.isNull()) {
269         p = image.rgbSwapped();
270     } else
271         p.fill(Qt::red);
272
273     delete frame;
274     return p;
275 }
276 /*
277 void KThumb::getImage(KUrl url, int frame, int width, int height)
278 {
279     if (url.isEmpty()) return;
280     QPixmap image(width, height);
281     char *tmp = KRender::decodedString(url.path());
282     Mlt::Producer m_producer(tmp);
283     delete tmp;
284     image.fill(Qt::black);
285
286     if (m_producer.is_blank()) {
287  emit thumbReady(frame, image);
288  return;
289     }
290     Mlt::Filter m_convert("avcolour_space");
291     m_convert.set("forced", mlt_image_rgb24a);
292     m_producer.attach(m_convert);
293     m_producer.seek(frame);
294     Mlt::Frame * m_frame = m_producer.get_frame();
295     mlt_image_format format = mlt_image_rgb24a;
296     width = width - 2;
297     height = height - 2;
298     if (m_frame && m_frame->is_valid()) {
299      uint8_t *thumb = m_frame->get_image(format, width, height);
300      QImage tmpimage(thumb, width, height, 32, NULL, 0, QImage::IgnoreEndian);
301      if (!tmpimage.isNull()) bitBlt(&image, 1, 1, &tmpimage, 0, 0, width + 2, height + 2);
302     }
303     if (m_frame) delete m_frame;
304     emit thumbReady(frame, image);
305 }
306
307 void KThumb::getThumbs(KUrl url, int startframe, int endframe, int width, int height)
308 {
309     if (url.isEmpty()) return;
310     QPixmap image(width, height);
311     char *tmp = KRender::decodedString(url.path());
312     Mlt::Producer m_producer(tmp);
313     delete tmp;
314     image.fill(Qt::black);
315
316     if (m_producer.is_blank()) {
317  emit thumbReady(startframe, image);
318  emit thumbReady(endframe, image);
319  return;
320     }
321     Mlt::Filter m_convert("avcolour_space");
322     m_convert.set("forced", mlt_image_rgb24a);
323     m_producer.attach(m_convert);
324     m_producer.seek(startframe);
325     Mlt::Frame * m_frame = m_producer.get_frame();
326     mlt_image_format format = mlt_image_rgb24a;
327     width = width - 2;
328     height = height - 2;
329
330     if (m_frame && m_frame->is_valid()) {
331      uint8_t *thumb = m_frame->get_image(format, width, height);
332      QImage tmpimage(thumb, width, height, 32, NULL, 0, QImage::IgnoreEndian);
333      if (!tmpimage.isNull()) bitBlt(&image, 1, 1, &tmpimage, 0, 0, width - 2, height - 2);
334     }
335     if (m_frame) delete m_frame;
336     emit thumbReady(startframe, image);
337
338     image.fill(Qt::black);
339     m_producer.seek(endframe);
340     m_frame = m_producer.get_frame();
341
342     if (m_frame && m_frame->is_valid()) {
343      uint8_t *thumb = m_frame->get_image(format, width, height);
344      QImage tmpimage(thumb, width, height, 32, NULL, 0, QImage::IgnoreEndian);
345      if (!tmpimage.isNull()) bitBlt(&image, 1, 1, &tmpimage, 0, 0, width - 2, height - 2);
346     }
347     if (m_frame) delete m_frame;
348     emit thumbReady(endframe, image);
349 }
350 */
351 void KThumb::stopAudioThumbs()
352 {
353     if (m_audioThumbProducer.isRunning()) {
354         m_audioThumbProducer.stop_me = true;
355         slotAudioThumbOver();
356     }
357 }
358
359 void KThumb::removeAudioThumb()
360 {
361     if (m_thumbFile.isEmpty()) return;
362     stopAudioThumbs();
363     QFile f(m_thumbFile);
364     f.remove();
365 }
366
367 void KThumb::getAudioThumbs(int channel, double frame, double frameLength, int arrayWidth)
368 {
369     if (channel == 0) {
370         slotAudioThumbOver();
371         return;
372     }
373     if ((m_audioThumbProducer.isRunning() && m_audioThumbProducer.isWorking())) {
374         return;
375     }
376
377     QMap <int, QMap <int, QByteArray> > storeIn;
378     //FIXME: Hardcoded!!!
379     int m_frequency = 48000;
380     int m_channels = channel;
381
382     QFile f(m_thumbFile);
383     if (f.open(QIODevice::ReadOnly)) {
384         QByteArray channelarray = f.readAll();
385         f.close();
386         if (channelarray.size() != arrayWidth*(frame + frameLength)*m_channels) {
387             kDebug() << "--- BROKEN THUMB FOR: " << m_url.fileName() << " ---------------------- " << endl;
388             f.remove();
389             slotAudioThumbOver();
390             return;
391         }
392         kDebug() << "reading audio thumbs from file";
393         for (int z = (int) frame; z < (int)(frame + frameLength); z++) {
394             for (int c = 0; c < m_channels; c++) {
395                 QByteArray m_array(arrayWidth, '\x00');
396                 for (int i = 0; i < arrayWidth; i++)
397                     m_array[i] = channelarray[z*arrayWidth*m_channels + c*arrayWidth + i];
398                 storeIn[z][c] = m_array;
399             }
400         }
401         emit audioThumbReady(storeIn);
402         slotAudioThumbOver();
403     } else {
404         if (m_audioThumbProducer.isRunning()) return;
405         m_audioThumbProducer.init(m_url, m_thumbFile, frame, frameLength, m_frequency, m_channels, arrayWidth);
406         m_audioThumbProducer.start(QThread::LowestPriority);
407         // kDebug() << "STARTING GENERATE THMB FOR: " <<m_id<<", URL: "<< m_url << " ................................";
408     }
409 }
410
411 void KThumb::slotAudioThumbProgress(const int progress)
412 {
413     m_clipManager->setThumbsProgress(i18n("Creating thumbnail for %1", m_url.fileName()), progress);
414 }
415
416 void KThumb::slotAudioThumbOver()
417 {
418     m_clipManager->setThumbsProgress(i18n("Creating thumbnail for %1", m_url.fileName()), -1);
419     m_clipManager->endAudioThumbsGeneration(m_id);
420 }
421
422 void KThumb::askForAudioThumbs(const QString &id)
423 {
424     m_clipManager->askForAudioThumb(id);
425 }
426
427
428 #include "kthumb.moc"
429