X-Git-Url: http://git.liburcu.org/?a=blobdiff_plain;f=lib%2Fringbuffer%2Ffrontend.h;h=ae1c1aaf1e84a31c6eb9c17481e7e6fb8a37c6a4;hb=369708f464bedc0682151df9308cebfa14dbdb2b;hp=01af77a281b046a9dfc8d3de2d0eb69daa98c15e;hpb=d01202ff1f043dd04f62ab77aacea3c26cb65eb3;p=lttng-modules.git diff --git a/lib/ringbuffer/frontend.h b/lib/ringbuffer/frontend.h index 01af77a2..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. */ @@ -225,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 */