[lttng-ust.git] / libringbuffer / backend.h

#ifndef _LINUX_RING_BUFFER_BACKEND_H
#define _LINUX_RING_BUFFER_BACKEND_H

/*
 * linux/ringbuffer/backend.h
 *
 * Copyright (C) 2008-2010 - Mathieu Desnoyers <mathieu.desnoyers@efficios.com>
 *
 * Ring buffer backend (API).
 *
 * Dual LGPL v2.1/GPL v2 license.
 *
 * Credits to Steven Rostedt for proposing to use an extra-subbuffer owned by
 * the reader in flight recorder mode.
 */

#include <unistd.h>

#include "ust/core.h"

/* Internal helpers */
#include "backend_internal.h"
#include "frontend_internal.h"

/* Ring buffer backend API */

/* Ring buffer backend access (read/write) */

extern size_t lib_ring_buffer_read(struct lib_ring_buffer_backend *bufb,
				   size_t offset, void *dest, size_t len,
				   struct shm_handle *handle);

extern int lib_ring_buffer_read_cstr(struct lib_ring_buffer_backend *bufb,
				     size_t offset, void *dest, size_t len,
				     struct shm_handle *handle);

/*
 * Return the address where a given offset is located.
 * Should be used to get the current subbuffer header pointer. Given we know
 * it's never on a page boundary, it's safe to write directly to this address,
 * as long as the write is never bigger than a page size.
 */
extern void *
lib_ring_buffer_offset_address(struct lib_ring_buffer_backend *bufb,
			       size_t offset,
			       struct shm_handle *handle);
extern void *
lib_ring_buffer_read_offset_address(struct lib_ring_buffer_backend *bufb,
				    size_t offset,
				    struct shm_handle *handle);

/**
 * lib_ring_buffer_write - write data to a buffer backend
 * @config : ring buffer instance configuration
 * @ctx: ring buffer context. (input arguments only)
 * @src : source pointer to copy from
 * @len : length of data to copy
 *
 * This function copies "len" bytes of data from a source pointer to a buffer
 * backend, at the current context offset. This is more or less a buffer
 * backend-specific memcpy() operation. Calls the slow path (_ring_buffer_write)
 * if copy is crossing a page boundary.
 */
static inline
void lib_ring_buffer_write(const struct lib_ring_buffer_config *config,
			   struct lib_ring_buffer_ctx *ctx,
			   const void *src, size_t len)
{
	struct lib_ring_buffer_backend *bufb = &ctx->buf->backend;
	struct channel_backend *chanb = &ctx->chan->backend;
	struct shm_handle *handle = ctx->handle;
	size_t sbidx;
	size_t offset = ctx->buf_offset;
	struct lib_ring_buffer_backend_pages_shmp *rpages;
	unsigned long sb_bindex, id;

	offset &= chanb->buf_size - 1;
	sbidx = offset >> chanb->subbuf_size_order;
	id = shmp(handle, bufb->buf_wsb)[sbidx].id;
	sb_bindex = subbuffer_id_get_index(config, id);
	rpages = &shmp(handle, bufb->array)[sb_bindex];
	CHAN_WARN_ON(ctx->chan,
		     config->mode == RING_BUFFER_OVERWRITE
		     && subbuffer_id_is_noref(config, id));
	/*
	 * Underlying layer should never ask for writes across
	 * subbuffers.
	 */
	CHAN_WARN_ON(chanb, offset >= chanb->buf_size);
	lib_ring_buffer_do_copy(config,
				shmp(handle, shmp(handle, rpages->shmp)->p) + (offset & ~(chanb->subbuf_size - 1)),
				src, len);
	ctx->buf_offset += len;
}

/*
 * This accessor counts the number of unread records in a buffer.
 * It only provides a consistent value if no reads not writes are performed
 * concurrently.
 */
static inline
unsigned long lib_ring_buffer_get_records_unread(
				const struct lib_ring_buffer_config *config,
				struct lib_ring_buffer *buf,
				struct shm_handle *handle)
{
	struct lib_ring_buffer_backend *bufb = &buf->backend;
	struct lib_ring_buffer_backend_pages_shmp *pages;
	unsigned long records_unread = 0, sb_bindex, id;
	unsigned int i;

	for (i = 0; i < shmp(handle, bufb->chan)->backend.num_subbuf; i++) {
		id = shmp(handle, bufb->buf_wsb)[i].id;
		sb_bindex = subbuffer_id_get_index(config, id);
		pages = &shmp(handle, bufb->array)[sb_bindex];
		records_unread += v_read(config, &shmp(handle, pages->shmp)->records_unread);
	}
	if (config->mode == RING_BUFFER_OVERWRITE) {
		id = bufb->buf_rsb.id;
		sb_bindex = subbuffer_id_get_index(config, id);
		pages = &shmp(handle, bufb->array)[sb_bindex];
		records_unread += v_read(config, &shmp(handle, pages->shmp)->records_unread);
	}
	return records_unread;
}

#endif /* _LINUX_RING_BUFFER_BACKEND_H */
Commit	Line	Data
852c2936 MD	1	#ifndef _LINUX_RING_BUFFER_BACKEND_H
	2	#define _LINUX_RING_BUFFER_BACKEND_H
	3
	4	/*
	5	* linux/ringbuffer/backend.h
	6	*
	7	* Copyright (C) 2008-2010 - Mathieu Desnoyers <mathieu.desnoyers@efficios.com>
	8	*
	9	* Ring buffer backend (API).
	10	*
	11	* Dual LGPL v2.1/GPL v2 license.
	12	*
	13	* Credits to Steven Rostedt for proposing to use an extra-subbuffer owned by
	14	* the reader in flight recorder mode.
	15	*/
	16
14641deb MD	17	#include <unistd.h>
	18
	19	#include "ust/core.h"
	20
852c2936	21	/* Internal helpers */
4931a13e MD	22	#include "backend_internal.h"
4931a13e MD	23	#include "frontend_internal.h"
852c2936 MD	24
	25	/* Ring buffer backend API */
	26
	27	/* Ring buffer backend access (read/write) */
	28
	29	extern size_t lib_ring_buffer_read(struct lib_ring_buffer_backend *bufb,
1d498196 MD	30	size_t offset, void *dest, size_t len,
1d498196 MD	31	struct shm_handle *handle);
852c2936	32
852c2936	33	extern int lib_ring_buffer_read_cstr(struct lib_ring_buffer_backend *bufb,
1d498196 MD	34	size_t offset, void *dest, size_t len,
1d498196 MD	35	struct shm_handle *handle);
852c2936	36
852c2936 MD	37	/*
	38	* Return the address where a given offset is located.
	39	* Should be used to get the current subbuffer header pointer. Given we know
	40	* it's never on a page boundary, it's safe to write directly to this address,
	41	* as long as the write is never bigger than a page size.
	42	*/
	43	extern void *
	44	lib_ring_buffer_offset_address(struct lib_ring_buffer_backend *bufb,
1d498196 MD	45	size_t offset,
1d498196 MD	46	struct shm_handle *handle);
852c2936 MD	47	extern void *
852c2936 MD	48	lib_ring_buffer_read_offset_address(struct lib_ring_buffer_backend *bufb,
1d498196 MD	49	size_t offset,
1d498196 MD	50	struct shm_handle *handle);
852c2936 MD	51
	52	/**
	53	* lib_ring_buffer_write - write data to a buffer backend
	54	* @config : ring buffer instance configuration
	55	* @ctx: ring buffer context. (input arguments only)
	56	* @src : source pointer to copy from
	57	* @len : length of data to copy
	58	*
	59	* This function copies "len" bytes of data from a source pointer to a buffer
	60	* backend, at the current context offset. This is more or less a buffer
	61	* backend-specific memcpy() operation. Calls the slow path (_ring_buffer_write)
	62	* if copy is crossing a page boundary.
	63	*/
	64	static inline
	65	void lib_ring_buffer_write(const struct lib_ring_buffer_config *config,
	66	struct lib_ring_buffer_ctx *ctx,
	67	const void *src, size_t len)
	68	{
	69	struct lib_ring_buffer_backend *bufb = &ctx->buf->backend;
	70	struct channel_backend *chanb = &ctx->chan->backend;
1d498196	71	struct shm_handle *handle = ctx->handle;
a6352fd4	72	size_t sbidx;
852c2936	73	size_t offset = ctx->buf_offset;
1d498196	74	struct lib_ring_buffer_backend_pages_shmp *rpages;
852c2936 MD	75	unsigned long sb_bindex, id;
	76
	77	offset &= chanb->buf_size - 1;
	78	sbidx = offset >> chanb->subbuf_size_order;
1d498196	79	id = shmp(handle, bufb->buf_wsb)[sbidx].id;
852c2936	80	sb_bindex = subbuffer_id_get_index(config, id);
1d498196	81	rpages = &shmp(handle, bufb->array)[sb_bindex];
852c2936 MD	82	CHAN_WARN_ON(ctx->chan,
	83	config->mode == RING_BUFFER_OVERWRITE
	84	&& subbuffer_id_is_noref(config, id));
a6352fd4 MD	85	/*
	86	* Underlying layer should never ask for writes across
	87	* subbuffers.
	88	*/
	89	CHAN_WARN_ON(chanb, offset >= chanb->buf_size);
	90	lib_ring_buffer_do_copy(config,
1d498196	91	shmp(handle, shmp(handle, rpages->shmp)->p) + (offset & ~(chanb->subbuf_size - 1)),
a6352fd4	92	src, len);
852c2936 MD	93	ctx->buf_offset += len;
	94	}
	95
	96	/*
	97	* This accessor counts the number of unread records in a buffer.
	98	* It only provides a consistent value if no reads not writes are performed
	99	* concurrently.
	100	*/
	101	static inline
	102	unsigned long lib_ring_buffer_get_records_unread(
	103	const struct lib_ring_buffer_config *config,
1d498196 MD	104	struct lib_ring_buffer *buf,
1d498196 MD	105	struct shm_handle *handle)
852c2936 MD	106	{
852c2936 MD	107	struct lib_ring_buffer_backend *bufb = &buf->backend;
1d498196	108	struct lib_ring_buffer_backend_pages_shmp *pages;
852c2936 MD	109	unsigned long records_unread = 0, sb_bindex, id;
	110	unsigned int i;
	111
1d498196 MD	112	for (i = 0; i < shmp(handle, bufb->chan)->backend.num_subbuf; i++) {
1d498196 MD	113	id = shmp(handle, bufb->buf_wsb)[i].id;
852c2936	114	sb_bindex = subbuffer_id_get_index(config, id);
1d498196 MD	115	pages = &shmp(handle, bufb->array)[sb_bindex];
1d498196 MD	116	records_unread += v_read(config, &shmp(handle, pages->shmp)->records_unread);
852c2936 MD	117	}
	118	if (config->mode == RING_BUFFER_OVERWRITE) {
	119	id = bufb->buf_rsb.id;
	120	sb_bindex = subbuffer_id_get_index(config, id);
1d498196 MD	121	pages = &shmp(handle, bufb->array)[sb_bindex];
1d498196 MD	122	records_unread += v_read(config, &shmp(handle, pages->shmp)->records_unread);
852c2936 MD	123	}
	124	return records_unread;
	125	}
	126
852c2936	127	#endif /* _LINUX_RING_BUFFER_BACKEND_H */