mirror of
https://github.com/polybar/polybar.git
synced 2024-11-18 13:55:11 -05:00
f653c3a738
If context_state_callback is called before we call pa_threaded_mainloop_wait in the main thread, the signal is lost and we wait forever. Fixes #2707 Ref #2699 Ref #2697
87 lines
2.3 KiB
C++
87 lines
2.3 KiB
C++
#pragma once
|
|
|
|
#include <pulse/pulseaudio.h>
|
|
|
|
#include <atomic>
|
|
#include <queue>
|
|
|
|
#include "common.hpp"
|
|
#include "errors.hpp"
|
|
#include "settings.hpp"
|
|
#include "utils/math.hpp"
|
|
// fwd
|
|
struct pa_context;
|
|
struct pa_threaded_mainloop;
|
|
struct pa_cvolume;
|
|
typedef struct pa_context pa_context;
|
|
typedef struct pa_threaded_mainloop pa_threaded_mainloop;
|
|
|
|
POLYBAR_NS
|
|
class logger;
|
|
|
|
DEFINE_ERROR(pulseaudio_error);
|
|
|
|
class pulseaudio {
|
|
// events to add to our queue
|
|
enum class evtype { NEW = 0, CHANGE, REMOVE, SERVER };
|
|
using queue = std::queue<evtype>;
|
|
|
|
public:
|
|
explicit pulseaudio(const logger& logger, string&& sink_name, bool m_max_volume);
|
|
~pulseaudio();
|
|
|
|
pulseaudio(const pulseaudio& o) = delete;
|
|
pulseaudio& operator=(const pulseaudio& o) = delete;
|
|
|
|
const string& get_name();
|
|
|
|
bool wait();
|
|
int process_events();
|
|
|
|
int get_volume();
|
|
double get_decibels();
|
|
void set_volume(float percentage);
|
|
void inc_volume(int delta_perc);
|
|
void set_mute(bool mode);
|
|
void toggle_mute();
|
|
bool is_muted();
|
|
|
|
private:
|
|
void update_volume(pa_operation* o);
|
|
static void check_mute_callback(pa_context* context, const pa_sink_info* info, int eol, void* userdata);
|
|
static void get_sink_volume_callback(pa_context* context, const pa_sink_info* info, int is_last, void* userdata);
|
|
static void subscribe_callback(pa_context* context, pa_subscription_event_type_t t, uint32_t idx, void* userdata);
|
|
static void simple_callback(pa_context* context, int success, void* userdata);
|
|
static void sink_info_callback(pa_context* context, const pa_sink_info* info, int eol, void* userdata);
|
|
static void context_state_callback(pa_context* context, void* userdata);
|
|
|
|
inline void wait_loop(pa_operation* op, pa_threaded_mainloop* loop);
|
|
|
|
const logger& m_log;
|
|
|
|
/**
|
|
* Has context_state_callback signalled the mainloop during connection.
|
|
*/
|
|
std::atomic_bool m_state_callback_signal{false};
|
|
|
|
// used for temporary callback results
|
|
int success{0};
|
|
pa_cvolume cv{};
|
|
bool muted{false};
|
|
// default sink name
|
|
static constexpr auto DEFAULT_SINK = "@DEFAULT_SINK@";
|
|
|
|
pa_context* m_context{nullptr};
|
|
pa_threaded_mainloop* m_mainloop{nullptr};
|
|
|
|
queue m_events;
|
|
|
|
// specified sink name
|
|
string spec_s_name;
|
|
string s_name;
|
|
uint32_t m_index{0};
|
|
|
|
pa_volume_t m_max_volume{PA_VOLUME_UI_MAX};
|
|
};
|
|
|
|
POLYBAR_NS_END
|