#define WRITE_PACKET_LEN (getpagesize() * 8 * CHAR_BIT)
#define UUID_LEN 16 /* uuid by value len */
+#ifndef min
+#define min(a, b) (((a) < (b)) ? (a) : (b))
+#endif
+
extern int yydebug;
struct trace_descriptor *ctf_open_trace(const char *path, int flags);
int ret = 0;
len = fread(&magic, sizeof(magic), 1, fp);
- if (len != sizeof(magic)) {
+ if (len != 1) {
goto end;
}
if (magic == TSDL_MAGIC) {
td->byte_order = (BYTE_ORDER == BIG_ENDIAN) ?
LITTLE_ENDIAN : BIG_ENDIAN;
}
+ CTF_TRACE_SET_FIELD(td, byte_order);
end:
rewind(fp);
return ret;
FILE *out)
{
struct metadata_packet_header header;
- size_t readlen, writelen;
+ size_t readlen, writelen, toread;
char buf[4096];
int ret = 0;
readlen = fread(&header, sizeof(header), 1, in);
- if (readlen < sizeof(header))
+ if (readlen < 1)
return -EINVAL;
if (td->byte_order != BYTE_ORDER) {
return -EINVAL;
}
- while (!feof(in)) {
- readlen = fread(buf, sizeof(char), sizeof(buf), in);
+ toread = header.content_size / CHAR_BIT;
+
+ for (;;) {
+ readlen = fread(buf, sizeof(char), min(sizeof(buf), toread), in);
if (ferror(in)) {
ret = -EINVAL;
break;
}
+ printf("read %s\n", buf);
writelen = fwrite(buf, sizeof(char), readlen, out);
if (writelen < readlen) {
ret = -EIO;
ret = -EINVAL;
break;
}
+ toread -= readlen;
+ if (!toread) {
+ ret = -EOF;
+ break;
+ }
+ if (feof(in)) {
+ ret = -EINVAL;
+ break;
+ }
}
return ret;
}
readdir_error:
free(dirent);
error_metadata:
- g_ptr_array_free(td->streams, TRUE);
close(td->dirfd);
error_dirfd:
closedir(td->dir);
CTF_TRACE_SET_FIELD(trace, minor);
} else if (!strcmp(left, "uuid")) {
uuid_t uuid;
- ret = get_unary_uuid(&node->u.ctf_expression.right, &trace->uuid);
+
+ ret = get_unary_uuid(&node->u.ctf_expression.right, &uuid);
if (ret) {
fprintf(fd, "[error] %s: unexpected unary expression for trace uuid\n", __func__);
ret = -EINVAL;
fprintf(fd, "[error] %s: uuid mismatch\n", __func__);
ret = -EPERM;
goto error;
+ } else {
+ memcpy(trace->uuid, uuid, sizeof(uuid));
}
CTF_TRACE_SET_FIELD(trace, uuid);
} else if (!strcmp(left, "byte_order")) {
struct ctf_node *right;
int byte_order;
- if (CTF_TRACE_FIELD_IS_SET(trace, byte_order)) {
- fprintf(fd, "[error] %s: endianness already declared in trace declaration\n", __func__);
- ret = -EPERM;
- goto error;
- }
right = _cds_list_first_entry(&node->u.ctf_expression.right, struct ctf_node, siblings);
byte_order = get_trace_byte_order(fd, depth, right);
if (byte_order < 0)
return -EINVAL;
- trace->byte_order = byte_order;
+
+ if (CTF_TRACE_FIELD_IS_SET(trace, byte_order)
+ && byte_order != trace->byte_order) {
+ fprintf(fd, "[error] %s: endianness mismatch\n", __func__);
+ ret = -EPERM;
+ goto error;
+ } else {
+ trace->byte_order = byte_order;
+ }
CTF_TRACE_SET_FIELD(trace, byte_order);
} else if (!strcmp(left, "packet.header")) {
struct declaration *declaration;
printf_verbose("CTF visitor: metadata construction... ");
trace->root_declaration_scope = new_declaration_scope(NULL);
- trace->streams = g_ptr_array_new();
trace->byte_order = byte_order;
switch (node->type) {
ret = ctf_root_declaration_visit(fd, depth + 1, iter, trace);
if (ret) {
fprintf(fd, "[error] %s: root declaration error\n", __func__);
- return ret;
+ goto error;
}
}
cds_list_for_each_entry(iter, &node->u.root.trace, siblings) {
ret = ctf_trace_visit(fd, depth + 1, iter, trace);
if (ret) {
fprintf(fd, "[error] %s: trace declaration error\n", __func__);
- return ret;
+ goto error;
}
}
if (!trace->streams) {
fprintf(fd, "[error] %s: missing trace declaration\n", __func__);
- return -EINVAL;
+ ret = -EINVAL;
+ goto error;
}
cds_list_for_each_entry(iter, &node->u.root.stream, siblings) {
ret = ctf_stream_visit(fd, depth + 1, iter,
trace->root_declaration_scope, trace);
if (ret) {
fprintf(fd, "[error] %s: stream declaration error\n", __func__);
- return ret;
+ goto error;
}
}
cds_list_for_each_entry(iter, &node->u.root.event, siblings) {
trace->root_declaration_scope, trace);
if (ret) {
fprintf(fd, "[error] %s: event declaration error\n", __func__);
- return ret;
+ goto error;
}
}
break;
default:
fprintf(fd, "[error] %s: unknown node type %d\n", __func__,
(int) node->type);
- return -EINVAL;
+ ret = -EINVAL;
+ goto error;
}
printf_verbose("done.\n");
return ret;
+
+error:
+ free_declaration_scope(trace->root_declaration_scope);
+ return ret;
}