|
@@ -74,6 +74,9 @@ struct convert {
|
|
|
|
|
|
u64 events_size;
|
|
u64 events_size;
|
|
u64 events_count;
|
|
u64 events_count;
|
|
|
|
+
|
|
|
|
+ /* Ordered events configured queue size. */
|
|
|
|
+ u64 queue_size;
|
|
};
|
|
};
|
|
|
|
|
|
static int value_set(struct bt_ctf_field_type *type,
|
|
static int value_set(struct bt_ctf_field_type *type,
|
|
@@ -968,6 +971,18 @@ static int ctf_writer__flush_streams(struct ctf_writer *cw)
|
|
return ret;
|
|
return ret;
|
|
}
|
|
}
|
|
|
|
|
|
|
|
+static int convert__config(const char *var, const char *value, void *cb)
|
|
|
|
+{
|
|
|
|
+ struct convert *c = cb;
|
|
|
|
+
|
|
|
|
+ if (!strcmp(var, "convert.queue-size")) {
|
|
|
|
+ c->queue_size = perf_config_u64(var, value);
|
|
|
|
+ return 0;
|
|
|
|
+ }
|
|
|
|
+
|
|
|
|
+ return perf_default_config(var, value, cb);
|
|
|
|
+}
|
|
|
|
+
|
|
int bt_convert__perf2ctf(const char *input, const char *path, bool force)
|
|
int bt_convert__perf2ctf(const char *input, const char *path, bool force)
|
|
{
|
|
{
|
|
struct perf_session *session;
|
|
struct perf_session *session;
|
|
@@ -994,6 +1009,8 @@ int bt_convert__perf2ctf(const char *input, const char *path, bool force)
|
|
struct ctf_writer *cw = &c.writer;
|
|
struct ctf_writer *cw = &c.writer;
|
|
int err = -1;
|
|
int err = -1;
|
|
|
|
|
|
|
|
+ perf_config(convert__config, &c);
|
|
|
|
+
|
|
/* CTF writer */
|
|
/* CTF writer */
|
|
if (ctf_writer__init(cw, path))
|
|
if (ctf_writer__init(cw, path))
|
|
return -1;
|
|
return -1;
|
|
@@ -1003,6 +1020,11 @@ int bt_convert__perf2ctf(const char *input, const char *path, bool force)
|
|
if (!session)
|
|
if (!session)
|
|
goto free_writer;
|
|
goto free_writer;
|
|
|
|
|
|
|
|
+ if (c.queue_size) {
|
|
|
|
+ ordered_events__set_alloc_size(&session->ordered_events,
|
|
|
|
+ c.queue_size);
|
|
|
|
+ }
|
|
|
|
+
|
|
/* CTF writer env/clock setup */
|
|
/* CTF writer env/clock setup */
|
|
if (ctf_writer__setup_env(cw, session))
|
|
if (ctf_writer__setup_env(cw, session))
|
|
goto free_session;
|
|
goto free_session;
|