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