libringbuffer/backend_types.h

   1 #ifndef _LTTNG_RING_BUFFER_BACKEND_TYPES_H
   2 #define _LTTNG_RING_BUFFER_BACKEND_TYPES_H
   3
   4 /*
   5  * linux/ringbuffer/backend_types.h
   6  *
   7  * Ring buffer backend (types).
   8  *
   9  * Copyright (C) 2008-2012 Mathieu Desnoyers <mathieu.desnoyers@efficios.com>
  10  *
  11  * This library is free software; you can redistribute it and/or
  12  * modify it under the terms of the GNU Lesser General Public
  13  * License as published by the Free Software Foundation; only
  14  * version 2.1 of the License.
  15  *
  16  * This library is distributed in the hope that it will be useful,
  17  * but WITHOUT ANY WARRANTY; without even the implied warranty of
  18  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
  19  * Lesser General Public License for more details.
  20  *
  21  * You should have received a copy of the GNU Lesser General Public
  22  * License along with this library; if not, write to the Free Software
  23  * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA
  24  */
  25
  26 #include <limits.h>
  27 #include "shm_internal.h"
  28 #include "vatomic.h"
  29
  30 #define RB_BACKEND_PAGES_PADDING        16
  31 struct lttng_ust_lib_ring_buffer_backend_pages {
  32         unsigned long mmap_offset;      /* offset of the subbuffer in mmap */
  33         union v_atomic records_commit;  /* current records committed count */
  34         union v_atomic records_unread;  /* records to read */
  35         unsigned long data_size;        /* Amount of data to read from subbuf */
  36         DECLARE_SHMP(char, p);          /* Backing memory map */
  37         char padding[RB_BACKEND_PAGES_PADDING];
  38 };
  39
  40 struct lttng_ust_lib_ring_buffer_backend_subbuffer {
  41         /* Identifier for subbuf backend pages. Exchanged atomically. */
  42         unsigned long id;               /* backend subbuffer identifier */
  43 };
  44
  45 struct lttng_ust_lib_ring_buffer_backend_counts {
  46         /*
  47          * Counter specific to the sub-buffer location within the ring buffer.
  48          * The actual sequence number of the packet within the entire ring
  49          * buffer can be derived from the formula nr_subbuffers * seq_cnt +
  50          * subbuf_idx.
  51          */
  52         uint64_t seq_cnt;               /* packet sequence number */
  53 };
  54
  55 /*
  56  * Forward declaration of frontend-specific channel and ring_buffer.
  57  */
  58 struct channel;
  59 struct lttng_ust_lib_ring_buffer;
  60
  61 struct lttng_ust_lib_ring_buffer_backend_pages_shmp {
  62         DECLARE_SHMP(struct lttng_ust_lib_ring_buffer_backend_pages, shmp);
  63 };
  64
  65 #define RB_BACKEND_RING_BUFFER_PADDING          64
  66 struct lttng_ust_lib_ring_buffer_backend {
  67         /* Array of ring_buffer_backend_subbuffer for writer */
  68         DECLARE_SHMP(struct lttng_ust_lib_ring_buffer_backend_subbuffer, buf_wsb);
  69         /* ring_buffer_backend_subbuffer for reader */
  70         struct lttng_ust_lib_ring_buffer_backend_subbuffer buf_rsb;
  71         /* Array of lib_ring_buffer_backend_counts for the packet counter */
  72         DECLARE_SHMP(struct lttng_ust_lib_ring_buffer_backend_counts, buf_cnt);
  73         /*
  74          * Pointer array of backend pages, for whole buffer.
  75          * Indexed by ring_buffer_backend_subbuffer identifier (id) index.
  76          */
  77         DECLARE_SHMP(struct lttng_ust_lib_ring_buffer_backend_pages_shmp, array);
  78         DECLARE_SHMP(char, memory_map); /* memory mapping */
  79
  80         DECLARE_SHMP(struct channel, chan);     /* Associated channel */
  81         int cpu;                        /* This buffer's cpu. -1 if global. */
  82         union v_atomic records_read;    /* Number of records read */
  83         unsigned int allocated:1;       /* is buffer allocated ? */
  84         char padding[RB_BACKEND_RING_BUFFER_PADDING];
  85 };
  86
  87 struct lttng_ust_lib_ring_buffer_shmp {
  88         DECLARE_SHMP(struct lttng_ust_lib_ring_buffer, shmp); /* Channel per-cpu buffers */
  89 };
  90
  91 #define RB_BACKEND_CHANNEL_PADDING      64
  92 struct channel_backend {
  93         unsigned long buf_size;         /* Size of the buffer */
  94         unsigned long subbuf_size;      /* Sub-buffer size */
  95         unsigned int subbuf_size_order; /* Order of sub-buffer size */
  96         unsigned int num_subbuf_order;  /*
  97                                          * Order of number of sub-buffers/buffer
  98                                          * for writer.
  99                                          */
 100         unsigned int buf_size_order;    /* Order of buffer size */
 101         unsigned int extra_reader_sb:1; /* has extra reader subbuffer ? */
 102         unsigned long num_subbuf;       /* Number of sub-buffers for writer */
 103         uint64_t start_tsc;             /* Channel creation TSC value */
 104         DECLARE_SHMP(void *, priv_data);/* Client-specific information */
 105         struct lttng_ust_lib_ring_buffer_config config; /* Ring buffer configuration */
 106         char name[NAME_MAX];            /* Channel name */
 107         char padding[RB_BACKEND_CHANNEL_PADDING];
 108         struct lttng_ust_lib_ring_buffer_shmp buf[];
 109 };
 110
 111 #endif /* _LTTNG_RING_BUFFER_BACKEND_TYPES_H */