1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
|
/*
* Copyright (C) 2010-2018 Team Kodi
* This file is part of Kodi - https://kodi.tv
*
* SPDX-License-Identifier: GPL-2.0-or-later
* See LICENSES/README.md for more information.
*/
#pragma once
#include "cores/AudioEngine/Interfaces/AESink.h"
#include "cores/AudioEngine/Utils/AEDeviceInfo.h"
#include "cores/AudioEngine/Utils/AEUtil.h"
#include "threads/CriticalSection.h"
#include "threads/SystemClock.h"
#include "threads/Thread.h"
#include <atomic>
#include <memory>
#include <pulse/pulseaudio.h>
#include <pulse/simple.h>
class CDriverMonitor;
class CAESinkPULSE : public IAESink
{
public:
const char *GetName() override { return "PULSE"; }
CAESinkPULSE();
~CAESinkPULSE() override;
static bool Register();
static IAESink* Create(std::string &device, AEAudioFormat &desiredFormat);
static void EnumerateDevicesEx(AEDeviceInfoList &list, bool force = false);
static void Cleanup();
bool Initialize(AEAudioFormat &format, std::string &device) override;
void Deinitialize() override;
virtual double GetDelay() { return 0.0; }
void GetDelay(AEDelayStatus& status) override;
double GetCacheTotal() override;
unsigned int AddPackets(uint8_t **data, unsigned int frames, unsigned int offset) override;
void Drain() override;
bool HasVolume() override { return true; }
void SetVolume(float volume) override;
bool IsInitialized();
void UpdateInternalVolume(const pa_cvolume* nVol);
pa_stream* GetInternalStream();
pa_threaded_mainloop* GetInternalMainLoop();
CCriticalSection m_sec;
std::atomic<int> m_requestedBytes = 0;
private:
void Pause(bool pause);
static inline bool WaitForOperation(pa_operation *op, pa_threaded_mainloop *mainloop, const char *LogEntry);
bool m_IsAllocated;
bool m_passthrough;
bool m_IsStreamPaused;
AEAudioFormat m_format;
unsigned int m_BytesPerSecond;
unsigned int m_BufferSize;
unsigned int m_Channels;
double m_maxLatency;
pa_stream *m_Stream;
pa_cvolume m_Volume;
bool m_volume_needs_update;
uint32_t m_periodSize;
pa_context *m_Context;
pa_threaded_mainloop *m_MainLoop;
static std::unique_ptr<CDriverMonitor> m_pMonitor;
};
|
