X-Git-Url: http://git.efficios.com/?p=babeltrace.git;a=blobdiff_plain;f=formats%2Fctf%2Fctf.c;h=41aa35d60fd6a67e23b128a60a258ed03215bab2;hp=7c354bf0a40710a9eed836226d6bb273f94b2148;hb=4152822bf555f86a1dce28cb6755ff0849c3a75a;hpb=a0fe7d97d4a551665af7bd91f7571dc785a75951

diff --git a/formats/ctf/ctf.c b/formats/ctf/ctf.c
index 7c354bf0..41aa35d6 100644
--- a/formats/ctf/ctf.c
+++ b/formats/ctf/ctf.c
@@ -63,8 +63,8 @@ rw_dispatch read_dispatch_table[] = {
 	[ CTF_TYPE_STRING ] = ctf_string_read,
 	[ CTF_TYPE_STRUCT ] = ctf_struct_rw,
 	[ CTF_TYPE_VARIANT ] = ctf_variant_rw,
-	[ CTF_TYPE_ARRAY ] = ctf_array_rw,
-	[ CTF_TYPE_SEQUENCE ] = ctf_sequence_rw,
+	[ CTF_TYPE_ARRAY ] = ctf_array_read,
+	[ CTF_TYPE_SEQUENCE ] = ctf_sequence_read,
 };
 
 static
@@ -75,8 +75,8 @@ rw_dispatch write_dispatch_table[] = {
 	[ CTF_TYPE_STRING ] = ctf_string_write,
 	[ CTF_TYPE_STRUCT ] = ctf_struct_rw,
 	[ CTF_TYPE_VARIANT ] = ctf_variant_rw,
-	[ CTF_TYPE_ARRAY ] = ctf_array_rw,
-	[ CTF_TYPE_SEQUENCE ] = ctf_sequence_rw,
+	[ CTF_TYPE_ARRAY ] = ctf_array_write,
+	[ CTF_TYPE_SEQUENCE ] = ctf_sequence_write,
 };
 
 static
@@ -93,7 +93,6 @@ int ctf_read_event(struct stream_pos *ppos, struct ctf_stream *stream)
 	struct ctf_stream_class *stream_class = stream->stream_class;
 	struct ctf_event *event_class;
 	uint64_t id = 0;
-	int len_index;
 	int ret;
 
 	if (pos->offset == EOF)
@@ -101,38 +100,43 @@ int ctf_read_event(struct stream_pos *ppos, struct ctf_stream *stream)
 
 	/* Read event header */
 	if (stream_class->event_header) {
+		struct definition_integer *integer_definition;
+
 		ret = generic_rw(ppos, &stream_class->event_header->p);
 		if (ret)
 			goto error;
 		/* lookup event id */
-		len_index = struct_declaration_lookup_field_index(stream_class->event_header_decl,
-				g_quark_from_static_string("id"));
-		if (len_index >= 0) {
-			struct definition_integer *defint;
-			struct definition *field;
+		integer_definition = lookup_integer(&stream_class->event_header->p, "id", FALSE);
+		if (integer_definition) {
+			id = integer_definition->value._unsigned;
+		} else {
+			struct definition_enum *enum_definition;
 
-			field = struct_definition_get_field_from_index(stream_class->event_header, len_index);
-			assert(field->declaration->id == CTF_TYPE_INTEGER);
-			defint = container_of(field, struct definition_integer, p);
-			assert(defint->declaration->signedness == FALSE);
-			id = defint->value._unsigned;	/* set id */
+			enum_definition = lookup_enum(&stream_class->event_header->p, "id", FALSE);
+			if (enum_definition) {
+				id = enum_definition->integer->value._unsigned;
+			}
 		}
 
 		/* lookup timestamp */
-		len_index = struct_declaration_lookup_field_index(stream_class->event_header_decl,
-				g_quark_from_static_string("timestamp"));
-		if (len_index >= 0) {
-			struct definition_integer *defint;
-			struct definition *field;
+		integer_definition = lookup_integer(&stream_class->event_header->p, "timestamp", FALSE);
+		if (integer_definition) {
+			stream->timestamp = integer_definition->value._unsigned;
+		} else {
+			struct definition *definition;
 
-			field = struct_definition_get_field_from_index(stream_class->event_header, len_index);
-			assert(field->declaration->id == CTF_TYPE_INTEGER);
-			defint = container_of(field, struct definition_integer, p);
-			assert(defint->declaration->signedness == FALSE);
-			/* update timestamp */
-			stream->timestamp = defint->value._unsigned;
+			definition = lookup_variant(&stream_class->event_header->p, "v");
+			if (definition) {
+				integer_definition = lookup_integer(definition, "id", FALSE);
+				if (integer_definition) {
+					id = integer_definition->value._unsigned;
+				}
+				integer_definition = lookup_integer(definition, "timestamp", FALSE);
+				if (integer_definition) {
+					stream->timestamp = integer_definition->value._unsigned;
+				}
+			}
 		}
-
 	}
 
 	/* Read stream-declared event context */
@@ -410,7 +414,7 @@ int ctf_open_trace_metadata_packet_read(struct ctf_trace *td, FILE *in,
 	char buf[4096];
 	int ret = 0;
 
-	readlen = fread(&header, sizeof(header), 1, in);
+	readlen = fread(&header, header_sizeof(header), 1, in);
 	if (readlen < 1)
 		return -EINVAL;
 
@@ -453,7 +457,11 @@ int ctf_open_trace_metadata_packet_read(struct ctf_trace *td, FILE *in,
 			ret = -EINVAL;
 			break;
 		}
-		printf("read %s\n", buf);
+		if (babeltrace_debug) {
+			fprintf(stdout, "[debug] metadata packet read: %s\n",
+				buf);
+		}
+
 		writelen = fwrite(buf, sizeof(char), readlen, out);
 		if (writelen < readlen) {
 			ret = -EIO;
@@ -465,11 +473,7 @@ int ctf_open_trace_metadata_packet_read(struct ctf_trace *td, FILE *in,
 		}
 		toread -= readlen;
 		if (!toread) {
-			ret = -EOF;
-			break;
-		}
-		if (feof(in)) {
-			ret = -EINVAL;
+			ret = 0;	/* continue reading next packet */
 			break;
 		}
 	}
@@ -491,10 +495,11 @@ int ctf_open_trace_metadata_stream_read(struct ctf_trace *td, FILE **fp,
 
 	for (;;) {
 		ret = ctf_open_trace_metadata_packet_read(td, in, out);
-		if (ret == -EOF) {
-			ret = 0;
+		if (ret) {
 			break;
-		} else if (ret) {
+		}
+		if (feof(in)) {
+			ret = 0;
 			break;
 		}
 	}