src/bin/lttng-sessiond/utils.cpp

   1 /*
   2  * Copyright (C) 2011 EfficiOS Inc.
   3  * Copyright (C) 2011 Mathieu Desnoyers <mathieu.desnoyers@efficios.com>
   4  *
   5  * SPDX-License-Identifier: GPL-2.0-only
   6  *
   7  */
   8
   9 #define _LGPL_SOURCE
  10 #include "lttng-sessiond.hpp"
  11 #include "snapshot.hpp"
  12 #include "utils.hpp"
  13
  14 #include <common/error.hpp>
  15
  16 #include <stdlib.h>
  17 #include <unistd.h>
  18
  19 /*
  20  * Write to writable pipe used to notify a thread.
  21  */
  22 int notify_thread_pipe(int wpipe)
  23 {
  24         ssize_t ret;
  25
  26         /* Ignore if the pipe is invalid. */
  27         if (wpipe < 0) {
  28                 return 0;
  29         }
  30
  31         ret = lttng_write(wpipe, "!", 1);
  32         if (ret < 1) {
  33                 ret = -1;
  34                 PERROR("Failed to write to thread pipe");
  35         }
  36
  37         return (int) ret;
  38 }
  39
  40 int loglevels_match(int a_loglevel_type,
  41                     int a_loglevel_value,
  42                     int b_loglevel_type,
  43                     int b_loglevel_value,
  44                     int loglevel_all_type)
  45 {
  46         int match = 1;
  47
  48         if (a_loglevel_type == b_loglevel_type) {
  49                 /* Same loglevel type. */
  50                 if (b_loglevel_type != loglevel_all_type) {
  51                         /*
  52                          * Loglevel value must also match since the loglevel
  53                          * type is not all.
  54                          */
  55                         if (a_loglevel_value != b_loglevel_value) {
  56                                 match = 0;
  57                         }
  58                 }
  59         } else {
  60                 /* Loglevel type is different: no match. */
  61                 match = 0;
  62         }
  63
  64         return match;
  65 }
  66
  67 const char *session_get_base_path(const struct ltt_session *session)
  68 {
  69         return consumer_output_get_base_path(session->consumer);
  70 }
  71
  72 const char *consumer_output_get_base_path(const struct consumer_output *output)
  73 {
  74         return output->type == CONSUMER_DST_LOCAL ? output->dst.session_root_path :
  75                                                     output->dst.net.base_dir;
  76 }