mirror of
https://github.com/isledecomp/SIEdit.git
synced 2024-12-02 11:57:35 -05:00
584 lines
15 KiB
C++
584 lines
15 KiB
C++
#include "mediapanel.h"
|
|
|
|
#include <object.h>
|
|
#include <QDateTime>
|
|
#include <QDebug>
|
|
#include <QGroupBox>
|
|
#include <QMouseEvent>
|
|
|
|
MediaPanel::MediaPanel(QWidget *parent) :
|
|
Panel(parent),
|
|
m_FmtCtx(nullptr),
|
|
m_Packet(nullptr),
|
|
m_VideoCodecCtx(nullptr),
|
|
m_VideoStream(nullptr),
|
|
m_SwsFrame(nullptr),
|
|
m_AudioCodecCtx(nullptr),
|
|
m_AudioStream(nullptr),
|
|
m_SwsCtx(nullptr),
|
|
m_SwrCtx(nullptr),
|
|
m_IoCtx(nullptr),
|
|
m_AudioOutput(nullptr),
|
|
m_SliderPressed(false)
|
|
{
|
|
int row = 0;
|
|
|
|
auto wav_group = new QGroupBox(tr("Playback"));
|
|
layout()->addWidget(wav_group, row, 0, 1, 2);
|
|
|
|
auto preview_layout = new QVBoxLayout(wav_group);
|
|
|
|
m_ImgViewer = new QLabel();
|
|
m_ImgViewer->setAlignment(Qt::AlignCenter);
|
|
preview_layout->addWidget(m_ImgViewer);
|
|
|
|
auto wav_layout = new QHBoxLayout();
|
|
preview_layout->addLayout(wav_layout);
|
|
|
|
m_PlayheadSlider = new ClickableSlider(Qt::Horizontal);
|
|
m_PlayheadSlider->setMinimum(0);
|
|
m_PlayheadSlider->setMaximum(100000);
|
|
connect(m_PlayheadSlider, &QSlider::sliderPressed, this, &MediaPanel::SliderPressed);
|
|
connect(m_PlayheadSlider, &QSlider::sliderMoved, this, &MediaPanel::SliderMoved);
|
|
connect(m_PlayheadSlider, &QSlider::sliderReleased, this, &MediaPanel::SliderReleased);
|
|
wav_layout->addWidget(m_PlayheadSlider);
|
|
|
|
m_PlayBtn = new QPushButton(tr("Play"));
|
|
m_PlayBtn->setCheckable(true);
|
|
connect(m_PlayBtn, &QPushButton::clicked, this, &MediaPanel::Play);
|
|
wav_layout->addWidget(m_PlayBtn);
|
|
|
|
FinishLayout();
|
|
|
|
m_PlaybackTimer = new QTimer(this);
|
|
m_PlaybackTimer->setInterval(10);
|
|
connect(m_PlaybackTimer, &QTimer::timeout, this, &MediaPanel::TimerUpdate);
|
|
|
|
m_AudioNotifyDevice = new MediaAudioDevice(this);
|
|
}
|
|
|
|
MediaPanel::~MediaPanel()
|
|
{
|
|
Close();
|
|
}
|
|
|
|
qint64 MediaPanel::ReadAudio(char *data, qint64 maxlen)
|
|
{
|
|
if (m_AudioFlushed) {
|
|
return 0;
|
|
}
|
|
|
|
while (!m_AudioFlushed && m_AudioBuffer.size() < maxlen) {
|
|
int ret = GetNextFrame(m_AudioCodecCtx, m_AudioStream->index, m_AudioFrame);
|
|
if (ret >= 0 || ret == AVERROR_EOF) {
|
|
const uint8_t **in_data;
|
|
int in_nb_samples;
|
|
if (ret == AVERROR_EOF) {
|
|
in_data = nullptr;
|
|
in_nb_samples = 0;
|
|
m_AudioFlushed = true;
|
|
} else {
|
|
in_data = const_cast<const uint8_t**>(m_AudioFrame->data);
|
|
in_nb_samples = m_AudioFrame->nb_samples;
|
|
}
|
|
|
|
int dst_nb_samples = av_rescale_rnd(swr_get_delay(m_SwrCtx, m_AudioStream->codecpar->sample_rate) + in_nb_samples,
|
|
m_AudioOutput->format().sampleRate(), m_AudioStream->codecpar->sample_rate, AV_ROUND_UP);
|
|
int data_size = dst_nb_samples * av_get_bytes_per_sample(m_AudioOutputSampleFmt) * m_AudioOutput->format().channelCount();
|
|
|
|
int old_sz = m_AudioBuffer.size();
|
|
m_AudioBuffer.resize(old_sz + data_size);
|
|
|
|
uint8_t *out = reinterpret_cast<uint8_t*>(m_AudioBuffer.data() + old_sz);
|
|
int converted = swr_convert(m_SwrCtx, &out, dst_nb_samples, in_data, in_nb_samples);
|
|
|
|
data_size = converted * av_get_bytes_per_sample(m_AudioOutputSampleFmt) * m_AudioOutput->format().channelCount();
|
|
|
|
if (m_AudioBuffer.size() != old_sz + data_size) {
|
|
m_AudioBuffer.resize(old_sz + data_size);
|
|
}
|
|
} else {
|
|
break;
|
|
}
|
|
}
|
|
|
|
if (!m_AudioBuffer.isEmpty()) {
|
|
qint64 copy_len = std::min(maxlen, qint64(m_AudioBuffer.size()));
|
|
memcpy(data, m_AudioBuffer.data(), copy_len);
|
|
m_AudioBuffer = m_AudioBuffer.mid(copy_len);
|
|
return copy_len;
|
|
}
|
|
|
|
return 0;
|
|
}
|
|
|
|
int ReadData(void *opaque, uint8_t *buf, int buf_sz)
|
|
{
|
|
si::MemoryBuffer *m = static_cast<si::MemoryBuffer *>(opaque);
|
|
|
|
int s = m->ReadData(reinterpret_cast<char*>(buf), buf_sz);
|
|
if (s == 0) {
|
|
if (m->pos() == m->size()) {
|
|
s = AVERROR_EOF;
|
|
}
|
|
}
|
|
|
|
return s;
|
|
}
|
|
|
|
int64_t SeekData(void *opaque, int64_t offset, int whence)
|
|
{
|
|
si::MemoryBuffer *m = static_cast<si::MemoryBuffer *>(opaque);
|
|
|
|
if (whence == AVSEEK_SIZE) {
|
|
return m->size();
|
|
}
|
|
|
|
m->seek(offset);
|
|
|
|
return m->pos();
|
|
}
|
|
|
|
void MediaPanel::OnOpeningData(void *data)
|
|
{
|
|
si::Object *o = static_cast<si::Object*>(data);
|
|
|
|
m_Data = o->ExtractToMemory();
|
|
|
|
static const size_t buf_sz = 4096;
|
|
|
|
m_IoCtx = avio_alloc_context(
|
|
(unsigned char *) av_malloc(buf_sz),
|
|
buf_sz,
|
|
0,
|
|
&m_Data,
|
|
ReadData,
|
|
nullptr,
|
|
SeekData
|
|
);
|
|
|
|
m_FmtCtx = avformat_alloc_context();
|
|
m_FmtCtx->pb = m_IoCtx;
|
|
m_FmtCtx->flags |= AVFMT_FLAG_CUSTOM_IO;
|
|
|
|
if (avformat_open_input(&m_FmtCtx, "", nullptr, nullptr) < 0) {
|
|
qCritical() << "Failed to open format context";
|
|
Close();
|
|
return;
|
|
}
|
|
|
|
if (avformat_find_stream_info(m_FmtCtx, nullptr) < 0) {
|
|
qCritical() << "Failed to find stream info";
|
|
Close();
|
|
return;
|
|
}
|
|
|
|
m_Packet = av_packet_alloc();
|
|
m_SwsFrame = av_frame_alloc();
|
|
m_AudioFrame = av_frame_alloc();
|
|
|
|
for (unsigned int i=0; i<m_FmtCtx->nb_streams; i++) {
|
|
AVStream *s = m_FmtCtx->streams[i];
|
|
|
|
const AVCodec *decoder = avcodec_find_decoder(s->codecpar->codec_id);
|
|
|
|
if (decoder) {
|
|
if (!m_VideoCodecCtx && s->codecpar->codec_type == AVMEDIA_TYPE_VIDEO) {
|
|
m_VideoStream = s;
|
|
|
|
m_VideoCodecCtx = avcodec_alloc_context3(decoder);
|
|
avcodec_parameters_to_context(m_VideoCodecCtx, s->codecpar);
|
|
avcodec_open2(m_VideoCodecCtx, decoder, nullptr);
|
|
|
|
const AVPixelFormat dest = AV_PIX_FMT_RGBA;
|
|
m_SwsCtx = sws_getContext(s->codecpar->width,
|
|
s->codecpar->height,
|
|
static_cast<AVPixelFormat>(s->codecpar->format),
|
|
s->codecpar->width,
|
|
s->codecpar->height,
|
|
dest,
|
|
0,
|
|
nullptr,
|
|
nullptr,
|
|
nullptr);
|
|
|
|
m_SwsFrame = av_frame_alloc();
|
|
m_SwsFrame->width = s->codecpar->width;
|
|
m_SwsFrame->height = s->codecpar->height;
|
|
m_SwsFrame->format = dest;
|
|
av_frame_get_buffer(m_SwsFrame, 0);
|
|
}
|
|
|
|
if (!m_AudioCodecCtx && s->codecpar->codec_type == AVMEDIA_TYPE_AUDIO) {
|
|
m_AudioStream = s;
|
|
|
|
m_AudioCodecCtx = avcodec_alloc_context3(decoder);
|
|
avcodec_parameters_to_context(m_AudioCodecCtx, s->codecpar);
|
|
avcodec_open2(m_AudioCodecCtx, decoder, nullptr);
|
|
}
|
|
}
|
|
}
|
|
|
|
if (m_VideoCodecCtx) {
|
|
VideoUpdate(0);
|
|
}
|
|
}
|
|
|
|
void MediaPanel::OnClosingData(void *data)
|
|
{
|
|
Close();
|
|
}
|
|
|
|
void MediaPanel::Close()
|
|
{
|
|
Play(false);
|
|
|
|
if (m_VideoCodecCtx) {
|
|
avcodec_free_context(&m_VideoCodecCtx);
|
|
}
|
|
|
|
if (m_AudioCodecCtx) {
|
|
avcodec_free_context(&m_AudioCodecCtx);
|
|
}
|
|
|
|
if (m_SwsCtx) {
|
|
sws_freeContext(m_SwsCtx);
|
|
m_SwsCtx = nullptr;
|
|
}
|
|
|
|
if (m_SwrCtx) {
|
|
swr_free(&m_SwrCtx);
|
|
}
|
|
|
|
if (m_Packet) {
|
|
av_packet_free(&m_Packet);
|
|
}
|
|
|
|
if (m_SwsFrame) {
|
|
av_frame_free(&m_SwsFrame);
|
|
}
|
|
|
|
if (m_AudioFrame) {
|
|
av_frame_free(&m_AudioFrame);
|
|
}
|
|
|
|
ClearQueue();
|
|
|
|
if (m_FmtCtx) {
|
|
avformat_free_context(m_FmtCtx);
|
|
m_FmtCtx = nullptr;
|
|
}
|
|
|
|
if (m_IoCtx) {
|
|
avio_context_free(&m_IoCtx);
|
|
m_IoCtx = nullptr;
|
|
}
|
|
|
|
m_VideoStream = nullptr;
|
|
m_AudioStream = nullptr;
|
|
|
|
m_Data.Close();
|
|
|
|
m_PlayheadSlider->setValue(0);
|
|
|
|
m_ImgViewer->setPixmap(QPixmap());
|
|
}
|
|
|
|
void MediaPanel::VideoUpdate(float t)
|
|
{
|
|
double flipped = av_q2d(av_inv_q(m_VideoStream->time_base));
|
|
int64_t ts = std::floor(t * flipped);
|
|
//int64_t second = std::ceil(flipped);
|
|
|
|
AVFrame *using_frame = nullptr;
|
|
for (auto it=m_FrameQueue.begin(); it!=m_FrameQueue.end(); it++) {
|
|
auto next = it;
|
|
next++;
|
|
|
|
if ((*it)->pts == ts
|
|
|| (next != m_FrameQueue.end() && (*next)->pts > ts)) {
|
|
using_frame = *it;
|
|
break;
|
|
}
|
|
}
|
|
|
|
if (!using_frame) {
|
|
// Determine if the queue will eventually get this frame
|
|
if (m_FrameQueue.empty()
|
|
//|| ts > m_FrameQueue.back()->pts + second
|
|
|| ts < m_FrameQueue.front()->pts) {
|
|
ClearQueue();
|
|
av_seek_frame(m_FmtCtx, m_VideoStream->index, ts, AVSEEK_FLAG_BACKWARD);
|
|
}
|
|
|
|
while (m_FrameQueue.empty() || m_FrameQueue.back()->pts < ts) {
|
|
AVFrame *f = av_frame_alloc();
|
|
int ret = GetNextFrame(m_VideoCodecCtx, m_VideoStream->index, f);
|
|
if (ret < 0) {
|
|
av_frame_free(&f);
|
|
|
|
if (ret == AVERROR_EOF) {
|
|
Play(false);
|
|
m_PlayheadSlider->setValue(m_PlayheadSlider->maximum());
|
|
}
|
|
break;
|
|
} else {
|
|
AVFrame *previous = nullptr;
|
|
if (!m_FrameQueue.empty()) {
|
|
previous = m_FrameQueue.back();
|
|
}
|
|
|
|
m_FrameQueue.push_back(f);
|
|
|
|
if (previous && f->pts > ts) {
|
|
using_frame = previous;
|
|
break;
|
|
} else if (f->pts == ts) {
|
|
using_frame = f;
|
|
break;
|
|
}
|
|
}
|
|
|
|
}
|
|
}
|
|
|
|
if (using_frame) {
|
|
if (using_frame->pts != m_SwsFrame->pts) {
|
|
m_SwsFrame->pts = using_frame->pts;
|
|
|
|
sws_scale(m_SwsCtx, using_frame->data, using_frame->linesize, 0, using_frame->height,
|
|
m_SwsFrame->data, m_SwsFrame->linesize);
|
|
|
|
QImage img(m_SwsFrame->data[0], m_SwsFrame->width, m_SwsFrame->height, m_SwsFrame->linesize[0], QImage::Format_RGBA8888);
|
|
m_ImgViewer->setPixmap(QPixmap::fromImage(img));
|
|
}
|
|
}
|
|
}
|
|
|
|
void MediaPanel::AudioSeek(float t)
|
|
{
|
|
double flipped = av_q2d(av_inv_q(m_AudioStream->time_base));
|
|
int64_t ts = std::floor(t * flipped);
|
|
|
|
av_seek_frame(m_FmtCtx, m_AudioStream->index, ts, AVSEEK_FLAG_BACKWARD);
|
|
}
|
|
|
|
int MediaPanel::GetNextFrame(AVCodecContext *cctx, unsigned int stream, AVFrame *frame)
|
|
{
|
|
int ret;
|
|
av_frame_unref(frame);
|
|
while ((ret = avcodec_receive_frame(cctx, frame)) == AVERROR(EAGAIN)) {
|
|
av_packet_unref(m_Packet);
|
|
ret = av_read_frame(m_FmtCtx, m_Packet);
|
|
if (ret < 0) {
|
|
return ret;
|
|
}
|
|
|
|
if (m_Packet->stream_index == stream) {
|
|
ret = avcodec_send_packet(cctx, m_Packet);
|
|
if (ret < 0) {
|
|
return ret;
|
|
}
|
|
}
|
|
}
|
|
|
|
return ret;
|
|
}
|
|
|
|
void MediaPanel::ClearQueue()
|
|
{
|
|
while (!m_FrameQueue.empty()) {
|
|
av_frame_free(&m_FrameQueue.front());
|
|
m_FrameQueue.pop_front();
|
|
}
|
|
}
|
|
|
|
void MediaPanel::StartAudioPlayback()
|
|
{
|
|
auto output_dev = QAudioDeviceInfo::defaultOutputDevice();
|
|
auto fmt = output_dev.preferredFormat();
|
|
|
|
AVSampleFormat smp_fmt = AV_SAMPLE_FMT_S16;
|
|
switch (fmt.sampleType()) {
|
|
case QAudioFormat::Unknown:
|
|
break;
|
|
case QAudioFormat::SignedInt:
|
|
switch (fmt.sampleSize()) {
|
|
case 16:
|
|
smp_fmt = AV_SAMPLE_FMT_S16;
|
|
break;
|
|
case 32:
|
|
smp_fmt = AV_SAMPLE_FMT_S32;
|
|
break;
|
|
case 64:
|
|
smp_fmt = AV_SAMPLE_FMT_S64;
|
|
break;
|
|
}
|
|
break;
|
|
case QAudioFormat::UnSignedInt:
|
|
switch (fmt.sampleSize()) {
|
|
case 8:
|
|
smp_fmt = AV_SAMPLE_FMT_U8;
|
|
break;
|
|
}
|
|
break;
|
|
case QAudioFormat::Float:
|
|
switch (fmt.sampleSize()) {
|
|
case 32:
|
|
smp_fmt = AV_SAMPLE_FMT_FLT;
|
|
break;
|
|
case 64:
|
|
smp_fmt = AV_SAMPLE_FMT_DBL;
|
|
break;
|
|
}
|
|
break;
|
|
}
|
|
m_AudioOutputSampleFmt = smp_fmt;
|
|
|
|
m_SwrCtx = swr_alloc_set_opts(nullptr,
|
|
av_get_default_channel_layout(fmt.channelCount()),
|
|
smp_fmt,
|
|
fmt.sampleRate(),
|
|
av_get_default_channel_layout(m_AudioStream->codecpar->channels),
|
|
static_cast<AVSampleFormat>(m_AudioStream->codecpar->format),
|
|
m_AudioStream->codecpar->sample_rate,
|
|
0, nullptr);
|
|
if (!m_SwrCtx) {
|
|
qCritical() << "Failed to alloc swr ctx";
|
|
} else {
|
|
if (swr_init(m_SwrCtx) < 0) {
|
|
qCritical() << "Failed to init swr ctx";
|
|
} else {
|
|
if (m_AudioFlushed) {
|
|
AudioSeek(0);
|
|
m_AudioFlushed = false;
|
|
}
|
|
m_AudioBuffer.clear();
|
|
|
|
m_AudioOutput = new QAudioOutput(output_dev, fmt, this);
|
|
m_AudioNotifyDevice->open(QIODevice::ReadOnly);
|
|
connect(m_AudioOutput, &QAudioOutput::stateChanged, this, &MediaPanel::AudioStateChanged);
|
|
m_AudioOutput->start(m_AudioNotifyDevice);
|
|
}
|
|
}
|
|
}
|
|
|
|
float MediaPanel::SliderValueToFloatSeconds(int i, int max, AVStream *s)
|
|
{
|
|
float percent = float(i) / float(max);
|
|
float duration = float(s->time_base.num) * float(s->duration) / float(s->time_base.den);
|
|
return percent * duration;
|
|
}
|
|
|
|
void MediaPanel::Play(bool e)
|
|
{
|
|
if (m_AudioOutput) {
|
|
m_AudioOutput->stop();
|
|
delete m_AudioOutput;
|
|
m_AudioOutput = nullptr;
|
|
|
|
m_AudioNotifyDevice->close();
|
|
}
|
|
|
|
if (e) {
|
|
if (m_VideoStream) {
|
|
m_PlaybackOffset = SliderValueToFloatSeconds(m_PlayheadSlider->value(), m_PlayheadSlider->maximum(), m_VideoStream);
|
|
} else {
|
|
m_PlaybackOffset = 0;
|
|
}
|
|
|
|
if (m_AudioStream) {
|
|
StartAudioPlayback();
|
|
}
|
|
|
|
m_PlaybackStart = QDateTime::currentMSecsSinceEpoch();
|
|
m_PlaybackTimer->start();
|
|
} else {
|
|
m_PlaybackTimer->stop();
|
|
}
|
|
m_PlayBtn->setChecked(e);
|
|
}
|
|
|
|
void MediaPanel::TimerUpdate()
|
|
{
|
|
float now = float(QDateTime::currentMSecsSinceEpoch() - m_PlaybackStart) * 0.001f;
|
|
if (m_VideoStream) {
|
|
VideoUpdate(now + m_PlaybackOffset);
|
|
|
|
if (!m_SliderPressed && m_SwsFrame->pts != AV_NOPTS_VALUE) {
|
|
float percent = float(m_SwsFrame->pts) / float(m_VideoStream->duration);
|
|
m_PlayheadSlider->setValue(percent * m_PlayheadSlider->maximum());
|
|
}
|
|
} else if (m_AudioStream) {
|
|
if (!m_SliderPressed && m_AudioFrame->pts != AV_NOPTS_VALUE) {
|
|
float percent = float(m_AudioFrame->pts) / float(m_AudioStream->duration);
|
|
m_PlayheadSlider->setValue(percent * m_PlayheadSlider->maximum());
|
|
}
|
|
}
|
|
}
|
|
|
|
void MediaPanel::SliderPressed()
|
|
{
|
|
m_SliderPressed = true;
|
|
}
|
|
|
|
void MediaPanel::SliderMoved(int i)
|
|
{
|
|
if (m_VideoStream) {
|
|
float f = SliderValueToFloatSeconds(i, m_PlayheadSlider->maximum(), m_VideoStream);
|
|
m_PlaybackOffset = f;
|
|
m_PlaybackStart = QDateTime::currentMSecsSinceEpoch();
|
|
VideoUpdate(f);
|
|
}
|
|
if (m_AudioStream) {
|
|
AudioSeek(SliderValueToFloatSeconds(i, m_PlayheadSlider->maximum(), m_AudioStream));
|
|
}
|
|
}
|
|
|
|
void MediaPanel::SliderReleased()
|
|
{
|
|
m_SliderPressed = false;
|
|
}
|
|
|
|
void MediaPanel::AudioStateChanged(QAudio::State state)
|
|
{
|
|
if (state == QAudio::IdleState) {
|
|
Play(false);
|
|
m_PlayheadSlider->setValue(m_PlayheadSlider->maximum());
|
|
}
|
|
}
|
|
|
|
MediaAudioDevice::MediaAudioDevice(MediaPanel *o) :
|
|
QIODevice(o)
|
|
{
|
|
m_MediaPanel = o;
|
|
}
|
|
|
|
qint64 MediaAudioDevice::readData(char *data, qint64 maxSize)
|
|
{
|
|
return m_MediaPanel->ReadAudio(data, maxSize);
|
|
}
|
|
|
|
qint64 MediaAudioDevice::writeData(const char *data, qint64 maxSize)
|
|
{
|
|
return -1;
|
|
}
|
|
|
|
ClickableSlider::ClickableSlider(Qt::Orientation orientation, QWidget *parent) :
|
|
QSlider(orientation, parent)
|
|
{
|
|
}
|
|
|
|
ClickableSlider::ClickableSlider(QWidget *parent) :
|
|
QSlider(parent)
|
|
{
|
|
}
|
|
|
|
void ClickableSlider::mousePressEvent(QMouseEvent *e)
|
|
{
|
|
int v = double(e->pos().x()) / double(width()) * this->maximum();
|
|
setValue(v);
|
|
emit sliderMoved(v);
|
|
|
|
QSlider::mousePressEvent(e);
|
|
}
|