Support the add operation of urcu hash table
[lttng-tools.git] / src / common / ust-consumer / ust-consumer.h
CommitLineData
3bd1e081
MD
1/*
2 * Copyright (C) 2011 - Julien Desfossez <julien.desfossez@polymtl.ca>
3 * Copyright (C) 2011 - Mathieu Desnoyers <mathieu.desnoyers@efficios.com>
4 *
d14d33bf
AM
5 * This program is free software; you can redistribute it and/or modify
6 * it under the terms of the GNU General Public License, version 2 only,
7 * as published by the Free Software Foundation.
3bd1e081
MD
8 *
9 * This program is distributed in the hope that it will be useful,
10 * but WITHOUT ANY WARRANTY; without even the implied warranty of
d14d33bf 11 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
3bd1e081
MD
12 * GNU General Public License for more details.
13 *
d14d33bf
AM
14 * You should have received a copy of the GNU General Public License along
15 * with this program; if not, write to the Free Software Foundation, Inc.,
16 * 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA.
3bd1e081
MD
17 */
18
19#ifndef _LTTNG_USTCONSUMER_H
20#define _LTTNG_USTCONSUMER_H
21
22#include <config.h>
3bd1e081
MD
23#include <errno.h>
24
10a8a223
DG
25#include <common/consumer.h>
26
74d0b642 27#ifdef HAVE_LIBLTTNG_UST_CTL
3bd1e081 28
3bd1e081
MD
29/*
30 * Take a snapshot for a specific fd
31 *
32 * Returns 0 on success, < 0 on error
33 */
34int lttng_ustconsumer_take_snapshot(struct lttng_consumer_local_data *ctx,
35 struct lttng_consumer_stream *stream);
36
37/*
38 * Get the produced position
39 *
40 * Returns 0 on success, < 0 on error
41 */
42int lttng_ustconsumer_get_produced_snapshot(
43 struct lttng_consumer_local_data *ctx,
44 struct lttng_consumer_stream *stream,
45 unsigned long *pos);
46
47int lttng_ustconsumer_recv_cmd(struct lttng_consumer_local_data *ctx,
48 int sock, struct pollfd *consumer_sockpoll);
49
50extern int lttng_ustconsumer_allocate_channel(struct lttng_consumer_channel *chan);
51extern void lttng_ustconsumer_del_channel(struct lttng_consumer_channel *chan);
e316aad5 52extern int lttng_ustconsumer_add_stream(struct lttng_consumer_stream *stream);
3bd1e081
MD
53extern void lttng_ustconsumer_del_stream(struct lttng_consumer_stream *stream);
54
d41f73b7
MD
55int lttng_ustconsumer_read_subbuffer(struct lttng_consumer_stream *stream,
56 struct lttng_consumer_local_data *ctx);
57int lttng_ustconsumer_on_recv_stream(struct lttng_consumer_stream *stream);
58
d056b477
MD
59void lttng_ustconsumer_on_stream_hangup(struct lttng_consumer_stream *stream);
60
f02e1e8a
DG
61extern int lttng_ustctl_get_mmap_read_offset(
62 struct lttng_ust_shm_handle *handle,
63 struct lttng_ust_lib_ring_buffer *buf, unsigned long *off);
64
74d0b642 65#else /* HAVE_LIBLTTNG_UST_CTL */
3bd1e081
MD
66
67static inline
4078b776 68ssize_t lttng_ustconsumer_on_read_subbuffer_mmap(
3bd1e081 69 struct lttng_consumer_local_data *ctx,
1d4dfdef
DG
70 struct lttng_consumer_stream *stream, unsigned long len,
71 unsigned long padding)
3bd1e081
MD
72{
73 return -ENOSYS;
74}
75
76static inline
4078b776 77ssize_t lttng_ustconsumer_on_read_subbuffer_splice(
3bd1e081 78 struct lttng_consumer_local_data *ctx,
1d4dfdef
DG
79 struct lttng_consumer_stream *uststream, unsigned long len,
80 unsigned long padding)
3bd1e081
MD
81{
82 return -ENOSYS;
83}
84
85static inline
86int lttng_ustconsumer_take_snapshot(struct lttng_consumer_local_data *ctx,
87 struct lttng_consumer_stream *stream)
88{
89 return -ENOSYS;
90}
91
92static inline
93int lttng_ustconsumer_get_produced_snapshot(
94 struct lttng_consumer_local_data *ctx,
95 struct lttng_consumer_stream *stream,
96 unsigned long *pos)
97{
98 return -ENOSYS;
99}
100
101static inline
102int lttng_ustconsumer_recv_cmd(struct lttng_consumer_local_data *ctx,
fbc72522
DG
103 int sock, struct pollfd *consumer_sockpoll)
104{
105 return -ENOSYS;
106}
3bd1e081
MD
107
108static inline
109int lttng_ustconsumer_allocate_channel(struct lttng_consumer_channel *chan)
110{
111 return -ENOSYS;
112}
113
114static inline
115void lttng_ustconsumer_del_channel(struct lttng_consumer_channel *chan)
116{
117}
118
119static inline
e316aad5 120int lttng_ustconsumer_add_stream(struct lttng_consumer_stream *stream)
3bd1e081
MD
121{
122 return -ENOSYS;
123}
124
125static inline
126void lttng_ustconsumer_del_stream(struct lttng_consumer_stream *stream)
127{
128}
129
d41f73b7
MD
130static inline
131int lttng_ustconsumer_read_subbuffer(struct lttng_consumer_stream *stream,
132 struct lttng_consumer_local_data *ctx)
133{
134 return -ENOSYS;
135}
136
137static inline
138int lttng_ustconsumer_on_recv_stream(struct lttng_consumer_stream *stream)
139{
140 return -ENOSYS;
141}
142
d056b477
MD
143static inline
144void lttng_ustconsumer_on_stream_hangup(struct lttng_consumer_stream *stream)
145{
146}
147
f02e1e8a
DG
148static inline
149int lttng_ustctl_get_mmap_read_offset(struct lttng_ust_shm_handle *handle,
150 struct lttng_ust_lib_ring_buffer *buf, unsigned long *off)
151{
152 return -ENOSYS;
153}
74d0b642 154#endif /* HAVE_LIBLTTNG_UST_CTL */
3bd1e081
MD
155
156#endif /* _LTTNG_USTCONSUMER_H */
This page took 0.05223 seconds and 4 git commands to generate.