X-Git-Url: http://git.liburcu.org/?a=blobdiff_plain;f=lib%2Fringbuffer%2Ffrontend.h;h=ae1c1aaf1e84a31c6eb9c17481e7e6fb8a37c6a4;hb=369708f464bedc0682151df9308cebfa14dbdb2b;hp=85858d936ca0c3f43ad1c8b84f5f569b1e5e2e54;hpb=24cedcfefbfe781af5430e07a327030cc7caddfc;p=lttng-modules.git diff --git a/lib/ringbuffer/frontend.h b/lib/ringbuffer/frontend.h index 85858d93..ae1c1aaf 100644 --- a/lib/ringbuffer/frontend.h +++ b/lib/ringbuffer/frontend.h @@ -1,21 +1,17 @@ -#ifndef _LINUX_RING_BUFFER_FRONTEND_H -#define _LINUX_RING_BUFFER_FRONTEND_H - -/* - * linux/ringbuffer/frontend.h +/* SPDX-License-Identifier: (GPL-2.0-only OR LGPL-2.1-only) * - * (C) Copyright 2005-2010 - Mathieu Desnoyers + * lib/ringbuffer/frontend.h * * Ring Buffer Library Synchronization Header (API). * - * Author: - * Mathieu Desnoyers + * Copyright (C) 2005-2012 Mathieu Desnoyers * * See ring_buffer_frontend.c for more information on wait-free algorithms. - * - * Dual LGPL v2.1/GPL v2 license. */ +#ifndef _LIB_RING_BUFFER_FRONTEND_H +#define _LIB_RING_BUFFER_FRONTEND_H + #include #include #include @@ -37,7 +33,10 @@ #include /* Internal helpers */ -#include "../../wrapper/ringbuffer/frontend_internal.h" +#include + +/* Max ring buffer nesting count, see lib_ring_buffer_get_cpu(). */ +#define RING_BUFFER_MAX_NESTING 4 /* Buffer creation/removal and setup operations */ @@ -94,6 +93,10 @@ extern void lib_ring_buffer_release_read(struct lib_ring_buffer *buf); extern int lib_ring_buffer_snapshot(struct lib_ring_buffer *buf, unsigned long *consumed, unsigned long *produced); +extern int lib_ring_buffer_snapshot_sample_positions( + struct lib_ring_buffer *buf, + unsigned long *consumed, + unsigned long *produced); extern void lib_ring_buffer_move_consumer(struct lib_ring_buffer *buf, unsigned long consumed_new); @@ -101,6 +104,9 @@ extern int lib_ring_buffer_get_subbuf(struct lib_ring_buffer *buf, unsigned long consumed); extern void lib_ring_buffer_put_subbuf(struct lib_ring_buffer *buf); +void lib_ring_buffer_set_quiescent_channel(struct channel *chan); +void lib_ring_buffer_clear_quiescent_channel(struct channel *chan); + /* * lib_ring_buffer_get_next_subbuf/lib_ring_buffer_put_next_subbuf are helpers * to read sub-buffers sequentially. @@ -149,7 +155,7 @@ static inline int lib_ring_buffer_is_finalized(const struct lib_ring_buffer_config *config, struct lib_ring_buffer *buf) { - int finalized = ACCESS_ONCE(buf->finalized); + int finalized = READ_ONCE(buf->finalized); /* * Read finalized before counters. */ @@ -163,6 +169,12 @@ int lib_ring_buffer_channel_is_finalized(const struct channel *chan) return chan->finalized; } +static inline +int lib_ring_buffer_channel_is_disabled(const struct channel *chan) +{ + return atomic_read(&chan->record_disabled); +} + static inline unsigned long lib_ring_buffer_get_read_data_size( const struct lib_ring_buffer_config *config, @@ -219,4 +231,4 @@ unsigned long lib_ring_buffer_get_records_read( return v_read(config, &buf->backend.records_read); } -#endif /* _LINUX_RING_BUFFER_FRONTEND_H */ +#endif /* _LIB_RING_BUFFER_FRONTEND_H */