File indexing completed on 2024-05-12 04:01:32

 /*
     SPDX-FileCopyrightText: 2022 Volker Krause <vkrause@kde.org>
     SPDX-License-Identifier: MIT
 */
 
 #include "videoscanner.h"
 #include "videoscannerframe_p.h"
 #include "videoscannerworker_p.h"
 
 #include <QDebug>
 
 using namespace Prison;
 
 namespace Prison
 {
 class VideoScannerPrivate
 {
 public:
     void newFrame(const QVideoFrame &videoFrame, bool verticallyFlipped);
     void setResult(VideoScanner *q, const ScanResult &result);
 
     QVideoSink *m_sink = nullptr;
     VideoScannerThread m_thread;
     VideoScannerWorker m_worker;
     QByteArray m_frameDataBuffer; // reused memory when we have to copy frame data
     ScanResult m_result;
     QVariant m_previousContent;
     Format::BarcodeFormats m_formats = Format::NoFormat;
     bool m_workerBusy = false;
 };
 }
 
 void VideoScannerPrivate::newFrame(const QVideoFrame &videoFrame, bool verticallyFlipped)
 {
     // NOTE: this runs in the render thread
     if (!m_workerBusy && videoFrame.isValid()) {
         m_workerBusy = true;
 
         VideoScannerFrame frame(videoFrame, verticallyFlipped, m_formats);
         // check if we are only allowed to access this in the render thread
         if (frame.copyRequired()) {
             frame.map();
             if (frame.needsConversion()) {
                 frame.convertToImage();
             } else {
                 frame.copyFrameData(m_frameDataBuffer);
             }
             frame.unmap();
         }
 
         Q_EMIT m_worker.scanFrameRequest(frame);
     }
 }
 
 void VideoScannerPrivate::setResult(VideoScanner *q, const ScanResult &result)
 {
     m_workerBusy = false;
     if (m_result == result) {
         return;
     }
 
     m_result = result;
     Q_EMIT q->resultChanged(result);
 
     if (m_previousContent == result.content()) {
         return;
     }
     m_previousContent = result.content();
     Q_EMIT q->resultContentChanged(result);
 }
 
 VideoScanner::VideoScanner(QObject *parent)
     : QObject(parent)
     , d(new VideoScannerPrivate)
 {
     d->m_worker.moveToThread(&d->m_thread);
     connect(
         &d->m_worker,
         &VideoScannerWorker::result,
         this,
         [this](const ScanResult &result) {
             d->setResult(this, result);
         },
         Qt::QueuedConnection);
 
     d->m_thread.setObjectName(QStringLiteral("Prison Barcode Scanner Worker"));
     d->m_thread.start();
 }
 
 VideoScanner::~VideoScanner()
 {
     d->m_thread.quit();
     d->m_thread.wait();
 }
 
 ScanResult VideoScanner::result() const
 {
     return d->m_result;
 }
 
 Format::BarcodeFormats VideoScanner::formats() const
 {
     return d->m_formats;
 }
 
 void VideoScanner::setFormats(Format::BarcodeFormats formats)
 {
     if (d->m_formats == formats) {
         return;
     }
 
     d->m_formats = formats;
     Q_EMIT formatsChanged();
 }
 
 QVideoSink *VideoScanner::videoSink() const
 {
     return d->m_sink;
 }
 
 void VideoScanner::setVideoSink(QVideoSink *sink)
 {
     if (d->m_sink == sink) {
         return;
     }
 
     if (d->m_sink) {
         disconnect(d->m_sink, nullptr, this, nullptr);
     }
     d->m_sink = sink;
     connect(d->m_sink, &QVideoSink::videoFrameChanged, this, [this](const QVideoFrame &frame) {
         d->newFrame(frame, frame.surfaceFormat().scanLineDirection() == QVideoFrameFormat::BottomToTop);
     });
     Q_EMIT videoSinkChanged();
 }
 
 #include "moc_videoscanner.cpp"