projects
/
babeltrace.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
Implement logging in lttng-live component
[babeltrace.git]
/
plugins
/
ctf
/
lttng-live
/
metadata.c
diff --git
a/plugins/ctf/lttng-live/metadata.c
b/plugins/ctf/lttng-live/metadata.c
index b176e114ea80873380ea64e3192ceba50daebc48..3124ff6c584d3dee2aaad5ed8b91ed9e4dcfe639 100644
(file)
--- a/
plugins/ctf/lttng-live/metadata.c
+++ b/
plugins/ctf/lttng-live/metadata.c
@@
-31,10
+31,7
@@
#include <babeltrace/compat/uuid-internal.h>
#include <babeltrace/compat/memstream-internal.h>
#include <babeltrace/compat/uuid-internal.h>
#include <babeltrace/compat/memstream-internal.h>
-#define PRINT_ERR_STREAM lttng_live->error_fp
-#define PRINT_PREFIX "lttng-live-metadata"
-#define PRINT_DBG_CHECK lttng_live_debug
-#include "../print.h"
+#define BT_LOG_TAG "PLUGIN-CTF-LTTNG-LIVE-METADATA"
#include "metadata.h"
#include "../common/metadata/decoder.h"
#include "metadata.h"
#include "../common/metadata/decoder.h"
@@
-98,7
+95,6
@@
enum bt_ctf_lttng_live_iterator_status lttng_live_metadata_update(
struct lttng_live_trace *trace)
{
struct lttng_live_session *session = trace->session;
struct lttng_live_trace *trace)
{
struct lttng_live_session *session = trace->session;
- struct lttng_live_component *lttng_live = session->lttng_live;
struct lttng_live_metadata *metadata = trace->metadata;
ssize_t ret = 0;
size_t size, len_read = 0;
struct lttng_live_metadata *metadata = trace->metadata;
ssize_t ret = 0;
size_t size, len_read = 0;
@@
-126,7
+122,7
@@
enum bt_ctf_lttng_live_iterator_status lttng_live_metadata_update(
/* Open for writing */
fp = bt_open_memstream(&metadata_buf, &size);
if (!fp) {
/* Open for writing */
fp = bt_open_memstream(&metadata_buf, &size);
if (!fp) {
-
PERR("Metadata open_memstream: %s\n
", strerror(errno));
+
BT_LOGE("Metadata open_memstream: %s
", strerror(errno));
goto error;
}
goto error;
}
@@
-182,7
+178,7
@@
enum bt_ctf_lttng_live_iterator_status lttng_live_metadata_update(
fp = bt_fmemopen(metadata_buf, len_read, "rb");
if (!fp) {
fp = bt_fmemopen(metadata_buf, len_read, "rb");
if (!fp) {
-
PERR("Cannot memory-open metadata buffer: %s\n
",
+
BT_LOGE("Cannot memory-open metadata buffer: %s
",
strerror(errno));
goto error;
}
strerror(errno));
goto error;
}
@@
-216,7
+212,7
@@
end:
closeret = fclose(fp);
if (closeret) {
closeret = fclose(fp);
if (closeret) {
-
PERR
("Error on fclose");
+
BT_LOGE
("Error on fclose");
}
}
return status;
}
}
return status;
@@
-236,8
+232,7
@@
int lttng_live_metadata_create_stream(struct lttng_live_session *session,
}
metadata->stream_id = stream_id;
//TODO: add clock offset option
}
metadata->stream_id = stream_id;
//TODO: add clock offset option
- metadata->decoder = ctf_metadata_decoder_create(
- session->lttng_live->error_fp, 0);
+ metadata->decoder = ctf_metadata_decoder_create(stderr, 0);
if (!metadata->decoder) {
goto error;
}
if (!metadata->decoder) {
goto error;
}
This page took
0.023844 seconds
and
4
git commands to generate.