#include "../common/src/msg-iter/msg-iter.hpp"
#include "viewer-connection.hpp"
+/*
+ * bt_common_lttng_live_url_parts is defined in common code, and is also used
+ * by C code, so it can't be C++-ified yet. Use this separate deleter object
+ * in the mean time.
+ */
+struct bt_common_lttng_live_url_parts_deleter
+{
+ explicit bt_common_lttng_live_url_parts_deleter(bt_common_lttng_live_url_parts& obj) noexcept :
+ _mObj {&obj}
+ {
+ }
+
+ bt_common_lttng_live_url_parts_deleter(const bt_common_lttng_live_url_parts_deleter&) = delete;
+ bt_common_lttng_live_url_parts&
+ operator=(const bt_common_lttng_live_url_parts_deleter&) = delete;
+
+ ~bt_common_lttng_live_url_parts_deleter()
+ {
+ bt_common_destroy_lttng_live_url_parts(_mObj);
+ }
+
+private:
+ bt_common_lttng_live_url_parts *_mObj;
+};
+
enum lttng_live_stream_state
{
/* This stream won't have data until some known time in the future. */
struct lttng_live_session
{
+ using UP = std::unique_ptr<lttng_live_session>;
+
explicit lttng_live_session(const bt2c::Logger& parentLogger) :
logger {parentLogger, "PLUGIN/SRC.CTF.LTTNG-LIVE/SESSION"}
{
}
+ ~lttng_live_session();
+
bt2c::Logger logger;
bt_self_component *self_comp = nullptr;
struct lttng_live_msg_iter
{
+ using UP = std::unique_ptr<lttng_live_msg_iter>;
+
explicit lttng_live_msg_iter(const bt2c::Logger& parentLogger) :
logger {parentLogger, "PLUGIN/SRC.CTF.LTTNG-LIVE/MSG-ITER"}
{
}
+ ~lttng_live_msg_iter();
+
bt2c::Logger logger;
bt_self_component *self_comp = nullptr;
/* Weak reference. */
bt_self_message_iterator *self_msg_iter = nullptr;
- /* Owned by this. */
- struct live_viewer_connection *viewer_connection = nullptr;
+ live_viewer_connection::UP viewer_connection;
- /* Array of pointers to struct lttng_live_session. */
- GPtrArray *sessions = nullptr;
+ std::vector<lttng_live_session::UP> sessions;
/* Number of live stream iterator this message iterator has.*/
uint64_t active_stream_iter = 0;