2 * SPDX-License-Identifier: MIT
4 * Copyright 2010-2011 EfficiOS Inc. and Linux Foundation
5 * Copyright 2017 Philippe Proulx <pproulx@efficios.com>
8 #define BT_COMP_LOG_SELF_COMP (dmesg_comp->self_comp)
9 #define BT_LOG_OUTPUT_LEVEL (dmesg_comp->log_level)
10 #define BT_LOG_TAG "PLUGIN/SRC.TEXT.DMESG"
11 #include "logging/comp-logging.h"
19 #include "common/common.h"
20 #include "common/assert.h"
21 #include <babeltrace2/babeltrace.h>
22 #include "compat/utc.h"
23 #include "compat/stdio.h"
25 #include "plugins/common/param-validation/param-validation.h"
27 #define NSEC_PER_USEC 1000UL
28 #define NSEC_PER_MSEC 1000000UL
29 #define NSEC_PER_SEC 1000000000ULL
30 #define USEC_PER_SEC 1000000UL
32 struct dmesg_component
;
34 struct dmesg_msg_iter
{
35 struct dmesg_component
*dmesg_comp
;
38 bt_self_message_iterator
*self_msg_iter
;
43 bt_message
*tmp_event_msg
;
44 uint64_t last_clock_value
;
47 STATE_EMIT_STREAM_BEGINNING
,
49 STATE_EMIT_STREAM_END
,
54 struct dmesg_component
{
55 bt_logging_level log_level
;
59 bt_bool read_from_stdin
;
63 bt_self_component_source
*self_comp_src
;
64 bt_self_component
*self_comp
;
65 bt_trace_class
*trace_class
;
66 bt_stream_class
*stream_class
;
67 bt_event_class
*event_class
;
70 bt_clock_class
*clock_class
;
74 bt_field_class
*create_event_payload_fc(struct dmesg_component
*dmesg_comp
,
75 bt_trace_class
*trace_class
)
77 bt_field_class
*root_fc
= NULL
;
78 bt_field_class
*fc
= NULL
;
79 bt_field_class_structure_append_member_status append_member_status
;
81 root_fc
= bt_field_class_structure_create(trace_class
);
83 BT_COMP_LOGE_APPEND_CAUSE(dmesg_comp
->self_comp
,
84 "Cannot create an empty structure field class object.");
88 fc
= bt_field_class_string_create(trace_class
);
90 BT_COMP_LOGE_APPEND_CAUSE(dmesg_comp
->self_comp
,
91 "Cannot create a string field class object.");
95 append_member_status
= bt_field_class_structure_append_member(root_fc
,
97 if (append_member_status
!= BT_FIELD_CLASS_STRUCTURE_APPEND_MEMBER_STATUS_OK
) {
98 BT_COMP_LOGE_APPEND_CAUSE(dmesg_comp
->self_comp
,
99 "Cannot add `str` member to structure field class: ret=%d",
100 append_member_status
);
107 BT_FIELD_CLASS_PUT_REF_AND_RESET(root_fc
);
110 bt_field_class_put_ref(fc
);
115 int create_meta(struct dmesg_component
*dmesg_comp
, bool has_ts
)
117 bt_field_class
*fc
= NULL
;
120 dmesg_comp
->trace_class
= bt_trace_class_create(dmesg_comp
->self_comp
);
121 if (!dmesg_comp
->trace_class
) {
122 BT_COMP_LOGE_APPEND_CAUSE(dmesg_comp
->self_comp
,
123 "Cannot create an empty trace class object.");
127 dmesg_comp
->stream_class
= bt_stream_class_create(
128 dmesg_comp
->trace_class
);
129 if (!dmesg_comp
->stream_class
) {
130 BT_COMP_LOGE_APPEND_CAUSE(dmesg_comp
->self_comp
,
131 "Cannot create a stream class object.");
136 dmesg_comp
->clock_class
= bt_clock_class_create(
137 dmesg_comp
->self_comp
);
138 if (!dmesg_comp
->clock_class
) {
139 BT_COMP_LOGE_APPEND_CAUSE(dmesg_comp
->self_comp
,
140 "Cannot create clock class.");
145 * The `dmesg` timestamp's origin is not the Unix epoch,
146 * it's the boot time.
148 bt_clock_class_set_origin_is_unix_epoch(dmesg_comp
->clock_class
,
151 ret
= bt_stream_class_set_default_clock_class(
152 dmesg_comp
->stream_class
, dmesg_comp
->clock_class
);
154 BT_COMP_LOGE_APPEND_CAUSE(dmesg_comp
->self_comp
,
155 "Cannot set stream class's default clock class.");
160 dmesg_comp
->event_class
= bt_event_class_create(
161 dmesg_comp
->stream_class
);
162 if (!dmesg_comp
->event_class
) {
163 BT_COMP_LOGE_APPEND_CAUSE(dmesg_comp
->self_comp
,
164 "Cannot create an event class object.");
168 ret
= bt_event_class_set_name(dmesg_comp
->event_class
, "string");
170 BT_COMP_LOGE_APPEND_CAUSE(dmesg_comp
->self_comp
,
171 "Cannot set event class's name.");
175 fc
= create_event_payload_fc(dmesg_comp
, dmesg_comp
->trace_class
);
177 BT_COMP_LOGE_APPEND_CAUSE(dmesg_comp
->self_comp
,
178 "Cannot create event payload field class.");
182 ret
= bt_event_class_set_payload_field_class(dmesg_comp
->event_class
, fc
);
184 BT_COMP_LOGE_APPEND_CAUSE(dmesg_comp
->self_comp
,
185 "Cannot set event class's event payload field class.");
195 bt_field_class_put_ref(fc
);
200 struct bt_param_validation_map_value_entry_descr dmesg_params
[] = {
201 { "no-extract-timestamp", BT_PARAM_VALIDATION_MAP_VALUE_ENTRY_OPTIONAL
, { .type
= BT_VALUE_TYPE_BOOL
} },
202 { "path", BT_PARAM_VALIDATION_MAP_VALUE_ENTRY_OPTIONAL
, { .type
= BT_VALUE_TYPE_STRING
} },
203 BT_PARAM_VALIDATION_MAP_VALUE_ENTRY_END
207 bt_component_class_initialize_method_status
handle_params(
208 struct dmesg_component
*dmesg_comp
,
209 const bt_value
*params
)
211 const bt_value
*no_timestamp
= NULL
;
212 const bt_value
*path
= NULL
;
213 bt_component_class_initialize_method_status status
;
214 enum bt_param_validation_status validation_status
;
215 gchar
*validate_error
= NULL
;
217 validation_status
= bt_param_validation_validate(params
,
218 dmesg_params
, &validate_error
);
219 if (validation_status
== BT_PARAM_VALIDATION_STATUS_MEMORY_ERROR
) {
220 status
= BT_COMPONENT_CLASS_INITIALIZE_METHOD_STATUS_MEMORY_ERROR
;
222 } else if (validation_status
== BT_PARAM_VALIDATION_STATUS_VALIDATION_ERROR
) {
223 status
= BT_COMPONENT_CLASS_INITIALIZE_METHOD_STATUS_ERROR
;
224 BT_COMP_LOGE_APPEND_CAUSE(dmesg_comp
->self_comp
,
225 "%s", validate_error
);
229 no_timestamp
= bt_value_map_borrow_entry_value_const(params
,
230 "no-extract-timestamp");
232 dmesg_comp
->params
.no_timestamp
=
233 bt_value_bool_get(no_timestamp
);
236 path
= bt_value_map_borrow_entry_value_const(params
, "path");
238 const char *path_str
= bt_value_string_get(path
);
240 g_string_assign(dmesg_comp
->params
.path
, path_str
);
242 dmesg_comp
->params
.read_from_stdin
= true;
245 status
= BT_COMPONENT_CLASS_INITIALIZE_METHOD_STATUS_OK
;
247 g_free(validate_error
);
253 int create_stream_and_trace(struct dmesg_component
*dmesg_comp
)
256 const char *trace_name
= NULL
;
257 gchar
*basename
= NULL
;
259 dmesg_comp
->trace
= bt_trace_create(dmesg_comp
->trace_class
);
260 if (!dmesg_comp
->trace
) {
261 BT_COMP_LOGE_APPEND_CAUSE(dmesg_comp
->self_comp
,
262 "Cannot create trace object.");
266 if (dmesg_comp
->params
.read_from_stdin
) {
267 trace_name
= "STDIN";
269 basename
= g_path_get_basename(dmesg_comp
->params
.path
->str
);
272 if (strcmp(basename
, G_DIR_SEPARATOR_S
) != 0 &&
273 strcmp(basename
, ".") != 0) {
274 trace_name
= basename
;
279 ret
= bt_trace_set_name(dmesg_comp
->trace
, trace_name
);
281 BT_COMP_LOGE_APPEND_CAUSE(dmesg_comp
->self_comp
,
282 "Cannot set trace's name: name=\"%s\"",
288 dmesg_comp
->stream
= bt_stream_create(dmesg_comp
->stream_class
,
290 if (!dmesg_comp
->stream
) {
291 BT_COMP_LOGE_APPEND_CAUSE(dmesg_comp
->self_comp
,
292 "Cannot create stream object.");
308 int try_create_meta_stream(struct dmesg_component
*dmesg_comp
, bool has_ts
)
312 if (dmesg_comp
->trace
) {
313 /* Already created */
317 ret
= create_meta(dmesg_comp
, has_ts
);
319 BT_COMP_LOGE_APPEND_CAUSE(dmesg_comp
->self_comp
,
320 "Cannot create metadata objects: dmesg-comp-addr=%p",
325 ret
= create_stream_and_trace(dmesg_comp
);
327 BT_COMP_LOGE_APPEND_CAUSE(dmesg_comp
->self_comp
,
328 "Cannot create stream object: dmesg-comp-addr=%p",
343 void destroy_dmesg_component(struct dmesg_component
*dmesg_comp
)
349 if (dmesg_comp
->params
.path
) {
350 g_string_free(dmesg_comp
->params
.path
, TRUE
);
353 bt_trace_put_ref(dmesg_comp
->trace
);
354 bt_stream_class_put_ref(dmesg_comp
->stream_class
);
355 bt_event_class_put_ref(dmesg_comp
->event_class
);
356 bt_stream_put_ref(dmesg_comp
->stream
);
357 bt_clock_class_put_ref(dmesg_comp
->clock_class
);
358 bt_trace_class_put_ref(dmesg_comp
->trace_class
);
362 bt_component_class_initialize_method_status
dmesg_init(
363 bt_self_component_source
*self_comp_src
,
364 bt_self_component_source_configuration
*config
,
365 const bt_value
*params
, void *init_method_data
)
367 struct dmesg_component
*dmesg_comp
= g_new0(struct dmesg_component
, 1);
368 bt_component_class_initialize_method_status status
;
369 bt_self_component
*self_comp
=
370 bt_self_component_source_as_self_component(self_comp_src
);
371 const bt_component
*comp
= bt_self_component_as_component(self_comp
);
372 bt_logging_level log_level
= bt_component_get_logging_level(comp
);
373 bt_self_component_add_port_status add_port_status
;
377 * Don't use BT_COMP_LOGE_APPEND_CAUSE, as `dmesg_comp` is not
380 BT_COMP_LOG_CUR_LVL(BT_LOG_ERROR
, log_level
, self_comp
,
381 "Failed to allocate one dmesg component structure.");
382 BT_CURRENT_THREAD_ERROR_APPEND_CAUSE_FROM_COMPONENT(self_comp
,
383 "Failed to allocate one dmesg component structure.");
384 status
= BT_COMPONENT_CLASS_INITIALIZE_METHOD_STATUS_MEMORY_ERROR
;
388 dmesg_comp
->log_level
= log_level
;
389 dmesg_comp
->self_comp
= self_comp
;
390 dmesg_comp
->self_comp_src
= self_comp_src
;
391 dmesg_comp
->params
.path
= g_string_new(NULL
);
392 if (!dmesg_comp
->params
.path
) {
393 BT_COMP_LOGE_APPEND_CAUSE(self_comp
, "Failed to allocate a GString.");
394 status
= BT_COMPONENT_CLASS_INITIALIZE_METHOD_STATUS_MEMORY_ERROR
;
398 status
= handle_params(dmesg_comp
, params
);
399 if (status
!= BT_COMPONENT_CLASS_INITIALIZE_METHOD_STATUS_OK
) {
400 BT_COMP_LOGE_APPEND_CAUSE(self_comp
,
401 "Invalid parameters: comp-addr=%p", self_comp
);
402 status
= BT_COMPONENT_CLASS_INITIALIZE_METHOD_STATUS_ERROR
;
406 if (!dmesg_comp
->params
.read_from_stdin
&&
407 !g_file_test(dmesg_comp
->params
.path
->str
,
408 G_FILE_TEST_IS_REGULAR
)) {
409 BT_COMP_LOGE_APPEND_CAUSE(self_comp
,
410 "Input path is not a regular file: "
411 "comp-addr=%p, path=\"%s\"", self_comp
,
412 dmesg_comp
->params
.path
->str
);
413 status
= BT_COMPONENT_CLASS_INITIALIZE_METHOD_STATUS_ERROR
;
417 add_port_status
= bt_self_component_source_add_output_port(
418 self_comp_src
, "out", NULL
, NULL
);
419 if (add_port_status
!= BT_SELF_COMPONENT_ADD_PORT_STATUS_OK
) {
420 BT_COMP_LOGE_APPEND_CAUSE(self_comp
, "Failed to add output port.");
421 status
= (int) add_port_status
;
425 bt_self_component_set_data(self_comp
, dmesg_comp
);
426 BT_COMP_LOGI_STR("Component initialized.");
428 status
= BT_COMPONENT_CLASS_INITIALIZE_METHOD_STATUS_OK
;
432 destroy_dmesg_component(dmesg_comp
);
433 bt_self_component_set_data(self_comp
, NULL
);
439 void dmesg_finalize(bt_self_component_source
*self_comp
)
441 destroy_dmesg_component(bt_self_component_get_data(
442 bt_self_component_source_as_self_component(self_comp
)));
446 bt_message
*create_init_event_msg_from_line(
447 struct dmesg_msg_iter
*msg_iter
,
448 const char *line
, const char **new_start
)
451 bt_message
*msg
= NULL
;
452 bool has_timestamp
= false;
453 unsigned long sec
, usec
, msec
;
454 unsigned int year
, mon
, mday
, hour
, min
;
457 struct dmesg_component
*dmesg_comp
= msg_iter
->dmesg_comp
;
461 if (dmesg_comp
->params
.no_timestamp
) {
465 /* Extract time from input line */
466 if (sscanf(line
, "[%lu.%lu] ", &sec
, &usec
) == 2) {
467 ts
= (uint64_t) sec
* USEC_PER_SEC
+ (uint64_t) usec
;
470 * The clock class we use has a 1 GHz frequency: convert
474 has_timestamp
= true;
475 } else if (sscanf(line
, "[%u-%u-%u %u:%u:%lu.%lu] ",
476 &year
, &mon
, &mday
, &hour
, &min
,
481 memset(&ti
, 0, sizeof(ti
));
482 ti
.tm_year
= year
- 1900; /* From 1900 */
483 ti
.tm_mon
= mon
- 1; /* 0 to 11 */
489 ep_sec
= bt_timegm(&ti
);
490 if (ep_sec
!= (time_t) -1) {
491 ts
= (uint64_t) ep_sec
* NSEC_PER_SEC
492 + (uint64_t) msec
* NSEC_PER_MSEC
;
495 has_timestamp
= true;
499 /* Set new start for the message portion of the line */
500 *new_start
= strchr(line
, ']');
501 BT_ASSERT_DBG(*new_start
);
504 if ((*new_start
)[0] == ' ') {
511 * At this point, we know if the stream class's event header
512 * field class should have a timestamp or not, so we can lazily
513 * create the metadata and stream objects.
515 ret
= try_create_meta_stream(dmesg_comp
, has_timestamp
);
517 /* try_create_meta_stream() logs errors */
521 if (dmesg_comp
->clock_class
) {
522 msg
= bt_message_event_create_with_default_clock_snapshot(
523 msg_iter
->self_msg_iter
,
524 dmesg_comp
->event_class
, dmesg_comp
->stream
, ts
);
525 msg_iter
->last_clock_value
= ts
;
527 msg
= bt_message_event_create(msg_iter
->self_msg_iter
,
528 dmesg_comp
->event_class
, dmesg_comp
->stream
);
532 BT_COMP_LOGE_APPEND_CAUSE(dmesg_comp
->self_comp
,
533 "Cannot create event message.");
537 event
= bt_message_event_borrow_event(msg
);
538 BT_ASSERT_DBG(event
);
542 BT_MESSAGE_PUT_REF_AND_RESET(msg
);
549 int fill_event_payload_from_line(struct dmesg_component
*dmesg_comp
,
550 const char *line
, bt_event
*event
)
552 bt_field
*ep_field
= NULL
;
553 bt_field
*str_field
= NULL
;
557 ep_field
= bt_event_borrow_payload_field(event
);
558 BT_ASSERT_DBG(ep_field
);
559 str_field
= bt_field_structure_borrow_member_field_by_index(
562 BT_COMP_LOGE_APPEND_CAUSE(dmesg_comp
->self_comp
,
563 "Cannot borrow `timestamp` field from event payload structure field.");
568 if (line
[len
- 1] == '\n') {
569 /* Do not include the newline character in the payload */
573 bt_field_string_clear(str_field
);
574 ret
= bt_field_string_append_with_length(str_field
, line
, len
);
576 BT_COMP_LOGE_APPEND_CAUSE(dmesg_comp
->self_comp
,
577 "Cannot append value to string field object: len=%zu", len
);
591 bt_message
*create_msg_from_line(
592 struct dmesg_msg_iter
*dmesg_msg_iter
, const char *line
)
594 struct dmesg_component
*dmesg_comp
= dmesg_msg_iter
->dmesg_comp
;
595 bt_event
*event
= NULL
;
596 bt_message
*msg
= NULL
;
597 const char *new_start
;
600 msg
= create_init_event_msg_from_line(dmesg_msg_iter
,
603 BT_COMP_LOGE_APPEND_CAUSE(dmesg_comp
->self_comp
,
604 "Cannot create and initialize event message from line.");
608 event
= bt_message_event_borrow_event(msg
);
609 BT_ASSERT_DBG(event
);
610 ret
= fill_event_payload_from_line(dmesg_comp
, new_start
, event
);
612 BT_COMP_LOGE_APPEND_CAUSE(dmesg_comp
->self_comp
,
613 "Cannot fill event payload field from line: ret=%d", ret
);
620 BT_MESSAGE_PUT_REF_AND_RESET(msg
);
627 void destroy_dmesg_msg_iter(struct dmesg_msg_iter
*dmesg_msg_iter
)
629 struct dmesg_component
*dmesg_comp
;
631 if (!dmesg_msg_iter
) {
635 dmesg_comp
= dmesg_msg_iter
->dmesg_comp
;
637 if (dmesg_msg_iter
->fp
&& dmesg_msg_iter
->fp
!= stdin
) {
638 if (fclose(dmesg_msg_iter
->fp
)) {
639 BT_COMP_LOGE_APPEND_CAUSE_ERRNO(dmesg_comp
->self_comp
,
640 "Cannot close input file", ".");
644 bt_message_put_ref(dmesg_msg_iter
->tmp_event_msg
);
645 free(dmesg_msg_iter
->linebuf
);
646 g_free(dmesg_msg_iter
);
651 bt_message_iterator_class_initialize_method_status
dmesg_msg_iter_init(
652 bt_self_message_iterator
*self_msg_iter
,
653 bt_self_message_iterator_configuration
*config
,
654 bt_self_component_port_output
*self_port
)
656 bt_self_component
*self_comp
=
657 bt_self_message_iterator_borrow_component(self_msg_iter
);
658 struct dmesg_component
*dmesg_comp
= bt_self_component_get_data(self_comp
);
659 struct dmesg_msg_iter
*dmesg_msg_iter
=
660 g_new0(struct dmesg_msg_iter
, 1);
661 bt_message_iterator_class_initialize_method_status status
;
663 if (!dmesg_msg_iter
) {
664 BT_COMP_LOGE_APPEND_CAUSE(self_comp
,
665 "Failed to allocate on dmesg message iterator structure.");
666 status
= BT_MESSAGE_ITERATOR_CLASS_INITIALIZE_METHOD_STATUS_MEMORY_ERROR
;
670 BT_ASSERT(dmesg_comp
);
671 dmesg_msg_iter
->dmesg_comp
= dmesg_comp
;
672 dmesg_msg_iter
->self_msg_iter
= self_msg_iter
;
674 if (dmesg_comp
->params
.read_from_stdin
) {
675 dmesg_msg_iter
->fp
= stdin
;
677 dmesg_msg_iter
->fp
= fopen(dmesg_comp
->params
.path
->str
, "r");
678 if (!dmesg_msg_iter
->fp
) {
679 BT_COMP_LOGE_APPEND_CAUSE_ERRNO(self_comp
,
680 "Cannot open input file in read mode", ": path=\"%s\"",
681 dmesg_comp
->params
.path
->str
);
682 status
= BT_MESSAGE_ITERATOR_CLASS_INITIALIZE_METHOD_STATUS_ERROR
;
687 bt_self_message_iterator_set_data(self_msg_iter
,
690 status
= BT_MESSAGE_ITERATOR_CLASS_INITIALIZE_METHOD_STATUS_OK
;
694 destroy_dmesg_msg_iter(dmesg_msg_iter
);
695 bt_self_message_iterator_set_data(self_msg_iter
, NULL
);
701 void dmesg_msg_iter_finalize(
702 bt_self_message_iterator
*priv_msg_iter
)
704 destroy_dmesg_msg_iter(bt_self_message_iterator_get_data(
709 bt_message_iterator_class_next_method_status
dmesg_msg_iter_next_one(
710 struct dmesg_msg_iter
*dmesg_msg_iter
,
714 struct dmesg_component
*dmesg_comp
;
715 bt_message_iterator_class_next_method_status status
;
717 BT_ASSERT_DBG(dmesg_msg_iter
);
718 dmesg_comp
= dmesg_msg_iter
->dmesg_comp
;
719 BT_ASSERT_DBG(dmesg_comp
);
721 if (dmesg_msg_iter
->state
== STATE_DONE
) {
722 status
= BT_MESSAGE_ITERATOR_CLASS_NEXT_METHOD_STATUS_END
;
726 if (dmesg_msg_iter
->tmp_event_msg
||
727 dmesg_msg_iter
->state
== STATE_EMIT_STREAM_END
) {
733 bool only_spaces
= true;
735 len
= bt_getline(&dmesg_msg_iter
->linebuf
,
736 &dmesg_msg_iter
->linebuf_len
, dmesg_msg_iter
->fp
);
738 if (errno
== EINVAL
) {
739 status
= BT_MESSAGE_ITERATOR_CLASS_NEXT_METHOD_STATUS_ERROR
;
741 } else if (errno
== ENOMEM
) {
742 status
= BT_MESSAGE_ITERATOR_CLASS_NEXT_METHOD_STATUS_MEMORY_ERROR
;
745 if (dmesg_msg_iter
->state
== STATE_EMIT_STREAM_BEGINNING
) {
746 /* Stream did not even begin */
747 status
= BT_MESSAGE_ITERATOR_CLASS_NEXT_METHOD_STATUS_END
;
751 dmesg_msg_iter
->state
=
752 STATE_EMIT_STREAM_END
;
758 BT_ASSERT_DBG(dmesg_msg_iter
->linebuf
);
760 /* Ignore empty lines, once trimmed */
761 for (ch
= dmesg_msg_iter
->linebuf
; *ch
!= '\0'; ch
++) {
762 if (!isspace((unsigned char) *ch
)) {
773 dmesg_msg_iter
->tmp_event_msg
= create_msg_from_line(
774 dmesg_msg_iter
, dmesg_msg_iter
->linebuf
);
775 if (!dmesg_msg_iter
->tmp_event_msg
) {
776 BT_COMP_LOGE_APPEND_CAUSE(dmesg_comp
->self_comp
,
777 "Cannot create event message from line: "
778 "dmesg-comp-addr=%p, line=\"%s\"", dmesg_comp
,
779 dmesg_msg_iter
->linebuf
);
780 status
= BT_MESSAGE_ITERATOR_CLASS_NEXT_METHOD_STATUS_ERROR
;
785 BT_ASSERT_DBG(dmesg_comp
->trace
);
787 switch (dmesg_msg_iter
->state
) {
788 case STATE_EMIT_STREAM_BEGINNING
:
789 BT_ASSERT_DBG(dmesg_msg_iter
->tmp_event_msg
);
790 *msg
= bt_message_stream_beginning_create(
791 dmesg_msg_iter
->self_msg_iter
, dmesg_comp
->stream
);
792 dmesg_msg_iter
->state
= STATE_EMIT_EVENT
;
794 case STATE_EMIT_EVENT
:
795 BT_ASSERT_DBG(dmesg_msg_iter
->tmp_event_msg
);
796 *msg
= dmesg_msg_iter
->tmp_event_msg
;
797 dmesg_msg_iter
->tmp_event_msg
= NULL
;
799 case STATE_EMIT_STREAM_END
:
800 *msg
= bt_message_stream_end_create(
801 dmesg_msg_iter
->self_msg_iter
, dmesg_comp
->stream
);
802 dmesg_msg_iter
->state
= STATE_DONE
;
809 BT_COMP_LOGE_APPEND_CAUSE(dmesg_comp
->self_comp
,
810 "Cannot create message: dmesg-comp-addr=%p",
812 status
= BT_MESSAGE_ITERATOR_CLASS_NEXT_METHOD_STATUS_ERROR
;
816 status
= BT_MESSAGE_ITERATOR_CLASS_NEXT_METHOD_STATUS_OK
;
822 bt_message_iterator_class_next_method_status
dmesg_msg_iter_next(
823 bt_self_message_iterator
*self_msg_iter
,
824 bt_message_array_const msgs
, uint64_t capacity
,
827 struct dmesg_msg_iter
*dmesg_msg_iter
=
828 bt_self_message_iterator_get_data(
830 bt_message_iterator_class_next_method_status status
=
831 BT_MESSAGE_ITERATOR_CLASS_NEXT_METHOD_STATUS_OK
;
834 while (i
< capacity
&&
835 status
== BT_MESSAGE_ITERATOR_CLASS_NEXT_METHOD_STATUS_OK
) {
836 bt_message
*priv_msg
= NULL
;
838 status
= dmesg_msg_iter_next_one(dmesg_msg_iter
,
841 if (status
== BT_MESSAGE_ITERATOR_CLASS_NEXT_METHOD_STATUS_OK
) {
848 * Even if dmesg_msg_iter_next_one() returned
849 * something else than
850 * BT_SELF_MESSAGE_ITERATOR_STATUS_OK, we
851 * accumulated message objects in the output
852 * message array, so we need to return
853 * BT_SELF_MESSAGE_ITERATOR_STATUS_OK so that they
854 * are transfered to downstream. This other status
855 * occurs again the next time muxer_msg_iter_do_next()
856 * is called, possibly without any accumulated
857 * message, in which case we'll return it.
860 status
= BT_MESSAGE_ITERATOR_CLASS_NEXT_METHOD_STATUS_OK
;
866 bt_message_iterator_class_can_seek_beginning_method_status
867 dmesg_msg_iter_can_seek_beginning(
868 bt_self_message_iterator
*self_msg_iter
, bt_bool
*can_seek
)
870 struct dmesg_msg_iter
*dmesg_msg_iter
=
871 bt_self_message_iterator_get_data(self_msg_iter
);
873 /* Can't seek the beginning of the standard input stream */
874 *can_seek
= !dmesg_msg_iter
->dmesg_comp
->params
.read_from_stdin
;
876 return BT_MESSAGE_ITERATOR_CLASS_CAN_SEEK_BEGINNING_METHOD_STATUS_OK
;
879 bt_message_iterator_class_seek_beginning_method_status
880 dmesg_msg_iter_seek_beginning(
881 bt_self_message_iterator
*self_msg_iter
)
883 struct dmesg_msg_iter
*dmesg_msg_iter
=
884 bt_self_message_iterator_get_data(self_msg_iter
);
886 BT_ASSERT(!dmesg_msg_iter
->dmesg_comp
->params
.read_from_stdin
);
888 BT_MESSAGE_PUT_REF_AND_RESET(dmesg_msg_iter
->tmp_event_msg
);
889 dmesg_msg_iter
->last_clock_value
= 0;
890 dmesg_msg_iter
->state
= STATE_EMIT_STREAM_BEGINNING
;
891 return BT_MESSAGE_ITERATOR_CLASS_SEEK_BEGINNING_METHOD_STATUS_OK
;