[lttng-tools.git] / src / common / kernel-consumer / kernel-consumer.h

/*
 * Copyright (C) 2011 - Julien Desfossez <julien.desfossez@polymtl.ca>
 * Copyright (C) 2011 - Mathieu Desnoyers <mathieu.desnoyers@efficios.com>
 * Copyright (C) 2017 - 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 _LTTNG_KCONSUMER_H
#define _LTTNG_KCONSUMER_H

#include <stdbool.h>
#include <common/consumer/consumer.h>

int lttng_kconsumer_take_snapshot(struct lttng_consumer_stream *stream);
int lttng_kconsumer_sample_snapshot_positions(
		struct lttng_consumer_stream *stream);
int lttng_kconsumer_get_produced_snapshot(struct lttng_consumer_stream *stream,
        unsigned long *pos);
int lttng_kconsumer_get_consumed_snapshot(struct lttng_consumer_stream *stream,
		unsigned long *pos);
int lttng_kconsumer_recv_cmd(struct lttng_consumer_local_data *ctx,
		int sock, struct pollfd *consumer_sockpoll);
ssize_t lttng_kconsumer_read_subbuffer(struct lttng_consumer_stream *stream,
		struct lttng_consumer_local_data *ctx, bool *rotated);
int lttng_kconsumer_on_recv_stream(struct lttng_consumer_stream *stream);
int lttng_kconsumer_data_pending(struct lttng_consumer_stream *stream);
int lttng_kconsumer_sync_metadata(struct lttng_consumer_stream *metadata);

#endif /* _LTTNG_KCONSUMER_H */
Commit	Line	Data
	1	/*
	2	* Copyright (C) 2011 - Julien Desfossez <julien.desfossez@polymtl.ca>
	3	* Copyright (C) 2011 - Mathieu Desnoyers <mathieu.desnoyers@efficios.com>
	4	* Copyright (C) 2017 - Jérémie Galarneau <jeremie.galarneau@efficios.com>
	5	*
	6	* This program is free software; you can redistribute it and/or modify
	7	* it under the terms of the GNU General Public License, version 2 only,
	8	* as published by the Free Software Foundation.
	9	*
	10	* This program is distributed in the hope that it will be useful,
	11	* but WITHOUT ANY WARRANTY; without even the implied warranty of
	12	* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
	13	* GNU General Public License for more details.
	14	*
	15	* You should have received a copy of the GNU General Public License along
	16	* with this program; if not, write to the Free Software Foundation, Inc.,
	17	* 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA.
	18	*/
	19
	20	#ifndef _LTTNG_KCONSUMER_H
	21	#define _LTTNG_KCONSUMER_H
	22
	23	#include <stdbool.h>
	24	#include <common/consumer/consumer.h>
	25
	26	int lttng_kconsumer_take_snapshot(struct lttng_consumer_stream *stream);
	27	int lttng_kconsumer_sample_snapshot_positions(
	28	struct lttng_consumer_stream *stream);
	29	int lttng_kconsumer_get_produced_snapshot(struct lttng_consumer_stream *stream,
	30	unsigned long *pos);
	31	int lttng_kconsumer_get_consumed_snapshot(struct lttng_consumer_stream *stream,
	32	unsigned long *pos);
	33	int lttng_kconsumer_recv_cmd(struct lttng_consumer_local_data *ctx,
	34	int sock, struct pollfd *consumer_sockpoll);
	35	ssize_t lttng_kconsumer_read_subbuffer(struct lttng_consumer_stream *stream,
	36	struct lttng_consumer_local_data ctx, bool rotated);
	37	int lttng_kconsumer_on_recv_stream(struct lttng_consumer_stream *stream);
	38	int lttng_kconsumer_data_pending(struct lttng_consumer_stream *stream);
	39	int lttng_kconsumer_sync_metadata(struct lttng_consumer_stream *metadata);
	40
	41	#endif /* _LTTNG_KCONSUMER_H */