X-Git-Url: https://git.efficios.com/?a=blobdiff_plain;f=plugins%2Flibctfcopytrace%2Fctfcopytrace.c;h=d3373c1e7c015fe4c068da7f87414e228e0a6491;hb=c8cb4c2aa30e49e20a8b0071705215a1a1172f3f;hp=f5cd071a142527b558032f9878cc79aa98088a28;hpb=d40cfeb9b211d1e7e86f29b55582fd5a3e351ed3;p=babeltrace.git

diff --git a/plugins/libctfcopytrace/ctfcopytrace.c b/plugins/libctfcopytrace/ctfcopytrace.c
index f5cd071a..d3373c1e 100644
--- a/plugins/libctfcopytrace/ctfcopytrace.c
+++ b/plugins/libctfcopytrace/ctfcopytrace.c
@@ -466,6 +466,79 @@ end:
 	return writer_stream_class;
 }
 
+BT_HIDDEN
+int ctf_stream_copy_packet_header(FILE *err, struct bt_ctf_packet *packet,
+		struct bt_ctf_stream *writer_stream)
+{
+	struct bt_ctf_field *packet_header = NULL, *writer_packet_header = NULL;
+	int ret = 0;
+
+	packet_header = bt_ctf_packet_get_header(packet);
+	if (!packet_header) {
+		goto end;
+	}
+
+	writer_packet_header = bt_ctf_field_copy(packet_header);
+	if (!writer_packet_header) {
+		fprintf(err, "[error] %s in %s:%d\n", __func__, __FILE__,
+				__LINE__);
+		goto error;
+	}
+
+	ret = bt_ctf_stream_set_packet_header(writer_stream,
+			writer_packet_header);
+	if (ret) {
+		fprintf(err, "[error] %s in %s:%d\n", __func__, __FILE__,
+				__LINE__);
+		goto error;
+	}
+
+	goto end;
+
+error:
+	ret = -1;
+end:
+	bt_put(writer_packet_header);
+	bt_put(packet_header);
+	return ret;
+}
+
+BT_HIDDEN
+int ctf_packet_copy_header(FILE *err, struct bt_ctf_packet *packet,
+		struct bt_ctf_packet *writer_packet)
+{
+	struct bt_ctf_field *packet_header = NULL, *writer_packet_header = NULL;
+	int ret = 0;
+
+	packet_header = bt_ctf_packet_get_header(packet);
+	if (!packet_header) {
+		goto end;
+	}
+
+	writer_packet_header = bt_ctf_field_copy(packet_header);
+	if (!writer_packet_header) {
+		fprintf(err, "[error] %s in %s:%d\n", __func__, __FILE__,
+				__LINE__);
+		goto error;
+	}
+
+	ret = bt_ctf_packet_set_header(writer_packet, writer_packet_header);
+	if (ret) {
+		fprintf(err, "[error] %s in %s:%d\n", __func__, __FILE__,
+				__LINE__);
+		goto error;
+	}
+
+	goto end;
+
+error:
+	ret = -1;
+end:
+	bt_put(packet_header);
+	bt_put(writer_packet_header);
+	return ret;
+}
+
 BT_HIDDEN
 int ctf_stream_copy_packet_context(FILE *err, struct bt_ctf_packet *packet,
 		struct bt_ctf_stream *writer_stream)
@@ -813,7 +886,7 @@ enum bt_component_status ctf_copy_trace(FILE *err, struct bt_ctf_trace *trace,
 		}
 	}
 
-	header_type = bt_ctf_trace_get_packet_header_type(writer_trace);
+	header_type = bt_ctf_trace_get_packet_header_type(trace);
 	if (header_type) {
 		int_ret = bt_ctf_trace_set_packet_header_type(writer_trace, header_type);
 		BT_PUT(header_type);