projects
/
babeltrace.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
lib: rename "self comp. input port message iter." -> "message iterator"
[babeltrace.git]
/
src
/
plugins
/
ctf
/
fs-sink
/
fs-sink.c
diff --git
a/src/plugins/ctf/fs-sink/fs-sink.c
b/src/plugins/ctf/fs-sink/fs-sink.c
index 9f1ef423b84684ca0403454a9a37fc5458c43e14..2cfc2048cc590bd0e46be4827a459dedcd35fc81 100644
(file)
--- a/
src/plugins/ctf/fs-sink/fs-sink.c
+++ b/
src/plugins/ctf/fs-sink/fs-sink.c
@@
-147,7
+147,7
@@
void destroy_fs_sink_comp(struct fs_sink_comp *fs_sink)
fs_sink->traces = NULL;
}
fs_sink->traces = NULL;
}
- BT_
SELF_COMPONENT_PORT_INPUT_
MESSAGE_ITERATOR_PUT_REF_AND_RESET(
+ BT_MESSAGE_ITERATOR_PUT_REF_AND_RESET(
fs_sink->upstream_iter);
g_free(fs_sink);
fs_sink->upstream_iter);
g_free(fs_sink);
@@
-991,7
+991,7
@@
bt_component_class_sink_consume_method_status ctf_fs_sink_consume(
BT_ASSERT_DBG(fs_sink->upstream_iter);
/* Consume messages */
BT_ASSERT_DBG(fs_sink->upstream_iter);
/* Consume messages */
- next_status = bt_
self_component_port_input_
message_iterator_next(
+ next_status = bt_message_iterator_next(
fs_sink->upstream_iter, &msgs, &msg_count);
if (next_status < 0) {
status = (int) next_status;
fs_sink->upstream_iter, &msgs, &msg_count);
if (next_status < 0) {
status = (int) next_status;
@@
-1090,17
+1090,17
@@
ctf_fs_sink_graph_is_configured(
bt_self_component_sink *self_comp)
{
bt_component_class_sink_graph_is_configured_method_status status;
bt_self_component_sink *self_comp)
{
bt_component_class_sink_graph_is_configured_method_status status;
- bt_
self_component_port_input_
message_iterator_create_from_sink_component_status
+ bt_message_iterator_create_from_sink_component_status
msg_iter_status;
struct fs_sink_comp *fs_sink = bt_self_component_get_data(
bt_self_component_sink_as_self_component(self_comp));
msg_iter_status =
msg_iter_status;
struct fs_sink_comp *fs_sink = bt_self_component_get_data(
bt_self_component_sink_as_self_component(self_comp));
msg_iter_status =
- bt_
self_component_port_input_
message_iterator_create_from_sink_component(
+ bt_message_iterator_create_from_sink_component(
self_comp,
bt_self_component_sink_borrow_input_port_by_name(
self_comp, in_port_name), &fs_sink->upstream_iter);
self_comp,
bt_self_component_sink_borrow_input_port_by_name(
self_comp, in_port_name), &fs_sink->upstream_iter);
- if (msg_iter_status != BT_
SELF_COMPONENT_PORT_INPUT_
MESSAGE_ITERATOR_CREATE_FROM_SINK_COMPONENT_STATUS_OK) {
+ if (msg_iter_status != BT_MESSAGE_ITERATOR_CREATE_FROM_SINK_COMPONENT_STATUS_OK) {
status = (int) msg_iter_status;
goto end;
}
status = (int) msg_iter_status;
goto end;
}
This page took
0.025334 seconds
and
4
git commands to generate.