[lttng-tools.git] / src / bin / lttng-sessiond / rotation-thread.h

/*
 * Copyright (C) 2017 - Julien Desfossez <jdesfossez@efficios.com>
 * Copyright (C) 2018 - Jérémie Galarneau <jeremie.galarneau@efficios.com>
 *
 * This program is free software; you can redistribute it and/or modify it
 * under the terms of the GNU General Public License, version 2 only, as
 * published by the Free Software Foundation.
 *
 * This program is distributed in the hope that it will be useful, but WITHOUT
 * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
 * FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License for
 * more details.
 *
 * You should have received a copy of the GNU General Public License along with
 * this program; if not, write to the Free Software Foundation, Inc., 51
 * Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA.
 */

#ifndef ROTATION_THREAD_H
#define ROTATION_THREAD_H

#include <urcu/list.h>
#include <urcu.h>
#include <urcu/rculfhash.h>
#include <lttng/domain.h>
#include <common/pipe.h>
#include <common/compat/poll.h>
#include <common/hashtable/hashtable.h>
#include <pthread.h>
#include <semaphore.h>
#include "session.h"
#include "notification-thread.h"

extern struct lttng_notification_channel *rotate_notification_channel;

enum rotation_thread_job_type {
	ROTATION_THREAD_JOB_TYPE_SCHEDULED_ROTATION,
	ROTATION_THREAD_JOB_TYPE_CHECK_PENDING_ROTATION
};

struct rotation_thread_timer_queue;
struct rotation_thread_handle;

struct rotation_thread_timer_queue *rotation_thread_timer_queue_create(void);
void rotation_thread_timer_queue_destroy(
		struct rotation_thread_timer_queue *queue);

struct rotation_thread_handle *rotation_thread_handle_create(
		struct rotation_thread_timer_queue *rotation_timer_queue,
		struct notification_thread_handle *notification_thread_handle,
		sem_t *notification_thread_ready);

void rotation_thread_handle_destroy(
		struct rotation_thread_handle *handle);

void rotation_thread_enqueue_job(struct rotation_thread_timer_queue *queue,
		enum rotation_thread_job_type job_type,
		struct ltt_session *session);

void *thread_rotation(void *data);

#endif /* ROTATION_THREAD_H */
Commit	Line	Data
	1	/*
	2	* Copyright (C) 2017 - Julien Desfossez <jdesfossez@efficios.com>
	3	* Copyright (C) 2018 - Jérémie Galarneau <jeremie.galarneau@efficios.com>
	4	*
	5	* This program is free software; you can redistribute it and/or modify it
	6	* under the terms of the GNU General Public License, version 2 only, as
	7	* published by the Free Software Foundation.
	8	*
	9	* This program is distributed in the hope that it will be useful, but WITHOUT
	10	* ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
	11	* FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License for
	12	* more details.
	13	*
	14	* You should have received a copy of the GNU General Public License along with
	15	* this program; if not, write to the Free Software Foundation, Inc., 51
	16	* Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA.
	17	*/
	18
	19	#ifndef ROTATION_THREAD_H
	20	#define ROTATION_THREAD_H
	21
	22	#include <urcu/list.h>
	23	#include <urcu.h>
	24	#include <urcu/rculfhash.h>
	25	#include <lttng/domain.h>
	26	#include <common/pipe.h>
	27	#include <common/compat/poll.h>
	28	#include <common/hashtable/hashtable.h>
	29	#include <pthread.h>
	30	#include <semaphore.h>
	31	#include "session.h"
	32	#include "notification-thread.h"
	33
	34	extern struct lttng_notification_channel *rotate_notification_channel;
	35
	36	enum rotation_thread_job_type {
	37	ROTATION_THREAD_JOB_TYPE_SCHEDULED_ROTATION,
	38	ROTATION_THREAD_JOB_TYPE_CHECK_PENDING_ROTATION
	39	};
	40
	41	struct rotation_thread_timer_queue;
	42	struct rotation_thread_handle;
	43
	44	struct rotation_thread_timer_queue *rotation_thread_timer_queue_create(void);
	45	void rotation_thread_timer_queue_destroy(
	46	struct rotation_thread_timer_queue *queue);
	47
	48	struct rotation_thread_handle *rotation_thread_handle_create(
	49	struct rotation_thread_timer_queue *rotation_timer_queue,
	50	struct notification_thread_handle *notification_thread_handle,
	51	sem_t *notification_thread_ready);
	52
	53	void rotation_thread_handle_destroy(
	54	struct rotation_thread_handle *handle);
	55
	56	void rotation_thread_enqueue_job(struct rotation_thread_timer_queue *queue,
	57	enum rotation_thread_job_type job_type,
	58	struct ltt_session *session);
	59
	60	void thread_rotation(void data);
	61
	62	#endif /* ROTATION_THREAD_H */