summaryrefslogtreecommitdiffstats
path: root/src/server/JackDriver.hpp
diff options
context:
space:
mode:
Diffstat (limited to 'src/server/JackDriver.hpp')
-rw-r--r--src/server/JackDriver.hpp134
1 files changed, 65 insertions, 69 deletions
diff --git a/src/server/JackDriver.hpp b/src/server/JackDriver.hpp
index 00b1836a..4c8e779e 100644
--- a/src/server/JackDriver.hpp
+++ b/src/server/JackDriver.hpp
@@ -19,34 +19,35 @@
#include "Driver.hpp"
#include "EnginePort.hpp"
-#include "ingen_config.h"
+#include "types.hpp"
-#include "ingen/types.hpp"
-#include "lv2/atom/forge.h"
-#include "raul/Semaphore.hpp"
+#include <ingen/URI.hpp>
+#include <ingen/memory.hpp>
+#include <lv2/atom/forge.h>
+#include <raul/Semaphore.hpp>
+
+#include <boost/intrusive/options.hpp>
+#include <boost/intrusive/slist.hpp>
+#include <jack/transport.h> // IWYU pragma: keep
+#include <jack/types.h>
-#include <jack/jack.h>
#include <jack/thread.h>
-#include <jack/transport.h>
-#ifdef INGEN_JACK_SESSION
-#include <jack/session.h>
-#endif
#include <atomic>
-#include <cstddef>
#include <cstdint>
+#include <exception>
+#include <memory>
#include <string>
-namespace Raul { class Path; }
-
namespace ingen {
+
+class Atom;
+
namespace server {
-class DuplexPort;
class Engine;
-class GraphImpl;
-class JackDriver;
-class PortImpl;
+class FrameTimer;
+class RunContext;
/** The Jack Driver.
*
@@ -60,7 +61,7 @@ class JackDriver : public Driver
{
public:
explicit JackDriver(Engine& engine);
- ~JackDriver();
+ ~JackDriver() override;
bool attach(const std::string& server_name,
const std::string& client_name,
@@ -72,21 +73,21 @@ public:
bool dynamic_ports() const override { return true; }
EnginePort* create_port(DuplexPort* graph_port) override;
- EnginePort* get_port(const Raul::Path& path) override;
+ EnginePort* get_port(const raul::Path& path) override;
- void rename_port(const Raul::Path& old_path, const Raul::Path& new_path) override;
- void port_property(const Raul::Path& path, const URI& uri, const Atom& value) override;
- void add_port(RunContext& context, EnginePort* port) override;
- void remove_port(RunContext& context, EnginePort* port) override;
+ void rename_port(const raul::Path& old_path, const raul::Path& new_path) override;
+ void port_property(const raul::Path& path, const URI& uri, const Atom& value) override;
+ void add_port(RunContext& ctx, EnginePort* port) override;
+ void remove_port(RunContext& ctx, EnginePort* port) override;
void register_port(EnginePort& port) override;
void unregister_port(EnginePort& port) override;
/** Transport state for this frame.
* Intended to only be called from the audio thread. */
- inline const jack_position_t* position() { return &_position; }
- inline jack_transport_state_t transport_state() { return _transport_state; }
+ const jack_position_t* position() { return &_position; }
+ jack_transport_state_t transport_state() { return _transport_state; }
- void append_time_events(RunContext& context, Buffer& buffer) override;
+ void append_time_events(RunContext& ctx, Buffer& buffer) override;
int real_time_priority() override {
return jack_client_real_time_priority(_client);
@@ -94,76 +95,71 @@ public:
jack_client_t* jack_client() const { return _client; }
SampleCount block_length() const override { return _block_length; }
- size_t seq_size() const override { return _seq_size; }
+ uint32_t seq_size() const override { return _seq_size; }
SampleCount sample_rate() const override { return _sample_rate; }
- SampleCount frame_time() const override {
- return _client ? jack_frame_time(_client) : 0;
- }
+ SampleCount frame_time() const override;
- class PortRegistrationFailedException : public std::exception {};
+ class PortRegistrationFailedException : public std::exception
+ {};
private:
friend class JackPort;
+ static void thread_init_cb(void* jack_driver);
+
// Static JACK callbacks which call the non-static callbacks (methods)
- inline static void thread_init_cb(void* const jack_driver) {
- return ((JackDriver*)jack_driver)->_thread_init_cb();
- }
- inline static void shutdown_cb(void* const jack_driver) {
- return ((JackDriver*)jack_driver)->_shutdown_cb();
- }
- inline static int process_cb(jack_nframes_t nframes, void* const jack_driver) {
- return ((JackDriver*)jack_driver)->_process_cb(nframes);
+
+ static void shutdown_cb(void* const jack_driver) {
+ static_cast<JackDriver*>(jack_driver)->_shutdown_cb();
}
- inline static int block_length_cb(jack_nframes_t nframes, void* const jack_driver) {
- return ((JackDriver*)jack_driver)->_block_length_cb(nframes);
+
+ static int process_cb(jack_nframes_t nframes, void* const jack_driver) {
+ return static_cast<JackDriver*>(jack_driver)->_process_cb(nframes);
}
-#ifdef INGEN_JACK_SESSION
- inline static void session_cb(jack_session_event_t* event, void* jack_driver) {
- ((JackDriver*)jack_driver)->_session_cb(event);
+
+ static int block_length_cb(jack_nframes_t nframes, void* const jack_driver) {
+ return static_cast<JackDriver*>(jack_driver)->_block_length_cb(nframes);
}
-#endif
- void pre_process_port(RunContext& context, EnginePort* port);
- void post_process_port(RunContext& context, EnginePort* port);
+ // Internal methods for processing
+
+ void pre_process_port(RunContext& ctx, EnginePort* port);
+ void post_process_port(RunContext& ctx, EnginePort* port) const;
void port_property_internal(const jack_port_t* jport,
const URI& uri,
const Atom& value);
// Non static callbacks (methods)
- void _thread_init_cb();
void _shutdown_cb();
int _process_cb(jack_nframes_t nframes);
int _block_length_cb(jack_nframes_t nframes);
-#ifdef INGEN_JACK_SESSION
- void _session_cb(jack_session_event_t* event);
-#endif
protected:
using Ports = boost::intrusive::slist<EnginePort,
boost::intrusive::cache_last<true>>;
- using AudioBufPtr = UPtr<float, FreeDeleter<float>>;
-
- Engine& _engine;
- Ports _ports;
- AudioBufPtr _fallback_buffer;
- LV2_Atom_Forge _forge;
- Raul::Semaphore _sem;
- std::atomic<bool> _flag;
- jack_client_t* _client;
- jack_nframes_t _block_length;
- size_t _seq_size;
- jack_nframes_t _sample_rate;
- uint32_t _midi_event_type;
- bool _is_activated;
- jack_position_t _position;
- jack_transport_state_t _transport_state;
- float _old_bpm;
- jack_nframes_t _old_frame;
- bool _old_rolling;
+ using AudioBufPtr = std::unique_ptr<float, FreeDeleter<float>>;
+
+ Engine& _engine;
+ Ports _ports;
+ AudioBufPtr _fallback_buffer;
+ LV2_Atom_Forge _forge;
+ raul::Semaphore _sem{0};
+ std::unique_ptr<FrameTimer> _timer;
+ std::atomic<bool> _flag{false};
+ jack_client_t* _client{nullptr};
+ jack_nframes_t _block_length{0};
+ uint32_t _seq_size{0};
+ jack_nframes_t _sample_rate{0};
+ uint32_t _midi_event_type;
+ bool _is_activated{false};
+ jack_position_t _position{};
+ jack_transport_state_t _transport_state{};
+ double _old_bpm{120.0};
+ jack_nframes_t _old_frame{0};
+ bool _old_rolling{false};
};
} // namespace server
generated by cgit v1.2.1 (git 2.18.0) at 2025-07-04 16:16:53 +0000