123 lines
4.4 KiB
C++
123 lines
4.4 KiB
C++
#pragma once
|
|
#include <any>
|
|
#include <google/protobuf/message.h>
|
|
#include <mutex>
|
|
#include <atomic>
|
|
#include <stdint.h>
|
|
#include <future>
|
|
#include <thread>
|
|
#include <string>
|
|
#include <vector>
|
|
#include <memory>
|
|
#include "thirdparty/CRC.hpp"
|
|
#include "playback_backend.hpp"
|
|
#include "rpc.hpp"
|
|
#include <ipc/common.pb.h>
|
|
#include <ipc/internal.pb.h>
|
|
#include <log.hpp>
|
|
#include "options.hpp"
|
|
#include "util.hpp"
|
|
class PlaybackProcess;
|
|
class PlaybackProcessServiceImpl {
|
|
Lock<PlaybackBackend*> cur_backend_lock;
|
|
Lock<DynPtr*> render_ptr;
|
|
public:
|
|
PlaybackProcess *process;
|
|
RenderResponseOrError Render(const RenderCommand *cmd);
|
|
PropertyDataOrError Get(const GetProperty *request);
|
|
MaybeError Set(const SetProperty *request);
|
|
ResetResponse Reset(const ResetProperty *request);
|
|
MaybeError Quit(const QuitCmd *request);
|
|
MaybeError Init(const InitCommand *cmd);
|
|
};
|
|
template<class T>
|
|
inline T *resolve_any(google::protobuf::Any value) {
|
|
T *output = new T();
|
|
value.UnpackTo(output);
|
|
return output;
|
|
}
|
|
//#define DEBUG_PRINT_IPC
|
|
void print_ipc_message(const google::protobuf::Message &msg, size_t level = 0);
|
|
class PlaybackProcess {
|
|
friend class HostProcessImpl;
|
|
friend class PlaybackProcessServiceImpl;
|
|
void threadfunc();
|
|
PlaybackProcess *other_process = nullptr;
|
|
PlaybackProcessServiceImpl impl;
|
|
int pid;
|
|
std::mutex start_mutex;
|
|
std::condition_variable started;
|
|
bool is_playback_process = false;
|
|
std::atomic_bool done;
|
|
RPCResponse SendCommand(RPCCall *msg);
|
|
std::string get_version_code();
|
|
PropertyData get_property(PropertyId id, std::optional<uint64_t> idx = {});
|
|
inline google::protobuf::Any get_property_value_any(PropertyId id, std::optional<uint64_t> idx = {}) {
|
|
PropertyData data = get_property(id, idx);
|
|
return data.value();
|
|
}
|
|
template<class T>
|
|
inline T *get_property_value(PropertyId id, std::optional<uint64_t> idx = {}) {
|
|
if constexpr (std::is_same_v<T, std::string>) {
|
|
auto *property = get_property_value<StringProperty>(id, idx);
|
|
std::string *tmp = new std::string(property->value());
|
|
delete property;
|
|
return tmp;
|
|
} else {
|
|
return resolve_any<T>(get_property_value_any(id, idx));
|
|
}
|
|
}
|
|
inline double get_property_double(PropertyId id, std::optional<uint64_t> idx = {}) {
|
|
auto *property = get_property_value<DoubleProperty>(id, idx);
|
|
double output = double(property->value());
|
|
delete property;
|
|
return output;
|
|
}
|
|
inline std::string get_property_string(PropertyId id, std::optional<uint64_t> idx = {}) {
|
|
auto *property = get_property_value<StringProperty>(id, idx);
|
|
std::string output = std::string(property->value());
|
|
delete property;
|
|
return output;
|
|
}
|
|
void set_property(PropertyId id, PropertyData data, std::optional<uint64_t> idx = {});
|
|
template<class T>
|
|
inline void set_property_value(PropertyId id, T *value, std::optional<uint64_t> idx = {}) {
|
|
PropertyData data;
|
|
data.mutable_value()->PackFrom(*value);
|
|
set_property(id, data, idx);
|
|
}
|
|
inline void set_property_double(PropertyId id, double value, std::optional<uint64_t> idx = {}) {
|
|
PropertyData data;
|
|
DoubleProperty property;
|
|
property.set_value(value);
|
|
data.mutable_value()->PackFrom(property);
|
|
set_property(id, data, idx);
|
|
}
|
|
friend int looper_run_playback_process(std::vector<std::string> args);
|
|
PlaybackProcess(PlaybackProcess *parent);
|
|
PlaybackProcess(std::vector<std::string> args);
|
|
void run_playback_process();
|
|
public:
|
|
bool process_running();
|
|
double get_position();
|
|
double get_length();
|
|
void set_position(double pos);
|
|
size_t get_stream_idx();
|
|
void set_stream_idx(size_t idx);
|
|
std::string get_title();
|
|
std::string get_file_path();
|
|
std::string get_file_name();
|
|
std::string get_backend_id();
|
|
double get_cached_rate();
|
|
void set_rate(double value);
|
|
std::string get_backend_name();
|
|
PlaybackStream get_playback_stream(size_t idx);
|
|
std::vector<PlaybackStream> get_playback_streams();
|
|
AudioSpec *get_audio_spec();
|
|
size_t render(void *buf, size_t maxlen);
|
|
|
|
std::optional<google::protobuf::Any> get_property(std::string path);
|
|
bool set_property(std::string path, google::protobuf::Any value);
|
|
PlaybackProcess(std::string filename, int idx = 0);
|
|
~PlaybackProcess();
|
|
};
|