struct ust_app_channel *ua_chan,
struct consumer_output *consumer,
struct consumer_socket *socket,
- ust_registry_session *registry,
+ lsu::registry_session *registry,
struct lttng_trace_chunk *trace_chunk)
{
int ret, output;
} else {
{
auto locked_registry = registry->lock();
- auto& ust_reg_chan = registry->get_channel(chan_reg_key);
+ auto& ust_reg_chan = registry->channel(chan_reg_key);
chan_id = ust_reg_chan.id;
}
struct ust_app_channel *ua_chan,
struct consumer_output *consumer,
struct consumer_socket *socket,
- ust_registry_session *registry,
+ lsu::registry_session *registry,
struct lttng_trace_chunk * trace_chunk)
{
int ret;
ssize_t ret_push;
struct lttcomm_metadata_request_msg request;
struct buffer_reg_uid *reg_uid;
- ust_registry_session *ust_reg;
+ lsu::registry_session *ust_reg;
struct lttcomm_consumer_msg msg;
LTTNG_ASSERT(socket);