mirror of
https://github.com/polybar/polybar.git
synced 2026-04-01 04:57:51 +00:00
42fda5b105
Modules and other features that require optional libraries are now dynamically loaded on the construction of the controller via dlopen(). This allows polybar to be built with support for all of the features on one machine, but gracefully fall back and disable those features on machines where the required optional shared libraries are not found.
155 lines
3.7 KiB
C++
155 lines
3.7 KiB
C++
#pragma once
|
|
|
|
#include <list>
|
|
#include <moodycamel/blockingconcurrentqueue.h>
|
|
#include <thread>
|
|
|
|
#include "common.hpp"
|
|
#include "settings.hpp"
|
|
#include "events/signal_fwd.hpp"
|
|
#include "events/signal_receiver.hpp"
|
|
#include "events/types.hpp"
|
|
#include "utils/file.hpp"
|
|
#include "utils/plugin.hpp"
|
|
#include "x11/types.hpp"
|
|
|
|
POLYBAR_NS
|
|
|
|
// fwd decl {{{
|
|
|
|
enum class alignment;
|
|
class bar;
|
|
class command;
|
|
class config;
|
|
class connection;
|
|
class inotify_watch;
|
|
class ipc;
|
|
class logger;
|
|
class signal_emitter;
|
|
namespace modules {
|
|
struct module_interface;
|
|
class input_handler;
|
|
}
|
|
using module_t = unique_ptr<modules::module_interface>;
|
|
using modulemap_t = std::map<alignment, vector<module_t>>;
|
|
|
|
// }}}
|
|
|
|
class controller : public signal_receiver<SIGN_PRIORITY_CONTROLLER, signals::eventqueue::exit_terminate, signals::eventqueue::exit_reload,
|
|
signals::eventqueue::notify_change, signals::eventqueue::notify_forcechange, signals::eventqueue::check_state, signals::ipc::action,
|
|
signals::ipc::command, signals::ipc::hook, signals::ui::ready, signals::ui::button_press> {
|
|
public:
|
|
using make_type = unique_ptr<controller>;
|
|
static make_type make(unique_ptr<ipc>&& ipc, unique_ptr<inotify_watch>&& config_watch);
|
|
|
|
explicit controller(connection&, signal_emitter&, const logger&, const config&, unique_ptr<bar>&&, unique_ptr<ipc>&&,
|
|
unique_ptr<inotify_watch>&&);
|
|
~controller();
|
|
|
|
bool run(bool writeback, string snapshot_dst);
|
|
|
|
bool enqueue(event&& evt);
|
|
bool enqueue(string&& input_data);
|
|
|
|
protected:
|
|
void read_events();
|
|
void process_eventqueue();
|
|
void process_inputdata();
|
|
bool process_update(bool force);
|
|
|
|
bool on(const signals::eventqueue::notify_change& evt);
|
|
bool on(const signals::eventqueue::notify_forcechange& evt);
|
|
bool on(const signals::eventqueue::exit_terminate& evt);
|
|
bool on(const signals::eventqueue::exit_reload& evt);
|
|
bool on(const signals::eventqueue::check_state& evt);
|
|
bool on(const signals::ui::ready& evt);
|
|
bool on(const signals::ui::button_press& evt);
|
|
bool on(const signals::ipc::action& evt);
|
|
bool on(const signals::ipc::command& evt);
|
|
bool on(const signals::ipc::hook& evt);
|
|
|
|
private:
|
|
connection& m_connection;
|
|
signal_emitter& m_sig;
|
|
const logger& m_log;
|
|
const config& m_conf;
|
|
unique_ptr<bar> m_bar;
|
|
unique_ptr<ipc> m_ipc;
|
|
unique_ptr<inotify_watch> m_confwatch;
|
|
unique_ptr<command> m_command;
|
|
|
|
array<unique_ptr<file_descriptor>, 2> m_queuefd{};
|
|
|
|
/**
|
|
* @brief State flag
|
|
*/
|
|
std::atomic<bool> m_process_events{false};
|
|
|
|
/**
|
|
* @brief Destination path of generated snapshot
|
|
*/
|
|
string m_snapshot_dst;
|
|
|
|
/**
|
|
* @brief Controls weather the output gets printed to stdout
|
|
*/
|
|
bool m_writeback{false};
|
|
|
|
/**
|
|
* @brief Internal event queue
|
|
*/
|
|
moodycamel::BlockingConcurrentQueue<event> m_queue;
|
|
|
|
/**
|
|
* @brief Loaded modules
|
|
*/
|
|
modulemap_t m_modules;
|
|
|
|
/**
|
|
* @brief Module input handlers
|
|
*/
|
|
vector<modules::input_handler*> m_inputhandlers;
|
|
|
|
/**
|
|
* @brief Maximum number of subsequent events to swallow
|
|
*/
|
|
size_t m_swallow_limit{5U};
|
|
|
|
/**
|
|
* @brief Time to wait for subsequent events
|
|
*/
|
|
std::chrono::milliseconds m_swallow_update{10};
|
|
|
|
/**
|
|
* @brief Time to throttle input events
|
|
*/
|
|
std::chrono::milliseconds m_swallow_input{30};
|
|
|
|
/**
|
|
* @brief Time of last handled input event
|
|
*/
|
|
std::chrono::time_point<std::chrono::system_clock, std::chrono::milliseconds> m_lastinput;
|
|
|
|
/**
|
|
* @brief Input data
|
|
*/
|
|
string m_inputdata;
|
|
|
|
/**
|
|
* @brief Thread for the eventqueue loop
|
|
*/
|
|
std::thread m_event_thread;
|
|
|
|
/**
|
|
* @brief Misc threads
|
|
*/
|
|
vector<std::thread> m_threads;
|
|
|
|
/**
|
|
* @brief Loaded plugins
|
|
*/
|
|
std::list<plugin_handle> m_plugins;
|
|
};
|
|
|
|
POLYBAR_NS_END
|