Test for new metadata at each packet
[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);
e316aad5 41extern int lttng_ustconsumer_add_stream(struct lttng_consumer_stream *stream);
3bd1e081
MD
42extern void lttng_ustconsumer_del_stream(struct lttng_consumer_stream *stream);
43
d41f73b7
MD
44int lttng_ustconsumer_read_subbuffer(struct lttng_consumer_stream *stream,
45 struct lttng_consumer_local_data *ctx);
46int lttng_ustconsumer_on_recv_stream(struct lttng_consumer_stream *stream);
47
d056b477
MD
48void lttng_ustconsumer_on_stream_hangup(struct lttng_consumer_stream *stream);
49
ffe60014
DG
50int lttng_ustctl_get_mmap_read_offset(struct lttng_consumer_stream *stream,
51 unsigned long *off);
52void *lttng_ustctl_get_mmap_base(struct lttng_consumer_stream *stream);
6d805429 53int lttng_ustconsumer_data_pending(struct lttng_consumer_stream *stream);
d88aee68 54void lttng_ustconsumer_close_metadata(struct lttng_ht *ht);
d8ef542d 55void lttng_ustconsumer_close_stream_wakeup(struct lttng_consumer_stream *stream);
331744e3 56int lttng_ustconsumer_recv_metadata(int sock, uint64_t key, uint64_t offset,
5e41ebe1 57 uint64_t len, struct lttng_consumer_channel *channel,
94d49140 58 int timer, int wait);
331744e3 59int lttng_ustconsumer_request_metadata(struct lttng_consumer_local_data *ctx,
94d49140
JD
60 struct lttng_consumer_channel *channel, int timer, int wait);
61int lttng_ustconsumer_sync_metadata(struct lttng_consumer_local_data *ctx,
62 struct lttng_consumer_stream *metadata);
f02e1e8a 63
74d0b642 64#else /* HAVE_LIBLTTNG_UST_CTL */
3bd1e081
MD
65
66static inline
4078b776 67ssize_t lttng_ustconsumer_on_read_subbuffer_mmap(
3bd1e081 68 struct lttng_consumer_local_data *ctx,
1d4dfdef
DG
69 struct lttng_consumer_stream *stream, unsigned long len,
70 unsigned long padding)
3bd1e081
MD
71{
72 return -ENOSYS;
73}
74
75static inline
4078b776 76ssize_t lttng_ustconsumer_on_read_subbuffer_splice(
3bd1e081 77 struct lttng_consumer_local_data *ctx,
1d4dfdef
DG
78 struct lttng_consumer_stream *uststream, unsigned long len,
79 unsigned long padding)
3bd1e081
MD
80{
81 return -ENOSYS;
82}
83
84static inline
ffe60014 85int lttng_ustconsumer_take_snapshot(struct lttng_consumer_stream *stream)
3bd1e081
MD
86{
87 return -ENOSYS;
88}
89
90static inline
91int lttng_ustconsumer_get_produced_snapshot(
ffe60014 92 struct lttng_consumer_stream *stream, unsigned long *pos)
3bd1e081
MD
93{
94 return -ENOSYS;
95}
96
97static inline
98int lttng_ustconsumer_recv_cmd(struct lttng_consumer_local_data *ctx,
fbc72522
DG
99 int sock, struct pollfd *consumer_sockpoll)
100{
101 return -ENOSYS;
102}
3bd1e081
MD
103
104static inline
105int lttng_ustconsumer_allocate_channel(struct lttng_consumer_channel *chan)
106{
107 return -ENOSYS;
108}
109
110static inline
111void lttng_ustconsumer_del_channel(struct lttng_consumer_channel *chan)
112{
113}
114
115static inline
e316aad5 116int lttng_ustconsumer_add_stream(struct lttng_consumer_stream *stream)
3bd1e081
MD
117{
118 return -ENOSYS;
119}
120
121static inline
122void lttng_ustconsumer_del_stream(struct lttng_consumer_stream *stream)
123{
124}
125
d41f73b7
MD
126static inline
127int lttng_ustconsumer_read_subbuffer(struct lttng_consumer_stream *stream,
128 struct lttng_consumer_local_data *ctx)
129{
130 return -ENOSYS;
131}
132
133static inline
134int lttng_ustconsumer_on_recv_stream(struct lttng_consumer_stream *stream)
135{
136 return -ENOSYS;
137}
138
d056b477
MD
139static inline
140void lttng_ustconsumer_on_stream_hangup(struct lttng_consumer_stream *stream)
141{
142}
143
f02e1e8a 144static inline
ffe60014
DG
145int lttng_ustctl_get_mmap_read_offset(struct lttng_consumer_stream *stream,
146 unsigned long *off)
f02e1e8a
DG
147{
148 return -ENOSYS;
149}
ca22feea 150static inline
6d805429 151int lttng_ustconsumer_data_pending(struct lttng_consumer_stream *stream)
ca22feea
DG
152{
153 return -ENOSYS;
154}
ffe60014
DG
155static inline
156void *lttng_ustctl_get_mmap_base(struct lttng_consumer_stream *stream)
157{
158 return NULL;
159}
d88aee68
DG
160static inline
161void lttng_ustconsumer_close_metadata(struct lttng_ht *ht)
162{
163}
d8ef542d
MD
164static inline
165void lttng_ustconsumer_close_stream_wakeup(struct lttng_consumer_stream *stream)
166{
167}
ee69440b
DG
168static inline
169int lttng_ustconsumer_recv_metadata(int sock, uint64_t key, uint64_t offset,
5e41ebe1
MD
170 uint64_t len, struct lttng_consumer_channel *channel,
171 int timer)
ee69440b
DG
172{
173 return -ENOSYS;
174}
175static inline
ee69440b 176int lttng_ustconsumer_request_metadata(struct lttng_consumer_local_data *ctx,
5e41ebe1 177 struct lttng_consumer_channel *channel, int timer)
ee69440b
DG
178{
179 return -ENOSYS;
180}
94d49140
JD
181static inline
182int lttng_ustconsumer_sync_metadata(struct lttng_consumer_local_data *ctx,
183 struct lttng_consumer_stream *metadata)
184{
185 return -ENOSYS;
186}
74d0b642 187#endif /* HAVE_LIBLTTNG_UST_CTL */
3bd1e081
MD
188
189#endif /* _LTTNG_USTCONSUMER_H */
This page took 0.068456 seconds and 4 git commands to generate.