This data structure only have sense on the application registry side.
The tracing registry does not directly handle stream anymore. This patch
also move it from trace-ust.h to ust-app.h.
No code was changed nor any behaviors altered.
Signed-off-by: David Goulet <dgoulet@efficios.com>
enum lttng_ust_loglevel_type loglevel;
};
-/* UST Stream list */
-struct ltt_ust_stream_list {
- unsigned int count;
- struct cds_list_head head;
-};
-
/* Context hash table nodes */
struct ltt_ust_context {
struct lttng_ust_context ctx;
struct lttng_ust_filter_bytecode *filter;
};
-/* UST stream */
-struct ltt_ust_stream {
- int handle;
- char pathname[PATH_MAX];
- /* Format is %s_%d respectively channel name and CPU number. */
- char name[DEFAULT_STREAM_NAME_LEN];
- struct lttng_ust_object_data *obj;
- /* Using a list of streams to keep order. */
- struct cds_list_head list;
-};
-
/* UST channel */
struct ltt_ust_channel {
unsigned int enabled;
* this function.
*/
static
-void delete_ust_app_stream(int sock, struct ltt_ust_stream *stream)
+void delete_ust_app_stream(int sock, struct ust_app_stream *stream)
{
if (stream->obj) {
ustctl_release_object(sock, stream->obj);
struct lttng_ht_iter iter;
struct ust_app_event *ua_event;
struct ust_app_ctx *ua_ctx;
- struct ltt_ust_stream *stream, *stmp;
+ struct ust_app_stream *stream, *stmp;
/* Wipe stream */
cds_list_for_each_entry_safe(stream, stmp, &ua_chan->streams.head, list) {
* On error, return a negative value.
*/
static int create_ust_stream(struct ust_app *app,
- struct ust_app_channel *ua_chan, struct ltt_ust_stream *stream)
+ struct ust_app_channel *ua_chan, struct ust_app_stream *stream)
{
int ret;
struct lttng_ht_iter iter;
struct ust_app_session *ua_sess;
struct ust_app_channel *ua_chan;
- struct ltt_ust_stream *ustream;
+ struct ust_app_stream *ustream;
struct consumer_socket *socket;
DBG("Starting tracing for ust app pid %d", app->pid);
*/
struct lttng_ht *ust_app_ht_by_sock;
+/* Stream list containing ust_app_stream. */
+struct ust_app_stream_list {
+ unsigned int count;
+ struct cds_list_head head;
+};
+
struct ust_app_ctx {
int handle;
struct lttng_ust_context ctx;
struct lttng_ust_filter_bytecode *filter;
};
+struct ust_app_stream {
+ int handle;
+ char pathname[PATH_MAX];
+ /* Format is %s_%d respectively channel name and CPU number. */
+ char name[DEFAULT_STREAM_NAME_LEN];
+ struct lttng_ust_object_data *obj;
+ /* Using a list of streams to keep order. */
+ struct cds_list_head list;
+};
+
struct ust_app_channel {
int enabled;
int handle;
char name[LTTNG_UST_SYM_NAME_LEN];
struct lttng_ust_channel attr;
struct lttng_ust_object_data *obj;
- struct ltt_ust_stream_list streams;
+ struct ust_app_stream_list streams;
struct lttng_ht *ctx;
struct lttng_ht *events;
struct lttng_ht_node_str node;
*/
static int send_channel_stream(struct consumer_socket *sock,
struct ust_app_channel *uchan, struct ust_app_session *usess,
- struct ltt_ust_stream *stream, struct consumer_output *consumer,
+ struct ust_app_stream *stream, struct consumer_output *consumer,
const char *pathname)
{
int ret, fds[2];
int ret;
char tmp_path[PATH_MAX];
const char *pathname;
- struct ltt_ust_stream *stream, *tmp;
+ struct ust_app_stream *stream, *tmp;
assert(sock);