projects / lttng-tools.git / blame
? search:
summary | shortlog | log | commit | commitdiff | tree
blob | blame (incremental) | history | HEAD
Fix: free metadata cache after grace period in consumer
[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
ffe60014 29int lttng_ustconsumer_take_snapshot(struct lttng_consumer_stream *stream);
3bd1e081 30
3bd1e081 31int lttng_ustconsumer_get_produced_snapshot(
ffe60014 32 struct lttng_consumer_stream *stream, unsigned long *pos);
10a50311
JD		 33int lttng_ustconsumer_get_consumed_snapshot(
34 struct lttng_consumer_stream *stream, unsigned long *pos);
3bd1e081
MD		 35
36int lttng_ustconsumer_recv_cmd(struct lttng_consumer_local_data *ctx,
37 int sock, struct pollfd *consumer_sockpoll);
38
39extern int lttng_ustconsumer_allocate_channel(struct lttng_consumer_channel *chan);
40extern void lttng_ustconsumer_del_channel(struct lttng_consumer_channel *chan);
b83e03c4 41extern void lttng_ustconsumer_free_channel(struct lttng_consumer_channel *chan);
e316aad5 42extern int lttng_ustconsumer_add_stream(struct lttng_consumer_stream *stream);
3bd1e081
MD		 43extern void lttng_ustconsumer_del_stream(struct lttng_consumer_stream *stream);
44
d41f73b7
MD		 45int lttng_ustconsumer_read_subbuffer(struct lttng_consumer_stream *stream,
46 struct lttng_consumer_local_data *ctx);
47int lttng_ustconsumer_on_recv_stream(struct lttng_consumer_stream *stream);
48
d056b477
MD		 49void lttng_ustconsumer_on_stream_hangup(struct lttng_consumer_stream *stream);
50
ffe60014
DG		 51int lttng_ustctl_get_mmap_read_offset(struct lttng_consumer_stream *stream,
52 unsigned long *off);
53void *lttng_ustctl_get_mmap_base(struct lttng_consumer_stream *stream);
70190e1c
DG		 54int lttng_ustconsumer_get_stream_id(struct lttng_consumer_stream *stream,
55 uint64_t *stream_id);
6d805429 56int lttng_ustconsumer_data_pending(struct lttng_consumer_stream *stream);
6d574024
DG		 57void lttng_ustconsumer_close_all_metadata(struct lttng_ht *ht);
58void lttng_ustconsumer_close_metadata(struct lttng_consumer_channel *metadata);
d8ef542d 59void lttng_ustconsumer_close_stream_wakeup(struct lttng_consumer_stream *stream);
331744e3 60int lttng_ustconsumer_recv_metadata(int sock, uint64_t key, uint64_t offset,
5e41ebe1 61 uint64_t len, struct lttng_consumer_channel *channel,
94d49140 62 int timer, int wait);
331744e3 63int lttng_ustconsumer_request_metadata(struct lttng_consumer_local_data *ctx,
94d49140
JD		 64 struct lttng_consumer_channel *channel, int timer, int wait);
65int lttng_ustconsumer_sync_metadata(struct lttng_consumer_local_data *ctx,
66 struct lttng_consumer_stream *metadata);
84a182ce
DG		 67void lttng_ustconsumer_flush_buffer(struct lttng_consumer_stream *stream,
68 int producer);
69int lttng_ustconsumer_get_current_timestamp(
70 struct lttng_consumer_stream *stream, uint64_t *ts);
f02e1e8a 71
74d0b642 72#else /* HAVE_LIBLTTNG_UST_CTL */
3bd1e081
MD		 73
74static inline
4078b776 75ssize_t lttng_ustconsumer_on_read_subbuffer_mmap(
3bd1e081 76 struct lttng_consumer_local_data *ctx,
1d4dfdef
DG		 77 struct lttng_consumer_stream *stream, unsigned long len,
78 unsigned long padding)
3bd1e081
MD		 79{
80 return -ENOSYS;
81}
82
83static inline
4078b776 84ssize_t lttng_ustconsumer_on_read_subbuffer_splice(
3bd1e081 85 struct lttng_consumer_local_data *ctx,
1d4dfdef
DG		 86 struct lttng_consumer_stream *uststream, unsigned long len,
87 unsigned long padding)
3bd1e081
MD		 88{
89 return -ENOSYS;
90}
91
92static inline
ffe60014 93int lttng_ustconsumer_take_snapshot(struct lttng_consumer_stream *stream)
3bd1e081
MD		 94{
95 return -ENOSYS;
96}
97
98static inline
99int lttng_ustconsumer_get_produced_snapshot(
ffe60014 100 struct lttng_consumer_stream *stream, unsigned long *pos)
3bd1e081
MD		 101{
102 return -ENOSYS;
103}
104
105static inline
106int lttng_ustconsumer_recv_cmd(struct lttng_consumer_local_data *ctx,
fbc72522
DG		 107 int sock, struct pollfd *consumer_sockpoll)
108{
109 return -ENOSYS;
110}
3bd1e081
MD		 111
112static inline
113int lttng_ustconsumer_allocate_channel(struct lttng_consumer_channel *chan)
114{
115 return -ENOSYS;
116}
117
118static inline
119void lttng_ustconsumer_del_channel(struct lttng_consumer_channel *chan)
120{
121}
122
b83e03c4
MD		 123static inline
124void lttng_ustconsumer_free_channel(struct lttng_consumer_channel *chan)
125{
126}
127
3bd1e081 128static inline
e316aad5 129int lttng_ustconsumer_add_stream(struct lttng_consumer_stream *stream)
3bd1e081
MD		 130{
131 return -ENOSYS;
132}
133
134static inline
135void lttng_ustconsumer_del_stream(struct lttng_consumer_stream *stream)
136{
137}
138
d41f73b7
MD		 139static inline
140int lttng_ustconsumer_read_subbuffer(struct lttng_consumer_stream *stream,
141 struct lttng_consumer_local_data *ctx)
142{
143 return -ENOSYS;
144}
145
146static inline
147int lttng_ustconsumer_on_recv_stream(struct lttng_consumer_stream *stream)
148{
149 return -ENOSYS;
150}
151
d056b477
MD		 152static inline
153void lttng_ustconsumer_on_stream_hangup(struct lttng_consumer_stream *stream)
154{
155}
156
f02e1e8a 157static inline
ffe60014
DG		 158int lttng_ustctl_get_mmap_read_offset(struct lttng_consumer_stream *stream,
159 unsigned long *off)
f02e1e8a
DG		 160{
161 return -ENOSYS;
162}
ca22feea 163static inline
6d805429 164int lttng_ustconsumer_data_pending(struct lttng_consumer_stream *stream)
ca22feea
DG		 165{
166 return -ENOSYS;
167}
ffe60014
DG		 168static inline
169void *lttng_ustctl_get_mmap_base(struct lttng_consumer_stream *stream)
170{
171 return NULL;
172}
d88aee68 173static inline
6d574024
DG		 174void lttng_ustconsumer_close_all_metadata(struct lttng_ht *ht)
175{
176}
177static inline
178void lttng_ustconsumer_close_metadata(struct lttng_consumer_channel *metadata)
d88aee68
DG		 179{
180}
d8ef542d
MD		 181static inline
182void lttng_ustconsumer_close_stream_wakeup(struct lttng_consumer_stream *stream)
183{
184}
ee69440b
DG		 185static inline
186int lttng_ustconsumer_recv_metadata(int sock, uint64_t key, uint64_t offset,
5e41ebe1
MD		 187 uint64_t len, struct lttng_consumer_channel *channel,
188 int timer)
ee69440b
DG		 189{
190 return -ENOSYS;
191}
192static inline
ee69440b 193int lttng_ustconsumer_request_metadata(struct lttng_consumer_local_data *ctx,
84a182ce 194 struct lttng_consumer_channel *channel, int timer, int wait)
ee69440b
DG		 195{
196 return -ENOSYS;
197}
94d49140
JD		 198static inline
199int lttng_ustconsumer_sync_metadata(struct lttng_consumer_local_data *ctx,
200 struct lttng_consumer_stream *metadata)
201{
202 return -ENOSYS;
203}
84a182ce
DG		 204static inline
205void lttng_ustconsumer_flush_buffer(struct lttng_consumer_stream *stream,
206 int producer)
207{
208}
209static inline
210int lttng_ustconsumer_get_current_timestamp(
211 struct lttng_consumer_stream *stream, uint64_t *ts)
212{
213 return -ENOSYS;
214}
70190e1c
DG		 215static inline
216int lttng_ustconsumer_get_stream_id(struct lttng_consumer_stream *stream,
217 uint64_t *stream_id)
218{
219 return -ENOSYS;
220}
74d0b642 221#endif /* HAVE_LIBLTTNG_UST_CTL */
3bd1e081
MD		 222
223#endif /* _LTTNG_USTCONSUMER_H */
LTTng 2.0 tools and control repository
This page took 0.04992 seconds and 4 git commands to generate.