X-Git-Url: http://git.efficios.com/?p=babeltrace.git;a=blobdiff_plain;f=lib%2Fcontext.c;h=90d77df88f6840af5a954616048f5fbc0f81c631;hp=f2f76be31a1cdbe0dc40da3284948ebc21812855;hb=34861b9ddd0eb8040ac54e51f9352c4d7ff6fead;hpb=e669e45e7fdff6b855907cde40524ebf4cc8a3bc diff --git a/lib/context.c b/lib/context.c index f2f76be3..90d77df8 100644 --- a/lib/context.c +++ b/lib/context.c @@ -62,22 +62,25 @@ int bt_context_add_trace(struct bt_context *ctx, const char *path, struct trace_descriptor *td; struct format *fmt; struct bt_trace_handle *handle; + int ret; fmt = bt_lookup_format(g_quark_from_string(format_str)); td = fmt->open_trace(path, O_RDONLY, ctf_move_pos_slow, NULL); if (!td) { - fprintf(stdout, "[error] [Context] Cannot open_trace of the format %s .\n\n", + fprintf(stderr, "[error] [Context] Cannot open_trace of the format %s .\n\n", path); - return -1; + ret = -1; + goto end; } /* Create an handle for the trace */ handle = bt_trace_handle_create(ctx); if (handle < 0) { - fprintf(stdout, "[error] [Context] Creating trace handle %s .\n\n", + fprintf(stderr, "[error] [Context] Creating trace handle %s .\n\n", path); - return -1; + ret = -1; + goto end; } handle->format = fmt; handle->td = td; @@ -88,88 +91,10 @@ int bt_context_add_trace(struct bt_context *ctx, const char *path, g_hash_table_insert(ctx->trace_handles, (gpointer) (unsigned long) handle->id, handle); - trace_collection_add(ctx->tc, td); - return 0; -} - -/* - * Unable to open toplevel: failure. - * Unable to open some subdirectory or file: warn and continue; - */ -int bt_context_add_traces_recursive(struct bt_context *ctx, const char *path, - const char *format_str) -{ - FTS *tree; - FTSENT *node; - GArray *trace_ids; - char lpath[PATH_MAX]; - char * const paths[2] = { lpath, NULL }; - int ret; - - /* - * Need to copy path, because fts_open can change it. - * It is the pointer array, not the strings, that are constant. - */ - strncpy(lpath, path, PATH_MAX); - lpath[PATH_MAX - 1] = '\0'; - - tree = fts_open(paths, FTS_NOCHDIR | FTS_LOGICAL, 0); - if (tree == NULL) { - fprintf(stdout, "[error] Cannot traverse \"%s\" for reading.\n\n", - path); - return -EINVAL; - } - - trace_ids = g_array_new(FALSE, TRUE, sizeof(int)); - - while ((node = fts_read(tree))) { - int dirfd, metafd; - - if (!(node->fts_info & FTS_D)) - continue; - - dirfd = open(node->fts_accpath, 0); - if (dirfd < 0) { - fprintf(stdout, "[warning] unable to open trace " - "directory file descriptor.\n"); - continue; - } - metafd = openat(dirfd, "metadata", O_RDONLY); - if (metafd < 0) { - ret = close(dirfd); - if (ret < 0) { - perror("close"); - goto error; - } - } else { - int trace_id; - - ret = close(metafd); - if (ret < 0) { - perror("close"); - goto error; - } - ret = close(dirfd); - if (ret < 0) { - perror("close"); - goto error; - } - - trace_id = bt_context_add_trace(ctx, - node->fts_accpath, format_str); - if (trace_id < 0) { - fprintf(stdout, "[warning] CTX opening trace \"%s\"from %s " - "for reading.\n\n", node->fts_accpath, path); - continue; - } - g_array_append_val(trace_ids, trace_id); - } - } - - g_array_free(trace_ids, TRUE); - return 0; - -error: + ret = trace_collection_add(ctx->tc, td); + if (ret == 0) + return handle->id; +end: return ret; }