projects
/
babeltrace.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
Init ctf fs data and metadata streams
[babeltrace.git]
/
plugins
/
ctf
/
fs
/
fs.c
diff --git
a/plugins/ctf/fs/fs.c
b/plugins/ctf/fs/fs.c
index 9019543eea6595268e81f0183eccd93b114bced4..6c7f2030b994a01c0a73a2b643916971c11b68b1 100644
(file)
--- a/
plugins/ctf/fs/fs.c
+++ b/
plugins/ctf/fs/fs.c
@@
-32,6
+32,8
@@
#include <assert.h>
#include <unistd.h>
#include "fs.h"
#include <assert.h>
#include <unistd.h>
#include "fs.h"
+#include "metadata.h"
+#include "data-stream.h"
static bool ctf_fs_debug;
static bool ctf_fs_debug;
@@
-67,8
+69,8
@@
static
enum bt_component_status ctf_fs_iterator_init(struct bt_component *source,
struct bt_notification_iterator *it)
{
enum bt_component_status ctf_fs_iterator_init(struct bt_component *source,
struct bt_notification_iterator *it)
{
- enum bt_component_status ret = BT_COMPONENT_STATUS_OK;
struct ctf_fs_iterator *ctf_it;
struct ctf_fs_iterator *ctf_it;
+ enum bt_component_status ret = BT_COMPONENT_STATUS_OK;
assert(source && it);
ctf_it = g_new0(struct ctf_fs_iterator, 1);
assert(source && it);
ctf_it = g_new0(struct ctf_fs_iterator, 1);
@@
-112,8
+114,8
@@
void ctf_fs_destroy_data(struct ctf_fs_component *component)
g_string_free(component->trace_path, TRUE);
}
g_string_free(component->trace_path, TRUE);
}
-
//
ctf_fs_metadata_fini(&component->metadata);
-
//
ctf_fs_data_stream_fini(&component->data_stream);
+
ctf_fs_metadata_fini(&component->metadata);
+
ctf_fs_data_stream_fini(&component->data_stream);
g_free(component);
}
g_free(component);
}
@@
-156,7
+158,9
@@
struct ctf_fs_component *ctf_fs_create(struct bt_value *params)
ctf_fs->error_fp = stderr;
ctf_fs->page_size = (size_t) getpagesize();
ctf_fs->error_fp = stderr;
ctf_fs->page_size = (size_t) getpagesize();
-
+ ctf_fs_data_stream_init(ctf_fs, &ctf_fs->data_stream);
+ ctf_fs_metadata_set_trace(ctf_fs);
+ ctf_fs_data_stream_open_streams(ctf_fs);
end:
return ctf_fs;
error:
end:
return ctf_fs;
error:
@@
-194,6
+198,7
@@
enum bt_component_status ctf_fs_init(struct bt_component *source,
if (ret != BT_COMPONENT_STATUS_OK) {
goto error;
}
if (ret != BT_COMPONENT_STATUS_OK) {
goto error;
}
+
end:
return ret;
error:
end:
return ret;
error:
This page took
0.035739 seconds
and
4
git commands to generate.