src/bin/lttng-sessiond/rotate.h

   1 /*
   2  * Copyright (C) 2017 - Julien Desfossez <jdesfossez@efficios.com>
   3  *
   4  * This program is free software; you can redistribute it and/or modify it
   5  * under the terms of the GNU General Public License, version 2 only, as
   6  * published by the Free Software Foundation.
   7  *
   8  * This program is distributed in the hope that it will be useful, but WITHOUT
   9  * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
  10  * FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License for
  11  * more details.
  12  *
  13  * You should have received a copy of the GNU General Public License along with
  14  * this program; if not, write to the Free Software Foundation, Inc., 51
  15  * Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA.
  16  */
  17
  18 #ifndef ROTATE_H
  19 #define ROTATE_H
  20
  21 #include "rotation-thread.h"
  22
  23 /*
  24  * Key in channel_pending_rotate_ht to map a channel to a
  25  * struct rotation_channel_info.
  26  */
  27 struct rotation_channel_key {
  28         uint64_t key;
  29         enum lttng_domain_type domain;
  30 };
  31
  32 /*
  33  * Added in channel_pending_rotate_ht everytime we start the rotation of a
  34  * channel. The consumer notifies the rotation thread with the channel_key to
  35  * inform a rotation is complete, we use that information to lookup the related
  36  * session from channel_pending_rotate_ht.
  37  */
  38 struct rotation_channel_info {
  39         uint64_t session_id;
  40         struct rotation_channel_key channel_key;
  41         struct cds_lfht_node rotate_channels_ht_node;
  42 };
  43
  44 extern struct cds_lfht *channel_pending_rotate_ht;
  45
  46 unsigned long hash_channel_key(struct rotation_channel_key *key);
  47
  48 /* session lock must be held by this function's caller. */
  49 int rename_complete_chunk(struct ltt_session *session, time_t ts);
  50
  51 /*
  52  * When we start the rotation of a channel, we add its information in
  53  * channel_pending_rotate_ht. This is called in the context of
  54  * thread_manage_client when the client asks for a rotation, in the context
  55  * of the sessiond_timer thread when periodic rotations are enabled and from
  56  * the rotation_thread when size-based rotations are enabled.
  57  */
  58 int rotate_add_channel_pending(uint64_t key, enum lttng_domain_type domain,
  59                 struct ltt_session *session);
  60
  61 #endif /* ROTATE_H */