2 * Copyright (C) 2022 Jérémie Galarneau <jeremie.galarneau@efficios.com>
4 * SPDX-License-Identifier: GPL-2.0-only
8 #ifndef LTTNG_UST_REGISTRY_CHANNEL_H
9 #define LTTNG_UST_REGISTRY_CHANNEL_H
11 #include "stream-class.hpp"
12 #include "trace-class.hpp"
14 #include <common/hashtable/hashtable.hpp>
16 #include <lttng/lttng.h>
29 class registry_channel : public lttng::sessiond::trace::stream_class {
31 using registered_listener_fn = std::function<void(const registry_channel&)>;
32 using event_added_listener_fn = std::function<void(const registry_channel&, const registry_event &)>;
34 registry_channel(uint32_t channel_id,
35 const lttng::sessiond::trace::abi& trace_abi,
36 std::string default_clock_class_name,
37 registered_listener_fn channel_registered_listener,
38 event_added_listener_fn new_event_listener);
39 void add_event(int session_objd,
42 std::string signature,
43 std::vector<lttng::sessiond::trace::field::cuptr> event_fields,
45 nonstd::optional<std::string> model_emf_uri,
46 lttng_buffer_type buffer_type,
48 uint32_t& out_event_id);
49 virtual ~registry_channel();
51 virtual const lttng::sessiond::trace::type *event_context() const override final;
52 void event_context(lttng::sessiond::trace::type::cuptr context);
54 /* Channel was registered to at least one application. */
55 bool is_registered() const;
56 void set_as_registered();
59 uint64_t _consumer_key;
62 * Hash table containing events sent by the UST tracer. MUST be accessed
63 * with a RCU read side lock acquired.
65 struct lttng_ht *_events;
66 struct lttng_ht_node_u64 _node;
67 /* For delayed reclaim */
68 struct rcu_head _rcu_head;
69 /* Once this value reaches UINT32_MAX, no more id can be allocated. */
70 uint32_t _next_event_id;
73 virtual void _accept_on_event_classes(
74 lttng::sessiond::trace::trace_class_visitor& trace_class_visitor) const override final;
76 registered_listener_fn _is_registered_listener;
77 event_added_listener_fn _event_added_listener;
78 /* Indicates if this channel registry has already been registered. */
83 } /* namespace sessiond */
84 } /* namespace lttng */
86 #endif /* LTTNG_UST_REGISTRY_CHANNEL_H */