2 * Copyright (C) 2011 - David Goulet <david.goulet@polymtl.ca>
4 * This program is free software; you can redistribute it and/or modify it
5 * under the terms of the GNU General Public License as published by the Free
6 * Software Foundation; only version 2 of the License.
8 * This program is distributed in the hope that it will be useful, but WITHOUT
9 * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
10 * FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License for
13 * You should have received a copy of the GNU General Public License along with
14 * this program; if not, write to the Free Software Foundation, Inc., 59 Temple
15 * Place - Suite 330, Boston, MA 02111-1307, USA.
22 #include <common/common.h>
23 #include <common/defaults.h>
24 #include <common/sessiond-comm/sessiond-comm.h>
33 * Return allocated channel attributes.
35 struct lttng_channel
*channel_new_default_attr(int dom
)
37 struct lttng_channel
*chan
;
39 chan
= zmalloc(sizeof(struct lttng_channel
));
41 PERROR("zmalloc channel init");
45 if (snprintf(chan
->name
, sizeof(chan
->name
), "%s",
46 DEFAULT_CHANNEL_NAME
) < 0) {
47 PERROR("snprintf default channel name");
51 chan
->attr
.overwrite
= DEFAULT_CHANNEL_OVERWRITE
;
52 chan
->attr
.switch_timer_interval
= DEFAULT_CHANNEL_SWITCH_TIMER
;
53 chan
->attr
.read_timer_interval
= DEFAULT_CHANNEL_READ_TIMER
;
56 case LTTNG_DOMAIN_KERNEL
:
57 chan
->attr
.subbuf_size
= DEFAULT_KERNEL_CHANNEL_SUBBUF_SIZE
;
58 chan
->attr
.num_subbuf
= DEFAULT_KERNEL_CHANNEL_SUBBUF_NUM
;
59 chan
->attr
.output
= DEFAULT_KERNEL_CHANNEL_OUTPUT
;
61 case LTTNG_DOMAIN_UST
:
62 case LTTNG_DOMAIN_UST_PID
:
63 chan
->attr
.subbuf_size
= DEFAULT_UST_CHANNEL_SUBBUF_SIZE
;
64 chan
->attr
.num_subbuf
= DEFAULT_UST_CHANNEL_SUBBUF_NUM
;
65 chan
->attr
.output
= DEFAULT_UST_CHANNEL_OUTPUT
;
68 goto error
; /* Not implemented */
80 * Disable kernel channel of the kernel session.
82 int channel_kernel_disable(struct ltt_kernel_session
*ksession
,
86 struct ltt_kernel_channel
*kchan
;
88 kchan
= trace_kernel_get_channel_by_name(channel_name
, ksession
);
90 ret
= LTTCOMM_KERN_CHAN_NOT_FOUND
;
92 } else if (kchan
->enabled
== 1) {
93 ret
= kernel_disable_channel(kchan
);
94 if (ret
< 0 && ret
!= -EEXIST
) {
95 ret
= LTTCOMM_KERN_CHAN_DISABLE_FAIL
;
107 * Enable kernel channel of the kernel session.
109 int channel_kernel_enable(struct ltt_kernel_session
*ksession
,
110 struct ltt_kernel_channel
*kchan
)
114 if (kchan
->enabled
== 0) {
115 ret
= kernel_enable_channel(kchan
);
117 ret
= LTTCOMM_KERN_CHAN_ENABLE_FAIL
;
129 * Create kernel channel of the kernel session and notify kernel thread.
131 int channel_kernel_create(struct ltt_kernel_session
*ksession
,
132 struct lttng_channel
*attr
, int kernel_pipe
)
135 struct lttng_channel
*defattr
= NULL
;
137 /* Creating channel attributes if needed */
139 defattr
= channel_new_default_attr(LTTNG_DOMAIN_KERNEL
);
140 if (defattr
== NULL
) {
147 /* Channel not found, creating it */
148 ret
= kernel_create_channel(ksession
, attr
, ksession
->trace_path
);
150 ret
= LTTCOMM_KERN_CHAN_FAIL
;
154 /* Notify kernel thread that there is a new channel */
155 ret
= notify_thread_pipe(kernel_pipe
);
168 * Enable UST channel for session and domain.
170 int channel_ust_enable(struct ltt_ust_session
*usess
, int domain
,
171 struct ltt_ust_channel
*uchan
)
173 int ret
= LTTCOMM_OK
;
175 /* If already enabled, everything is OK */
176 if (uchan
->enabled
) {
177 DBG3("Channel %s already enabled. Skipping", uchan
->name
);
182 case LTTNG_DOMAIN_UST
:
183 DBG2("Channel %s being enabled in UST global domain", uchan
->name
);
184 /* Enable channel for global domain */
185 ret
= ust_app_enable_channel_glb(usess
, uchan
);
187 case LTTNG_DOMAIN_UST_PID
:
188 case LTTNG_DOMAIN_UST_PID_FOLLOW_CHILDREN
:
189 case LTTNG_DOMAIN_UST_EXEC_NAME
:
190 ret
= LTTCOMM_NOT_IMPLEMENTED
;
195 if (ret
!= -EEXIST
) {
196 ret
= LTTCOMM_UST_CHAN_ENABLE_FAIL
;
204 DBG2("Channel %s enabled successfully", uchan
->name
);
212 * Create UST channel for session and domain.
214 int channel_ust_create(struct ltt_ust_session
*usess
, int domain
,
215 struct lttng_channel
*attr
)
217 int ret
= LTTCOMM_OK
;
218 struct ltt_ust_channel
*uchan
= NULL
;
219 struct lttng_channel
*defattr
= NULL
;
221 /* Creating channel attributes if needed */
223 defattr
= channel_new_default_attr(domain
);
224 if (defattr
== NULL
) {
231 /* Create UST channel */
232 uchan
= trace_ust_create_channel(attr
, usess
->pathname
);
240 case LTTNG_DOMAIN_UST
:
241 DBG2("Channel %s being created in UST global domain", uchan
->name
);
243 /* Enable channel for global domain */
244 ret
= ust_app_create_channel_glb(usess
, uchan
);
246 case LTTNG_DOMAIN_UST_PID
:
247 case LTTNG_DOMAIN_UST_PID_FOLLOW_CHILDREN
:
248 case LTTNG_DOMAIN_UST_EXEC_NAME
:
250 ret
= LTTCOMM_NOT_IMPLEMENTED
;
251 goto error_free_chan
;
254 if (ret
< 0 && ret
!= -EEXIST
) {
255 ret
= LTTCOMM_UST_CHAN_ENABLE_FAIL
;
256 goto error_free_chan
;
259 /* Adding the channel to the channel hash table. */
261 lttng_ht_add_unique_str(usess
->domain_global
.channels
, &uchan
->node
);
264 DBG2("Channel %s created successfully", uchan
->name
);
271 * No need to remove the channel from the hash table because at this point
272 * it was not added hence the direct call and no call_rcu().
274 trace_ust_destroy_channel(uchan
);
281 * Disable UST channel for session and domain.
283 int channel_ust_disable(struct ltt_ust_session
*usess
, int domain
,
284 struct ltt_ust_channel
*uchan
)
286 int ret
= LTTCOMM_OK
;
288 /* Already disabled */
289 if (uchan
->enabled
== 0) {
290 DBG2("Channel UST %s already disabled", uchan
->name
);
294 /* Get the right channel's hashtable */
296 case LTTNG_DOMAIN_UST
:
297 DBG2("Channel %s being disabled in UST global domain", uchan
->name
);
298 /* Disable channel for global domain */
299 ret
= ust_app_disable_channel_glb(usess
, uchan
);
301 case LTTNG_DOMAIN_UST_PID_FOLLOW_CHILDREN
:
302 case LTTNG_DOMAIN_UST_EXEC_NAME
:
303 case LTTNG_DOMAIN_UST_PID
:
304 ret
= LTTCOMM_NOT_IMPLEMENTED
;
308 if (ret
< 0 && ret
!= -EEXIST
) {
309 ret
= LTTCOMM_UST_DISABLE_FAIL
;
315 DBG2("Channel %s disabled successfully", uchan
->name
);