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