bt2c::Logger logger;
- /* Owned by this. */
- bt_stream *stream = nullptr;
+ bt2::Stream::Shared stream;
/* Weak reference. */
struct lttng_live_trace *trace = nullptr;
* Since only a single iterator per viewer connection, we have
* only a single message iterator per stream.
*/
- struct ctf_msg_iter *msg_iter = nullptr;
+ ctf_msg_iter_up msg_iter;
uint64_t viewer_stream_id = 0;
/* Timestamp in nanoseconds of the current message (current_msg). */
int64_t current_msg_ts_ns = 0;
- /* Owned by this. */
- uint8_t *buf = nullptr;
- size_t buflen = 0;
+ std::vector<uint8_t> buf;
/* Owned by this. */
GString *name = nullptr;
struct lttng_live_metadata
{
+ using UP = std::unique_ptr<lttng_live_metadata>;
+
explicit lttng_live_metadata(const bt2c::Logger& parentLogger) :
logger {parentLogger, "PLUGIN/SRC.CTF.LTTNG-LIVE/METADATA"}
{
bt2::TraceClass::Shared trace_class;
- struct lttng_live_metadata *metadata = nullptr;
+ lttng_live_metadata::UP metadata;
const bt_clock_class *clock_class = nullptr;
*/
struct lttng_live_component
{
+ using UP = std::unique_ptr<lttng_live_component>;
+
explicit lttng_live_component(bt2c::Logger loggerParam) noexcept :
logger {std::move(loggerParam)}
{
struct
{
- GString *url = nullptr;
+ std::string url;
enum session_not_found_action sess_not_found_act = SESSION_NOT_FOUND_ACTION_CONTINUE;
} params;