(gpointer) ctf_trace_id);
if (!trace) {
trace = g_new0(struct lttng_live_ctf_trace, 1);
- if (!trace) {
- ret = -1;
- fprintf(stderr, "[error] ctf_trace allocation\n");
- goto error;
- }
trace->ctf_trace_id = ctf_trace_id;
trace->streams = g_ptr_array_new();
g_hash_table_insert(stream->session->ctf_traces,
stream->ctf_trace = trace;
g_ptr_array_add(trace->streams, stream);
-error:
return ret;
}
ctx->session->stream_count);
ctx->session->streams = g_new0(struct lttng_live_viewer_stream,
ctx->session->stream_count);
- if (!ctx->session->streams) {
- ret = -1;
- goto error;
- }
-
for (i = 0; i < be32toh(rp.streams_count); i++) {
do {
ret_len = recv(ctx->control_sock, &stream, sizeof(stream), 0);
opt_payload_field_names = 1;
ctx.session = g_new0(struct lttng_live_session, 1);
- if (!ctx.session) {
- ret = -1;
- goto end;
- }
+
/* We need a pointer to the context from the packet_seek function. */
ctx.session->ctx = &ctx;
end_free:
g_hash_table_destroy(ctx.session->ctf_traces);
g_free(ctx.session);
-end:
g_free(ctx.session->streams);
return ret;
}