X-Git-Url: http://git.efficios.com/?p=babeltrace.git;a=blobdiff_plain;f=formats%2Fctf%2Fwriter%2Fwriter.c;fp=formats%2Fctf%2Fwriter%2Fwriter.c;h=0000000000000000000000000000000000000000;hp=854de432f36d1e830aa68bae4c819c28ae4c5e7d;hb=dc3fffef7b84cc4af1a7c99828fd57a106cd2257;hpb=f3985ab106d89d8e764c1a8dd0c8bda09b755d10 diff --git a/formats/ctf/writer/writer.c b/formats/ctf/writer/writer.c deleted file mode 100644 index 854de432..00000000 --- a/formats/ctf/writer/writer.c +++ /dev/null @@ -1,321 +0,0 @@ -/* - * writer.c - * - * Babeltrace CTF Writer - * - * Copyright 2013, 2014 Jérémie Galarneau - * - * Author: Jérémie Galarneau - * - * Permission is hereby granted, free of charge, to any person obtaining a copy - * of this software and associated documentation files (the "Software"), to deal - * in the Software without restriction, including without limitation the rights - * to use, copy, modify, merge, publish, distribute, sublicense, and/or sell - * copies of the Software, and to permit persons to whom the Software is - * furnished to do so, subject to the following conditions: - * - * The above copyright notice and this permission notice shall be included in - * all copies or substantial portions of the Software. - * - * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR - * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, - * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE - * AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER - * LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, - * OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE - * SOFTWARE. - */ - -#include -#include -#include -#include -#include -#include -#include -#include -#include -#include -#include -#include -#include -#include -#include -#include -#include - -static -void bt_ctf_writer_destroy(struct bt_object *obj); - -struct bt_ctf_writer *bt_ctf_writer_create(const char *path) -{ - struct bt_ctf_writer *writer = NULL; - - if (!path) { - goto error; - } - - writer = g_new0(struct bt_ctf_writer, 1); - if (!writer) { - goto error; - } - - bt_object_init(writer, bt_ctf_writer_destroy); - writer->path = g_string_new(path); - if (!writer->path) { - goto error_destroy; - } - - writer->trace = bt_ctf_trace_create(); - if (!writer->trace) { - goto error_destroy; - } - - writer->trace->is_created_by_writer = 1; - bt_object_set_parent(writer->trace, writer); - bt_put(writer->trace); - /* Create trace directory if necessary and open a metadata file */ - if (g_mkdir_with_parents(path, S_IRWXU | S_IRWXG)) { - perror("g_mkdir_with_parents"); - goto error_destroy; - } - - writer->trace_dir_fd = open(path, O_RDONLY, S_IRWXU | S_IRWXG); - if (writer->trace_dir_fd < 0) { - perror("open"); - goto error_destroy; - } - - writer->metadata_fd = openat(writer->trace_dir_fd, "metadata", - O_WRONLY | O_CREAT | O_TRUNC, - S_IRUSR | S_IWUSR | S_IRGRP | S_IWGRP); - - return writer; - -error_destroy: - unlinkat(writer->trace_dir_fd, "metadata", 0); - BT_PUT(writer); -error: - return writer; -} - -void bt_ctf_writer_destroy(struct bt_object *obj) -{ - struct bt_ctf_writer *writer; - - writer = container_of(obj, struct bt_ctf_writer, base); - bt_ctf_writer_flush_metadata(writer); - if (writer->path) { - g_string_free(writer->path, TRUE); - } - - if (writer->trace_dir_fd > 0) { - if (close(writer->trace_dir_fd)) { - perror("close"); - } - } - - if (writer->metadata_fd > 0) { - if (close(writer->metadata_fd)) { - perror("close"); - } - } - - bt_object_release(writer->trace); - g_free(writer); -} - -struct bt_ctf_trace *bt_ctf_writer_get_trace(struct bt_ctf_writer *writer) -{ - struct bt_ctf_trace *trace = NULL; - - if (!writer) { - goto end; - } - - trace = writer->trace; - bt_get(trace); -end: - return trace; -} - -struct bt_ctf_stream *bt_ctf_writer_create_stream(struct bt_ctf_writer *writer, - struct bt_ctf_stream_class *stream_class) -{ - struct bt_ctf_stream *stream = NULL; - int stream_class_count; - bool stream_class_found = false; - int i; - - if (!writer || !stream_class) { - goto error; - } - - /* Make sure the stream class is part of the writer's trace */ - stream_class_count = bt_ctf_trace_get_stream_class_count(writer->trace); - if (stream_class_count < 0) { - goto error; - } - - for (i = 0; i < stream_class_count; i++) { - struct bt_ctf_stream_class *existing_stream_class = - bt_ctf_trace_get_stream_class(writer->trace, i); - - if (existing_stream_class == stream_class) { - stream_class_found = true; - } - - BT_PUT(existing_stream_class); - - if (stream_class_found) { - break; - } - } - - if (!stream_class_found) { - int ret = bt_ctf_trace_add_stream_class(writer->trace, - stream_class); - - if (ret) { - goto error; - } - } - - stream = bt_ctf_stream_create(stream_class, NULL); - if (!stream) { - goto error; - } - - return stream; - -error: - BT_PUT(stream); - return stream; -} - -int bt_ctf_writer_add_environment_field(struct bt_ctf_writer *writer, - const char *name, - const char *value) -{ - int ret = -1; - - if (!writer || !name || !value) { - goto end; - } - - ret = bt_ctf_trace_set_environment_field_string(writer->trace, - name, value); -end: - return ret; -} - -int bt_ctf_writer_add_environment_field_int64(struct bt_ctf_writer *writer, - const char *name, - int64_t value) -{ - int ret = -1; - - if (!writer || !name) { - goto end; - } - - ret = bt_ctf_trace_set_environment_field_integer(writer->trace, name, - value); -end: - return ret; -} - -int bt_ctf_writer_add_clock(struct bt_ctf_writer *writer, - struct bt_ctf_clock *clock) -{ - int ret = -1; - - if (!writer || !clock) { - goto end; - } - - ret = bt_ctf_trace_add_clock_class(writer->trace, clock->clock_class); -end: - return ret; -} - -char *bt_ctf_writer_get_metadata_string(struct bt_ctf_writer *writer) -{ - char *metadata_string = NULL; - - if (!writer) { - goto end; - } - - metadata_string = bt_ctf_trace_get_metadata_string( - writer->trace); -end: - return metadata_string; -} - -void bt_ctf_writer_flush_metadata(struct bt_ctf_writer *writer) -{ - int ret; - char *metadata_string = NULL; - - if (!writer) { - goto end; - } - - metadata_string = bt_ctf_trace_get_metadata_string( - writer->trace); - if (!metadata_string) { - goto end; - } - - if (lseek(writer->metadata_fd, 0, SEEK_SET) == (off_t)-1) { - perror("lseek"); - goto end; - } - - if (ftruncate(writer->metadata_fd, 0)) { - perror("ftruncate"); - goto end; - } - - ret = write(writer->metadata_fd, metadata_string, - strlen(metadata_string)); - if (ret < 0) { - perror("write"); - goto end; - } -end: - g_free(metadata_string); -} - -int bt_ctf_writer_set_byte_order(struct bt_ctf_writer *writer, - enum bt_ctf_byte_order byte_order) -{ - int ret = 0; - - if (!writer || writer->frozen) { - ret = -1; - goto end; - } - - ret = bt_ctf_trace_set_byte_order(writer->trace, - byte_order); -end: - return ret; -} - -void bt_ctf_writer_get(struct bt_ctf_writer *writer) -{ - bt_get(writer); -} - -void bt_ctf_writer_put(struct bt_ctf_writer *writer) -{ - bt_put(writer); -} - -BT_HIDDEN -void bt_ctf_writer_freeze(struct bt_ctf_writer *writer) -{ - writer->frozen = 1; -}