Fix: hide internal libcommon time utilities
[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
3bd1e081
MD
22#include <errno.h>
23
c8fea79c 24#include <common/consumer/consumer.h>
02d02e31 25#include <stdbool.h>
10a8a223 26
74d0b642 27#ifdef HAVE_LIBLTTNG_UST_CTL
3bd1e081 28
ffe60014 29int lttng_ustconsumer_take_snapshot(struct lttng_consumer_stream *stream);
e9404c27
JG
30int lttng_ustconsumer_sample_snapshot_positions(
31 struct lttng_consumer_stream *stream);
3bd1e081 32
3bd1e081 33int lttng_ustconsumer_get_produced_snapshot(
ffe60014 34 struct lttng_consumer_stream *stream, unsigned long *pos);
10a50311
JD
35int lttng_ustconsumer_get_consumed_snapshot(
36 struct lttng_consumer_stream *stream, unsigned long *pos);
3bd1e081
MD
37
38int lttng_ustconsumer_recv_cmd(struct lttng_consumer_local_data *ctx,
39 int sock, struct pollfd *consumer_sockpoll);
40
41extern int lttng_ustconsumer_allocate_channel(struct lttng_consumer_channel *chan);
42extern void lttng_ustconsumer_del_channel(struct lttng_consumer_channel *chan);
b83e03c4 43extern void lttng_ustconsumer_free_channel(struct lttng_consumer_channel *chan);
e316aad5 44extern int lttng_ustconsumer_add_stream(struct lttng_consumer_stream *stream);
3bd1e081
MD
45extern void lttng_ustconsumer_del_stream(struct lttng_consumer_stream *stream);
46
d41f73b7 47int lttng_ustconsumer_read_subbuffer(struct lttng_consumer_stream *stream,
02d02e31 48 struct lttng_consumer_local_data *ctx, bool *rotated);
d41f73b7
MD
49int lttng_ustconsumer_on_recv_stream(struct lttng_consumer_stream *stream);
50
d056b477
MD
51void lttng_ustconsumer_on_stream_hangup(struct lttng_consumer_stream *stream);
52
ffe60014
DG
53int lttng_ustctl_get_mmap_read_offset(struct lttng_consumer_stream *stream,
54 unsigned long *off);
55void *lttng_ustctl_get_mmap_base(struct lttng_consumer_stream *stream);
fc6d7a51
JD
56void lttng_ustctl_flush_buffer(struct lttng_consumer_stream *stream,
57 int producer_active);
70190e1c
DG
58int lttng_ustconsumer_get_stream_id(struct lttng_consumer_stream *stream,
59 uint64_t *stream_id);
6d805429 60int lttng_ustconsumer_data_pending(struct lttng_consumer_stream *stream);
6d574024
DG
61void lttng_ustconsumer_close_all_metadata(struct lttng_ht *ht);
62void lttng_ustconsumer_close_metadata(struct lttng_consumer_channel *metadata);
d8ef542d 63void lttng_ustconsumer_close_stream_wakeup(struct lttng_consumer_stream *stream);
331744e3 64int lttng_ustconsumer_recv_metadata(int sock, uint64_t key, uint64_t offset,
93ec662e
JD
65 uint64_t len, uint64_t version,
66 struct lttng_consumer_channel *channel, int timer, int wait);
331744e3 67int lttng_ustconsumer_request_metadata(struct lttng_consumer_local_data *ctx,
94d49140
JD
68 struct lttng_consumer_channel *channel, int timer, int wait);
69int lttng_ustconsumer_sync_metadata(struct lttng_consumer_local_data *ctx,
70 struct lttng_consumer_stream *metadata);
84a182ce
DG
71void lttng_ustconsumer_flush_buffer(struct lttng_consumer_stream *stream,
72 int producer);
73int lttng_ustconsumer_get_current_timestamp(
74 struct lttng_consumer_stream *stream, uint64_t *ts);
fb83fe64
JD
75int lttng_ustconsumer_get_sequence_number(
76 struct lttng_consumer_stream *stream, uint64_t *seq);
f02e1e8a 77
74d0b642 78#else /* HAVE_LIBLTTNG_UST_CTL */
3bd1e081
MD
79
80static inline
4078b776 81ssize_t lttng_ustconsumer_on_read_subbuffer_mmap(
3bd1e081 82 struct lttng_consumer_local_data *ctx,
1d4dfdef
DG
83 struct lttng_consumer_stream *stream, unsigned long len,
84 unsigned long padding)
3bd1e081
MD
85{
86 return -ENOSYS;
87}
88
89static inline
4078b776 90ssize_t lttng_ustconsumer_on_read_subbuffer_splice(
3bd1e081 91 struct lttng_consumer_local_data *ctx,
1d4dfdef
DG
92 struct lttng_consumer_stream *uststream, unsigned long len,
93 unsigned long padding)
3bd1e081
MD
94{
95 return -ENOSYS;
96}
97
98static inline
ffe60014 99int lttng_ustconsumer_take_snapshot(struct lttng_consumer_stream *stream)
3bd1e081
MD
100{
101 return -ENOSYS;
102}
103
e9404c27
JG
104static inline
105int lttng_ustconsumer_sample_snapshot_positions(
106 struct lttng_consumer_stream *stream)
107{
108 return -ENOSYS;
109}
110
3bd1e081
MD
111static inline
112int lttng_ustconsumer_get_produced_snapshot(
ffe60014 113 struct lttng_consumer_stream *stream, unsigned long *pos)
3bd1e081
MD
114{
115 return -ENOSYS;
116}
117
e9404c27
JG
118static inline
119int lttng_ustconsumer_get_consumed_snapshot(
120 struct lttng_consumer_stream *stream, unsigned long *pos)
121{
122 return -ENOSYS;
123}
124
3bd1e081
MD
125static inline
126int lttng_ustconsumer_recv_cmd(struct lttng_consumer_local_data *ctx,
fbc72522
DG
127 int sock, struct pollfd *consumer_sockpoll)
128{
129 return -ENOSYS;
130}
3bd1e081
MD
131
132static inline
133int lttng_ustconsumer_allocate_channel(struct lttng_consumer_channel *chan)
134{
135 return -ENOSYS;
136}
137
138static inline
139void lttng_ustconsumer_del_channel(struct lttng_consumer_channel *chan)
140{
141}
142
b83e03c4
MD
143static inline
144void lttng_ustconsumer_free_channel(struct lttng_consumer_channel *chan)
145{
146}
147
3bd1e081 148static inline
e316aad5 149int lttng_ustconsumer_add_stream(struct lttng_consumer_stream *stream)
3bd1e081
MD
150{
151 return -ENOSYS;
152}
153
154static inline
155void lttng_ustconsumer_del_stream(struct lttng_consumer_stream *stream)
156{
157}
158
d41f73b7
MD
159static inline
160int lttng_ustconsumer_read_subbuffer(struct lttng_consumer_stream *stream,
02d02e31 161 struct lttng_consumer_local_data *ctx, bool *rotated)
d41f73b7
MD
162{
163 return -ENOSYS;
164}
165
166static inline
167int lttng_ustconsumer_on_recv_stream(struct lttng_consumer_stream *stream)
168{
169 return -ENOSYS;
170}
171
d056b477
MD
172static inline
173void lttng_ustconsumer_on_stream_hangup(struct lttng_consumer_stream *stream)
174{
175}
176
f02e1e8a 177static inline
ffe60014
DG
178int lttng_ustctl_get_mmap_read_offset(struct lttng_consumer_stream *stream,
179 unsigned long *off)
f02e1e8a
DG
180{
181 return -ENOSYS;
182}
ca22feea 183static inline
6d805429 184int lttng_ustconsumer_data_pending(struct lttng_consumer_stream *stream)
ca22feea
DG
185{
186 return -ENOSYS;
187}
ffe60014
DG
188static inline
189void *lttng_ustctl_get_mmap_base(struct lttng_consumer_stream *stream)
190{
191 return NULL;
192}
d88aee68 193static inline
fc6d7a51
JD
194void lttng_ustctl_flush_buffer(struct lttng_consumer_stream *stream,
195 int producer_active)
196{
197}
198static inline
6d574024
DG
199void lttng_ustconsumer_close_all_metadata(struct lttng_ht *ht)
200{
201}
202static inline
203void lttng_ustconsumer_close_metadata(struct lttng_consumer_channel *metadata)
d88aee68
DG
204{
205}
d8ef542d
MD
206static inline
207void lttng_ustconsumer_close_stream_wakeup(struct lttng_consumer_stream *stream)
208{
209}
ee69440b
DG
210static inline
211int lttng_ustconsumer_recv_metadata(int sock, uint64_t key, uint64_t offset,
93ec662e
JD
212 uint64_t len, uint64_t version,
213 struct lttng_consumer_channel *channel, int timer)
ee69440b
DG
214{
215 return -ENOSYS;
216}
217static inline
ee69440b 218int lttng_ustconsumer_request_metadata(struct lttng_consumer_local_data *ctx,
84a182ce 219 struct lttng_consumer_channel *channel, int timer, int wait)
ee69440b
DG
220{
221 return -ENOSYS;
222}
94d49140
JD
223static inline
224int lttng_ustconsumer_sync_metadata(struct lttng_consumer_local_data *ctx,
225 struct lttng_consumer_stream *metadata)
226{
227 return -ENOSYS;
228}
84a182ce
DG
229static inline
230void lttng_ustconsumer_flush_buffer(struct lttng_consumer_stream *stream,
231 int producer)
232{
233}
234static inline
235int lttng_ustconsumer_get_current_timestamp(
236 struct lttng_consumer_stream *stream, uint64_t *ts)
237{
238 return -ENOSYS;
239}
a31c9f22 240static inline
fb83fe64
JD
241int lttng_ustconsumer_get_sequence_number(
242 struct lttng_consumer_stream *stream, uint64_t *seq)
243{
244 return -ENOSYS;
245}
70190e1c
DG
246static inline
247int lttng_ustconsumer_get_stream_id(struct lttng_consumer_stream *stream,
248 uint64_t *stream_id)
249{
250 return -ENOSYS;
251}
74d0b642 252#endif /* HAVE_LIBLTTNG_UST_CTL */
3bd1e081
MD
253
254#endif /* _LTTNG_USTCONSUMER_H */
This page took 0.064651 seconds and 4 git commands to generate.