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 <stdlib.h>
  11 #include <unistd.h>
  12
  13 #include <common/error.hpp>
  14
  15 #include "utils.hpp"
  16 #include "snapshot.hpp"
  17 #include "lttng-sessiond.hpp"
  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, int a_loglevel_value,
  41         int b_loglevel_type, int b_loglevel_value, int loglevel_all_type)
  42 {
  43         int match = 1;
  44
  45         if (a_loglevel_type == b_loglevel_type) {
  46                 /* Same loglevel type. */
  47                 if (b_loglevel_type != loglevel_all_type) {
  48                         /*
  49                          * Loglevel value must also match since the loglevel
  50                          * type is not all.
  51                          */
  52                         if (a_loglevel_value != b_loglevel_value) {
  53                                 match = 0;
  54                         }
  55                 }
  56         } else {
  57                 /* Loglevel type is different: no match. */
  58                 match = 0;
  59         }
  60
  61         return match;
  62 }
  63
  64 const char *session_get_base_path(const struct ltt_session *session)
  65 {
  66         return consumer_output_get_base_path(session->consumer);
  67 }
  68
  69 const char *consumer_output_get_base_path(const struct consumer_output *output)
  70 {
  71         return output->type == CONSUMER_DST_LOCAL ?
  72                         output->dst.session_root_path :
  73                         output->dst.net.base_dir;
  74 }