Rename pc_msg_iter fields to self_msg_iter
authorSimon Marchi <simon.marchi@efficios.com>
Sun, 3 Nov 2019 03:23:03 +0000 (23:23 -0400)
committerSimon Marchi <simon.marchi@efficios.com>
Mon, 4 Nov 2019 18:45:32 +0000 (13:45 -0500)
The pc prefix means "private connection", which is not a concept
present in the API anymore.  Rename to "self_msg_iter", which is a more
contemporary term.

Change-Id: I76ab362cab05d1dd480549fc285060854375e1e7
Signed-off-by: Simon Marchi <simon.marchi@efficios.com>
Reviewed-on: https://review.lttng.org/c/babeltrace/+/2321
CI-Build: Francis Deslauriers <francis.deslauriers@efficios.com>
Tested-by: jenkins <jenkins@lttng.org>
Reviewed-by: Francis Deslauriers <francis.deslauriers@efficios.com>
src/plugins/ctf/fs-src/data-stream-file.c
src/plugins/ctf/fs-src/data-stream-file.h
src/plugins/ctf/fs-src/fs.c
src/plugins/ctf/fs-src/fs.h
src/plugins/text/dmesg/dmesg.c

index ff2b3d8bd0ba12c5eee7940f528710e3ad5dba9b..20b60cce70792475e78af132c3c4fee0e549f2c1 100644 (file)
@@ -648,7 +648,7 @@ struct ctf_fs_ds_file *ctf_fs_ds_file_create(
 
        ds_file->log_level = log_level;
        ds_file->self_comp = ctf_fs_trace->self_comp;
-       ds_file->pc_msg_iter = pc_msg_iter;
+       ds_file->self_msg_iter = pc_msg_iter;
        ds_file->file = ctf_fs_file_create(log_level, ds_file->self_comp);
        if (!ds_file->file) {
                goto error;
@@ -755,7 +755,7 @@ bt_component_class_message_iterator_next_method_status ctf_fs_ds_file_next(
        bt_component_class_message_iterator_next_method_status status;
 
        msg_iter_status = bt_msg_iter_get_next_message(
-               ds_file->msg_iter, ds_file->pc_msg_iter, msg);
+               ds_file->msg_iter, ds_file->self_msg_iter, msg);
 
        switch (msg_iter_status) {
        case BT_MSG_ITER_STATUS_EOF:
index af81915d829705ca3a43fbe8e4912822ac18b112..0517020e21c6a9f3431ecb3a17136eb7ec427dc0 100644 (file)
@@ -54,10 +54,10 @@ struct ctf_fs_ds_file {
        bt_self_component *self_comp;
 
        /* Weak */
-       struct ctf_fs_metadata *metadata;
+       bt_self_message_iterator *self_msg_iter;
 
        /* Weak */
-       bt_self_message_iterator *pc_msg_iter;
+       struct ctf_fs_metadata *metadata;
 
        /* Owned by this */
        struct ctf_fs_file *file;
index c9315227518536a6685743fd9fb7b6fb65e17397..f03a363535b18933ae2d343a812b47d1e74c55b3 100644 (file)
@@ -69,7 +69,7 @@ int msg_iter_data_set_current_ds_file(struct ctf_fs_msg_iter_data *msg_iter_data
        ctf_fs_ds_file_destroy(msg_iter_data->ds_file);
        msg_iter_data->ds_file = ctf_fs_ds_file_create(
                msg_iter_data->ds_file_group->ctf_fs_trace,
-               msg_iter_data->pc_msg_iter,
+               msg_iter_data->self_msg_iter,
                msg_iter_data->msg_iter,
                msg_iter_data->ds_file_group->stream,
                ds_file_info->path->str,
@@ -276,7 +276,7 @@ bt_component_class_message_iterator_initialize_method_status ctf_fs_iterator_ini
 
        msg_iter_data->log_level = log_level;
        msg_iter_data->self_comp = self_comp;
-       msg_iter_data->pc_msg_iter = self_msg_iter;
+       msg_iter_data->self_msg_iter = self_msg_iter;
        msg_iter_data->msg_iter = bt_msg_iter_create(
                port_data->ds_file_group->ctf_fs_trace->metadata->tc,
                bt_common_get_page_size(msg_iter_data->log_level) * 8,
index e645f17706b68026a2fd99b81067e0f8b3d96d1e..bf2e254e91efe4e349e8b882be2a8c4e2559e852 100644 (file)
@@ -181,7 +181,7 @@ struct ctf_fs_msg_iter_data {
        bt_self_component *self_comp;
 
        /* Weak */
-       bt_self_message_iterator *pc_msg_iter;
+       bt_self_message_iterator *self_msg_iter;
 
        /* Weak, belongs to ctf_fs_trace */
        struct ctf_fs_ds_file_group *ds_file_group;
index c516672c6ee6c454ba5a291ea74896d586bd4bdc..0d755e73339055525021b6fe741228dc773e4dc7 100644 (file)
@@ -49,7 +49,10 @@ struct dmesg_component;
 
 struct dmesg_msg_iter {
        struct dmesg_component *dmesg_comp;
-       bt_self_message_iterator *pc_msg_iter; /* Weak */
+
+       /* Weak */
+       bt_self_message_iterator *self_msg_iter;
+
        char *linebuf;
        size_t linebuf_len;
        FILE *fp;
@@ -533,11 +536,11 @@ skip_ts:
 
        if (dmesg_comp->clock_class) {
                msg = bt_message_event_create_with_default_clock_snapshot(
-                       msg_iter->pc_msg_iter,
+                       msg_iter->self_msg_iter,
                        dmesg_comp->event_class, dmesg_comp->stream, ts);
                msg_iter->last_clock_value = ts;
        } else {
-               msg = bt_message_event_create(msg_iter->pc_msg_iter,
+               msg = bt_message_event_create(msg_iter->self_msg_iter,
                        dmesg_comp->event_class, dmesg_comp->stream);
        }
 
@@ -678,7 +681,7 @@ bt_component_class_message_iterator_initialize_method_status dmesg_msg_iter_init
 
        BT_ASSERT(dmesg_comp);
        dmesg_msg_iter->dmesg_comp = dmesg_comp;
-       dmesg_msg_iter->pc_msg_iter = self_msg_iter;
+       dmesg_msg_iter->self_msg_iter = self_msg_iter;
 
        if (dmesg_comp->params.read_from_stdin) {
                dmesg_msg_iter->fp = stdin;
@@ -796,7 +799,7 @@ handle_state:
        case STATE_EMIT_STREAM_BEGINNING:
                BT_ASSERT_DBG(dmesg_msg_iter->tmp_event_msg);
                *msg = bt_message_stream_beginning_create(
-                       dmesg_msg_iter->pc_msg_iter, dmesg_comp->stream);
+                       dmesg_msg_iter->self_msg_iter, dmesg_comp->stream);
                dmesg_msg_iter->state = STATE_EMIT_EVENT;
                break;
        case STATE_EMIT_EVENT:
@@ -806,7 +809,7 @@ handle_state:
                break;
        case STATE_EMIT_STREAM_END:
                *msg = bt_message_stream_end_create(
-                       dmesg_msg_iter->pc_msg_iter, dmesg_comp->stream);
+                       dmesg_msg_iter->self_msg_iter, dmesg_comp->stream);
                dmesg_msg_iter->state = STATE_DONE;
                break;
        default:
This page took 0.029329 seconds and 4 git commands to generate.