Rename ltt_ust_stream to ust_app_stream
authorDavid Goulet <dgoulet@efficios.com>
Mon, 21 Jan 2013 20:20:52 +0000 (15:20 -0500)
committerDavid Goulet <dgoulet@efficios.com>
Mon, 21 Jan 2013 20:24:49 +0000 (15:24 -0500)
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>
src/bin/lttng-sessiond/trace-ust.h
src/bin/lttng-sessiond/ust-app.c
src/bin/lttng-sessiond/ust-app.h
src/bin/lttng-sessiond/ust-consumer.c

index 4004f9af2c5d3573a4de417b9cd7b6bbf5191c57..ab8fbe10576f7a1bb8951627cbe6682f38e8a445 100644 (file)
@@ -35,12 +35,6 @@ struct ltt_ust_ht_key {
        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;
@@ -55,17 +49,6 @@ struct ltt_ust_event {
        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;
index 374360e48c365937a20952e6623e356e21fae41c..397a2dfab29b5f2106f1a235a4ce1a7bfb7f0a7b 100644 (file)
@@ -155,7 +155,7 @@ void delete_ust_app_event(int sock, struct ust_app_event *ua_event)
  * 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);
@@ -176,7 +176,7 @@ void delete_ust_app_channel(int sock, struct ust_app_channel *ua_chan)
        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) {
@@ -757,7 +757,7 @@ error:
  * 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;
 
@@ -2314,7 +2314,7 @@ int ust_app_start_trace(struct ltt_ust_session *usess, struct ust_app *app)
        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);
index 8c23c319d6c41fd6c037f85f43674ff3752ad4af..d4ed5a6f8d26e9b166fb59f519511f3aca99ada6 100644 (file)
@@ -65,6 +65,12 @@ struct lttng_ht *ust_app_ht;
  */
 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;
@@ -82,13 +88,23 @@ struct ust_app_event {
        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;
index e804f4b5ac74284c1c3b0b9ea23a9317b505649f..ffa6429375b3d7c60d67f6545ce5c4a8e7d8d4e5 100644 (file)
@@ -83,7 +83,7 @@ error:
  */
 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];
@@ -140,7 +140,7 @@ static int send_channel_streams(struct consumer_socket *sock,
        int ret;
        char tmp_path[PATH_MAX];
        const char *pathname;
-       struct ltt_ust_stream *stream, *tmp;
+       struct ust_app_stream *stream, *tmp;
 
        assert(sock);
 
This page took 0.040231 seconds and 4 git commands to generate.