projects
/
babeltrace.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
ctf: save self_msg_iter in ctf_msg_iter when creating it
[babeltrace.git]
/
src
/
plugins
/
ctf
/
common
/
msg-iter
/
msg-iter.c
diff --git
a/src/plugins/ctf/common/msg-iter/msg-iter.c
b/src/plugins/ctf/common/msg-iter/msg-iter.c
index 8f0d663c795f4b5ef687a804ced70bbad723b2b5..5c99aed1e3381989f91fe59d47212ca23ce1dee0 100644
(file)
--- a/
src/plugins/ctf/common/msg-iter/msg-iter.c
+++ b/
src/plugins/ctf/common/msg-iter/msg-iter.c
@@
-2808,10
+2808,13
@@
end:
}
BT_HIDDEN
}
BT_HIDDEN
-struct ctf_msg_iter *ctf_msg_iter_create(struct ctf_trace_class *tc,
+struct ctf_msg_iter *ctf_msg_iter_create(
+ struct ctf_trace_class *tc,
size_t max_request_sz,
struct ctf_msg_iter_medium_ops medops, void *data,
size_t max_request_sz,
struct ctf_msg_iter_medium_ops medops, void *data,
- bt_logging_level log_level, bt_self_component *self_comp)
+ bt_logging_level log_level,
+ bt_self_component *self_comp,
+ bt_self_message_iterator *self_msg_iter)
{
struct ctf_msg_iter *msg_it = NULL;
struct bt_bfcr_cbs cbs = {
{
struct ctf_msg_iter *msg_it = NULL;
struct bt_bfcr_cbs cbs = {
@@
-2846,6
+2849,7
@@
struct ctf_msg_iter *ctf_msg_iter_create(struct ctf_trace_class *tc,
goto end;
}
msg_it->self_comp = self_comp;
goto end;
}
msg_it->self_comp = self_comp;
+ msg_it->self_msg_iter = self_msg_iter;
msg_it->log_level = log_level;
msg_it->meta.tc = tc;
msg_it->medium.medops = medops;
msg_it->log_level = log_level;
msg_it->meta.tc = tc;
msg_it->medium.medops = medops;
@@
-2912,14
+2916,13
@@
void ctf_msg_iter_destroy(struct ctf_msg_iter *msg_it)
enum ctf_msg_iter_status ctf_msg_iter_get_next_message(
struct ctf_msg_iter *msg_it,
enum ctf_msg_iter_status ctf_msg_iter_get_next_message(
struct ctf_msg_iter *msg_it,
- bt_
self_message_iterator *self_msg_iter, bt_
message **message)
+ bt_message **message)
{
enum ctf_msg_iter_status status = CTF_MSG_ITER_STATUS_OK;
bt_self_component *self_comp = msg_it->self_comp;
BT_ASSERT_DBG(msg_it);
BT_ASSERT_DBG(message);
{
enum ctf_msg_iter_status status = CTF_MSG_ITER_STATUS_OK;
bt_self_component *self_comp = msg_it->self_comp;
BT_ASSERT_DBG(msg_it);
BT_ASSERT_DBG(message);
- msg_it->self_msg_iter = self_msg_iter;
msg_it->set_stream = true;
BT_COMP_LOGD("Getting next message: msg-it-addr=%p", msg_it);
msg_it->set_stream = true;
BT_COMP_LOGD("Getting next message: msg-it-addr=%p", msg_it);
This page took
0.027825 seconds
and
4
git commands to generate.