src/plugins/ctf/fs-src/file.c

   1 /*
   2  * SPDX-License-Identifier: MIT
   3  *
   4  * Copyright 2016 Philippe Proulx <pproulx@efficios.com>
   5  */
   6
   7 #define BT_COMP_LOG_SELF_COMP (file->self_comp)
   8 #define BT_LOG_OUTPUT_LEVEL (file->log_level)
   9 #define BT_LOG_TAG "PLUGIN/SRC.CTF.FS/FILE"
  10 #include "logging/comp-logging.h"
  11
  12 #include <stdio.h>
  13 #include <sys/types.h>
  14 #include <sys/stat.h>
  15 #include <unistd.h>
  16 #include <glib.h>
  17 #include "file.h"
  18
  19 BT_HIDDEN
  20 void ctf_fs_file_destroy(struct ctf_fs_file *file)
  21 {
  22         if (!file) {
  23                 return;
  24         }
  25
  26         if (file->fp) {
  27                 BT_COMP_LOGD("Closing file \"%s\" (%p)",
  28                                 file->path ? file->path->str : NULL, file->fp);
  29
  30                 if (fclose(file->fp)) {
  31                         BT_COMP_LOGE("Cannot close file \"%s\": %s",
  32                                         file->path ? file->path->str : "NULL",
  33                                         strerror(errno));
  34                 }
  35         }
  36
  37         if (file->path) {
  38                 g_string_free(file->path, TRUE);
  39         }
  40
  41         g_free(file);
  42 }
  43
  44 BT_HIDDEN
  45 struct ctf_fs_file *ctf_fs_file_create(bt_logging_level log_level,
  46                 bt_self_component *self_comp)
  47 {
  48         struct ctf_fs_file *file = g_new0(struct ctf_fs_file, 1);
  49
  50         if (!file) {
  51                 goto error;
  52         }
  53
  54         file->log_level = log_level;
  55         file->self_comp = self_comp;
  56         file->path = g_string_new(NULL);
  57         if (!file->path) {
  58                 goto error;
  59         }
  60
  61         goto end;
  62
  63 error:
  64         ctf_fs_file_destroy(file);
  65         file = NULL;
  66
  67 end:
  68         return file;
  69 }
  70
  71 BT_HIDDEN
  72 int ctf_fs_file_open(struct ctf_fs_file *file, const char *mode)
  73 {
  74         int ret = 0;
  75         struct stat stat;
  76
  77         BT_COMP_LOGI("Opening file \"%s\" with mode \"%s\"", file->path->str, mode);
  78         file->fp = fopen(file->path->str, mode);
  79         if (!file->fp) {
  80                 BT_COMP_LOGE_APPEND_CAUSE_ERRNO(file->self_comp,
  81                         "Cannot open file", ": path=%s, mode=%s",
  82                         file->path->str, mode);
  83                 goto error;
  84         }
  85
  86         BT_COMP_LOGI("Opened file: %p", file->fp);
  87
  88         if (fstat(fileno(file->fp), &stat)) {
  89                 BT_COMP_LOGE_APPEND_CAUSE_ERRNO(file->self_comp,
  90                         "Cannot get file information",
  91                         ": path=%s", file->path->str);
  92                 goto error;
  93         }
  94
  95         file->size = stat.st_size;
  96         BT_COMP_LOGI("File is %jd bytes", (intmax_t) file->size);
  97         goto end;
  98
  99 error:
 100         ret = -1;
 101
 102         if (file->fp) {
 103                 if (fclose(file->fp)) {
 104                         BT_COMP_LOGE("Cannot close file \"%s\": %s", file->path->str,
 105                                 strerror(errno));
 106                 }
 107         }
 108
 109 end:
 110         return ret;
 111 }