afb81b8278
Some checks failed
Docker. / Ubuntu (push) Has been cancelled
User-agent updater. / User-agent (push) Failing after 15s
Lock Threads / lock (push) Failing after 10s
Waiting for answer. / waiting-for-answer (push) Failing after 22s
Close stale issues and PRs / stale (push) Successful in 13s
Needs user action. / needs-user-action (push) Failing after 8s
Can't reproduce. / cant-reproduce (push) Failing after 8s
82 lines
2.0 KiB
C++
82 lines
2.0 KiB
C++
/*
|
|
This file is part of Telegram Desktop,
|
|
the official desktop application for the Telegram messaging service.
|
|
|
|
For license and copyright information please follow this link:
|
|
https://github.com/telegramdesktop/tdesktop/blob/master/LEGAL
|
|
*/
|
|
#pragma once
|
|
|
|
#include "media/audio/media_audio.h"
|
|
#include "media/audio/media_child_ffmpeg_loader.h"
|
|
|
|
class AudioPlayerLoader;
|
|
class ChildFFMpegLoader;
|
|
|
|
namespace Media {
|
|
namespace Player {
|
|
|
|
class Loaders : public QObject {
|
|
Q_OBJECT
|
|
|
|
public:
|
|
Loaders(QThread *thread);
|
|
void feedFromExternal(ExternalSoundPart &&part);
|
|
void forceToBufferExternal(const AudioMsgId &audioId);
|
|
~Loaders();
|
|
|
|
Q_SIGNALS:
|
|
void error(const AudioMsgId &audio);
|
|
void needToCheck();
|
|
|
|
public Q_SLOTS:
|
|
void onInit();
|
|
|
|
void onStart(const AudioMsgId &audio, qint64 positionMs);
|
|
void onLoad(const AudioMsgId &audio);
|
|
void onCancel(const AudioMsgId &audio);
|
|
|
|
private:
|
|
struct SetupLoaderResult {
|
|
AudioPlayerLoader *loader = nullptr;
|
|
float64 oldSpeed = 0.;
|
|
float64 newSpeed = 0.;
|
|
int64 fadeStartPosition = 0;
|
|
int64 position = 0;
|
|
int64 normalLength = 0;
|
|
int frequency = 0;
|
|
bool errorAtStart = false;
|
|
bool justStarted = false;
|
|
};
|
|
|
|
void videoSoundAdded();
|
|
[[nodiscard]] Mixer::Track::WithSpeed rebufferOnSpeedChange(
|
|
const SetupLoaderResult &setup);
|
|
|
|
void emitError(AudioMsgId::Type type);
|
|
AudioMsgId clear(AudioMsgId::Type type);
|
|
void setStoppedState(Mixer::Track *m, State state = State::Stopped);
|
|
|
|
void loadData(AudioMsgId audio, crl::time positionMs = 0);
|
|
[[nodiscard]] SetupLoaderResult setupLoader(
|
|
const AudioMsgId &audio,
|
|
crl::time positionMs);
|
|
Mixer::Track *checkLoader(AudioMsgId::Type type);
|
|
|
|
AudioMsgId _audio, _song, _video;
|
|
std::unique_ptr<AudioPlayerLoader> _audioLoader;
|
|
std::unique_ptr<AudioPlayerLoader> _songLoader;
|
|
std::unique_ptr<AudioPlayerLoader> _videoLoader;
|
|
|
|
QMutex _fromExternalMutex;
|
|
base::flat_map<
|
|
AudioMsgId,
|
|
std::deque<FFmpeg::Packet>> _fromExternalQueues;
|
|
base::flat_set<AudioMsgId> _fromExternalForceToBuffer;
|
|
SingleQueuedInvokation _fromExternalNotify;
|
|
|
|
};
|
|
|
|
} // namespace Player
|
|
} // namespace Media
|