Fix: define _LGPL_SOURCE in C files
[lttng-tools.git] / src / bin / lttng-sessiond / kernel.c
CommitLineData
20fe2104
DG
1/*
2 * Copyright (C) 2011 - David Goulet <david.goulet@polymtl.ca>
3 *
d14d33bf
AM
4 * This program is free software; you can redistribute it and/or modify
5 * it under the terms of the GNU General Public License, version 2 only,
6 * as published by the Free Software Foundation.
20fe2104
DG
7 *
8 * This program is distributed in the hope that it will be useful,
9 * but WITHOUT ANY WARRANTY; without even the implied warranty of
10 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
11 * GNU General Public License for more details.
12 *
d14d33bf
AM
13 * You should have received a copy of the GNU General Public License along
14 * with this program; if not, write to the Free Software Foundation, Inc.,
15 * 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA.
20fe2104
DG
16 */
17
8c0faa1d 18#define _GNU_SOURCE
6c1c0768 19#define _LGPL_SOURCE
20fe2104 20#include <errno.h>
7b395890 21#include <fcntl.h>
20fe2104
DG
22#include <stdlib.h>
23#include <stdio.h>
f34daff7 24#include <string.h>
8c0faa1d 25#include <unistd.h>
77c7c900 26#include <inttypes.h>
20fe2104 27
990570ed 28#include <common/common.h>
db758600 29#include <common/kernel-ctl/kernel-ctl.h>
c052142c 30#include <common/kernel-ctl/kernel-ioctl.h>
42224349 31#include <common/sessiond-comm/sessiond-comm.h>
1e307fab 32
2f77fc4b 33#include "consumer.h"
4771f025 34#include "kernel.h"
6dc3064a 35#include "kernel-consumer.h"
096102bd 36#include "kern-modules.h"
834978fd 37#include "utils.h"
20fe2104 38
d65106b1 39/*
050349bb 40 * Add context on a kernel channel.
d65106b1
DG
41 */
42int kernel_add_channel_context(struct ltt_kernel_channel *chan,
645328ae 43 struct ltt_kernel_context *ctx)
d65106b1
DG
44{
45 int ret;
46
0525e9ae
DG
47 assert(chan);
48 assert(ctx);
49
d65106b1 50 DBG("Adding context to channel %s", chan->channel->name);
645328ae 51 ret = kernctl_add_context(chan->fd, &ctx->ctx);
d65106b1 52 if (ret < 0) {
b579acd9 53 if (errno != EEXIST) {
df0f840b 54 PERROR("add context ioctl");
b579acd9
DG
55 } else {
56 /* If EEXIST, we just ignore the error */
57 ret = 0;
58 }
d65106b1
DG
59 goto error;
60 }
61
645328ae 62 cds_list_add_tail(&ctx->list, &chan->ctx_list);
d65106b1
DG
63
64 return 0;
65
66error:
67 return ret;
68}
69
20fe2104 70/*
050349bb
DG
71 * Create a new kernel session, register it to the kernel tracer and add it to
72 * the session daemon session.
20fe2104 73 */
8c0faa1d 74int kernel_create_session(struct ltt_session *session, int tracer_fd)
20fe2104
DG
75{
76 int ret;
77 struct ltt_kernel_session *lks;
78
0525e9ae
DG
79 assert(session);
80
54012638 81 /* Allocate data structure */
dec56f6c 82 lks = trace_kernel_create_session();
20fe2104 83 if (lks == NULL) {
54012638 84 ret = -1;
20fe2104
DG
85 goto error;
86 }
87
54012638 88 /* Kernel tracer session creation */
20fe2104
DG
89 ret = kernctl_create_session(tracer_fd);
90 if (ret < 0) {
df0f840b 91 PERROR("ioctl kernel create session");
20fe2104
DG
92 goto error;
93 }
94
20fe2104 95 lks->fd = ret;
7b395890
DG
96 /* Prevent fd duplication after execlp() */
97 ret = fcntl(lks->fd, F_SETFD, FD_CLOEXEC);
98 if (ret < 0) {
df0f840b 99 PERROR("fcntl session fd");
7b395890
DG
100 }
101
53632229 102 lks->id = session->id;
3bd1e081 103 lks->consumer_fds_sent = 0;
8c0faa1d 104 session->kernel_session = lks;
8c0faa1d
DG
105
106 DBG("Kernel session created (fd: %d)", lks->fd);
20fe2104
DG
107
108 return 0;
109
110error:
5f62c685
DG
111 if (lks) {
112 trace_kernel_destroy_session(lks);
113 }
20fe2104
DG
114 return ret;
115}
116
117/*
050349bb
DG
118 * Create a kernel channel, register it to the kernel tracer and add it to the
119 * kernel session.
20fe2104 120 */
050349bb 121int kernel_create_channel(struct ltt_kernel_session *session,
fdd9eb17 122 struct lttng_channel *chan)
20fe2104
DG
123{
124 int ret;
125 struct ltt_kernel_channel *lkc;
20fe2104 126
0525e9ae
DG
127 assert(session);
128 assert(chan);
0525e9ae 129
54012638 130 /* Allocate kernel channel */
fdd9eb17 131 lkc = trace_kernel_create_channel(chan);
54012638 132 if (lkc == NULL) {
20fe2104
DG
133 goto error;
134 }
135
ecc48a90 136 DBG3("Kernel create channel %s with attr: %d, %" PRIu64 ", %" PRIu64 ", %u, %u, %d, %d",
fdd9eb17 137 chan->name, lkc->channel->attr.overwrite,
173af62f
DG
138 lkc->channel->attr.subbuf_size, lkc->channel->attr.num_subbuf,
139 lkc->channel->attr.switch_timer_interval, lkc->channel->attr.read_timer_interval,
ecc48a90 140 lkc->channel->attr.live_timer_interval, lkc->channel->attr.output);
173af62f 141
54012638 142 /* Kernel tracer channel creation */
f3ed775e 143 ret = kernctl_create_channel(session->fd, &lkc->channel->attr);
20fe2104 144 if (ret < 0) {
df0f840b 145 PERROR("ioctl kernel create channel");
20fe2104
DG
146 goto error;
147 }
148
54012638 149 /* Setup the channel fd */
20fe2104 150 lkc->fd = ret;
7b395890
DG
151 /* Prevent fd duplication after execlp() */
152 ret = fcntl(lkc->fd, F_SETFD, FD_CLOEXEC);
153 if (ret < 0) {
df0f840b 154 PERROR("fcntl session fd");
7b395890
DG
155 }
156
54012638 157 /* Add channel to session */
8c0faa1d
DG
158 cds_list_add(&lkc->list, &session->channel_list.head);
159 session->channel_count++;
fb5f35b6 160 lkc->session = session;
20fe2104 161
00e2e675 162 DBG("Kernel channel %s created (fd: %d)", lkc->channel->name, lkc->fd);
20fe2104
DG
163
164 return 0;
165
166error:
5f62c685
DG
167 if (lkc) {
168 free(lkc->channel);
169 free(lkc);
170 }
54012638 171 return -1;
20fe2104 172}
f34daff7
DG
173
174/*
050349bb
DG
175 * Create a kernel event, enable it to the kernel tracer and add it to the
176 * channel event list of the kernel session.
f34daff7 177 */
050349bb
DG
178int kernel_create_event(struct lttng_event *ev,
179 struct ltt_kernel_channel *channel)
f34daff7
DG
180{
181 int ret;
182 struct ltt_kernel_event *event;
f34daff7 183
0525e9ae
DG
184 assert(ev);
185 assert(channel);
186
62499ad6 187 event = trace_kernel_create_event(ev);
54012638 188 if (event == NULL) {
d87bfb32 189 ret = -1;
f34daff7
DG
190 goto error;
191 }
192
f3ed775e
DG
193 ret = kernctl_create_event(channel->fd, event->event);
194 if (ret < 0) {
bd29c13d
DG
195 switch (errno) {
196 case EEXIST:
197 break;
198 case ENOSYS:
199 WARN("Event type not implemented");
200 break;
8197a339
DG
201 case ENOENT:
202 WARN("Event %s not found!", ev->name);
203 break;
bd29c13d 204 default:
d87bfb32
DG
205 PERROR("create event ioctl");
206 }
207 ret = -errno;
e953ef25 208 goto free_event;
8c0faa1d 209 }
f34daff7 210
5f822d0a 211 /*
2c425ff7 212 * LTTNG_KERNEL_SYSCALL event creation will return 0 on success.
5f822d0a
DG
213 */
214 if (ret == 0 && event->event->instrumentation == LTTNG_KERNEL_SYSCALL) {
215 DBG2("Kernel event syscall creation success");
87eb4ab8
MD
216 /*
217 * We use fd == -1 to ensure that we never trigger a close of fd
218 * 0.
219 */
220 event->fd = -1;
2c425ff7 221 goto add_list;
5f822d0a
DG
222 }
223
f3ed775e 224 event->fd = ret;
7b395890
DG
225 /* Prevent fd duplication after execlp() */
226 ret = fcntl(event->fd, F_SETFD, FD_CLOEXEC);
227 if (ret < 0) {
df0f840b 228 PERROR("fcntl session fd");
7b395890
DG
229 }
230
2c425ff7 231add_list:
f3ed775e
DG
232 /* Add event to event list */
233 cds_list_add(&event->list, &channel->events_list.head);
cbbbb275
DG
234 channel->event_count++;
235
e953ef25
DG
236 DBG("Event %s created (fd: %d)", ev->name, event->fd);
237
238 return 0;
239
240free_event:
241 free(event);
242error:
d87bfb32 243 return ret;
e953ef25
DG
244}
245
26cc6b4e 246/*
050349bb 247 * Disable a kernel channel.
26cc6b4e
DG
248 */
249int kernel_disable_channel(struct ltt_kernel_channel *chan)
250{
251 int ret;
252
0525e9ae
DG
253 assert(chan);
254
26cc6b4e
DG
255 ret = kernctl_disable(chan->fd);
256 if (ret < 0) {
df0f840b 257 PERROR("disable chan ioctl");
26cc6b4e
DG
258 ret = errno;
259 goto error;
260 }
261
262 chan->enabled = 0;
263 DBG("Kernel channel %s disabled (fd: %d)", chan->channel->name, chan->fd);
264
265 return 0;
266
267error:
268 return ret;
269}
270
d36b8583 271/*
050349bb 272 * Enable a kernel channel.
d36b8583
DG
273 */
274int kernel_enable_channel(struct ltt_kernel_channel *chan)
275{
276 int ret;
277
0525e9ae
DG
278 assert(chan);
279
d36b8583 280 ret = kernctl_enable(chan->fd);
54d01ffb 281 if (ret < 0 && errno != EEXIST) {
df0f840b 282 PERROR("Enable kernel chan");
d36b8583
DG
283 goto error;
284 }
285
286 chan->enabled = 1;
287 DBG("Kernel channel %s enabled (fd: %d)", chan->channel->name, chan->fd);
288
289 return 0;
290
291error:
292 return ret;
293}
294
19e70852 295/*
050349bb 296 * Enable a kernel event.
19e70852
DG
297 */
298int kernel_enable_event(struct ltt_kernel_event *event)
299{
300 int ret;
301
0525e9ae
DG
302 assert(event);
303
19e70852 304 ret = kernctl_enable(event->fd);
42224349
DG
305 if (ret < 0) {
306 switch (errno) {
307 case EEXIST:
f73fabfd 308 ret = LTTNG_ERR_KERN_EVENT_EXIST;
42224349
DG
309 break;
310 default:
311 PERROR("enable kernel event");
312 break;
313 }
19e70852
DG
314 goto error;
315 }
316
317 event->enabled = 1;
318 DBG("Kernel event %s enabled (fd: %d)", event->event->name, event->fd);
319
320 return 0;
321
322error:
d36b8583 323 return ret;
19e70852
DG
324}
325
e953ef25 326/*
050349bb 327 * Disable a kernel event.
e953ef25 328 */
19e70852 329int kernel_disable_event(struct ltt_kernel_event *event)
e953ef25
DG
330{
331 int ret;
19e70852 332
0525e9ae
DG
333 assert(event);
334
19e70852 335 ret = kernctl_disable(event->fd);
42224349
DG
336 if (ret < 0) {
337 switch (errno) {
338 case EEXIST:
f73fabfd 339 ret = LTTNG_ERR_KERN_EVENT_EXIST;
42224349
DG
340 break;
341 default:
342 PERROR("disable kernel event");
343 break;
344 }
19e70852 345 goto error;
e953ef25 346 }
f3ed775e 347
19e70852
DG
348 event->enabled = 0;
349 DBG("Kernel event %s disabled (fd: %d)", event->event->name, event->fd);
350
f34daff7
DG
351 return 0;
352
353error:
d36b8583 354 return ret;
f34daff7 355}
aaf26714 356
6e911cad
MD
357int kernel_enable_syscall(const char *syscall_name,
358 struct ltt_kernel_channel *channel)
359{
360 return kernctl_enable_syscall(channel->fd, syscall_name);
361}
362
363int kernel_disable_syscall(const char *syscall_name,
364 struct ltt_kernel_channel *channel)
365{
366 return kernctl_disable_syscall(channel->fd, syscall_name);
367}
368
aaf26714 369/*
050349bb
DG
370 * Create kernel metadata, open from the kernel tracer and add it to the
371 * kernel session.
aaf26714 372 */
a4b92340 373int kernel_open_metadata(struct ltt_kernel_session *session)
aaf26714
DG
374{
375 int ret;
74024a21 376 struct ltt_kernel_metadata *lkm = NULL;
aaf26714 377
0525e9ae
DG
378 assert(session);
379
54012638 380 /* Allocate kernel metadata */
a4b92340 381 lkm = trace_kernel_create_metadata();
54012638 382 if (lkm == NULL) {
aaf26714
DG
383 goto error;
384 }
385
54012638 386 /* Kernel tracer metadata creation */
f3ed775e 387 ret = kernctl_open_metadata(session->fd, &lkm->conf->attr);
aaf26714 388 if (ret < 0) {
74024a21 389 goto error_open;
aaf26714
DG
390 }
391
8c0faa1d 392 lkm->fd = ret;
7b395890
DG
393 /* Prevent fd duplication after execlp() */
394 ret = fcntl(lkm->fd, F_SETFD, FD_CLOEXEC);
395 if (ret < 0) {
df0f840b 396 PERROR("fcntl session fd");
7b395890
DG
397 }
398
aaf26714 399 session->metadata = lkm;
8c0faa1d 400
00e2e675 401 DBG("Kernel metadata opened (fd: %d)", lkm->fd);
8c0faa1d
DG
402
403 return 0;
404
74024a21
DG
405error_open:
406 trace_kernel_destroy_metadata(lkm);
8c0faa1d 407error:
54012638 408 return -1;
8c0faa1d
DG
409}
410
411/*
050349bb 412 * Start tracing session.
8c0faa1d
DG
413 */
414int kernel_start_session(struct ltt_kernel_session *session)
415{
416 int ret;
417
0525e9ae
DG
418 assert(session);
419
8c0faa1d
DG
420 ret = kernctl_start_session(session->fd);
421 if (ret < 0) {
df0f840b 422 PERROR("ioctl start session");
8c0faa1d
DG
423 goto error;
424 }
425
426 DBG("Kernel session started");
427
428 return 0;
429
430error:
431 return ret;
432}
433
f3ed775e 434/*
050349bb 435 * Make a kernel wait to make sure in-flight probe have completed.
f3ed775e
DG
436 */
437void kernel_wait_quiescent(int fd)
438{
439 int ret;
440
441 DBG("Kernel quiescent wait on %d", fd);
442
443 ret = kernctl_wait_quiescent(fd);
444 if (ret < 0) {
df0f840b 445 PERROR("wait quiescent ioctl");
f3ed775e
DG
446 ERR("Kernel quiescent wait failed");
447 }
448}
449
d0254c7c 450/*
050349bb 451 * Kernel calibrate
d0254c7c
MD
452 */
453int kernel_calibrate(int fd, struct lttng_kernel_calibrate *calibrate)
454{
455 int ret;
456
0525e9ae
DG
457 assert(calibrate);
458
d0254c7c
MD
459 ret = kernctl_calibrate(fd, calibrate);
460 if (ret < 0) {
df0f840b 461 PERROR("calibrate ioctl");
d0254c7c
MD
462 return -1;
463 }
464
465 return 0;
466}
467
468
f3ed775e 469/*
f3ed775e
DG
470 * Force flush buffer of metadata.
471 */
472int kernel_metadata_flush_buffer(int fd)
473{
474 int ret;
475
169d2cb7
DG
476 DBG("Kernel flushing metadata buffer on fd %d", fd);
477
f3ed775e
DG
478 ret = kernctl_buffer_flush(fd);
479 if (ret < 0) {
00e2e675 480 ERR("Fail to flush metadata buffers %d (ret: %d)", fd, ret);
f3ed775e
DG
481 }
482
483 return 0;
484}
485
486/*
050349bb 487 * Force flush buffer for channel.
f3ed775e
DG
488 */
489int kernel_flush_buffer(struct ltt_kernel_channel *channel)
490{
491 int ret;
492 struct ltt_kernel_stream *stream;
493
0525e9ae
DG
494 assert(channel);
495
f3ed775e
DG
496 DBG("Flush buffer for channel %s", channel->channel->name);
497
498 cds_list_for_each_entry(stream, &channel->stream_list.head, list) {
499 DBG("Flushing channel stream %d", stream->fd);
500 ret = kernctl_buffer_flush(stream->fd);
501 if (ret < 0) {
df0f840b 502 PERROR("ioctl");
f3ed775e
DG
503 ERR("Fail to flush buffer for stream %d (ret: %d)",
504 stream->fd, ret);
505 }
506 }
507
508 return 0;
509}
510
8c0faa1d 511/*
050349bb 512 * Stop tracing session.
8c0faa1d
DG
513 */
514int kernel_stop_session(struct ltt_kernel_session *session)
515{
516 int ret;
517
0525e9ae
DG
518 assert(session);
519
8c0faa1d
DG
520 ret = kernctl_stop_session(session->fd);
521 if (ret < 0) {
522 goto error;
523 }
524
525 DBG("Kernel session stopped");
526
527 return 0;
528
529error:
530 return ret;
531}
532
533/*
050349bb
DG
534 * Open stream of channel, register it to the kernel tracer and add it
535 * to the stream list of the channel.
8c0faa1d 536 *
050349bb 537 * Return the number of created stream. Else, a negative value.
8c0faa1d 538 */
f3ed775e 539int kernel_open_channel_stream(struct ltt_kernel_channel *channel)
8c0faa1d 540{
00e2e675 541 int ret, count = 0;
8c0faa1d
DG
542 struct ltt_kernel_stream *lks;
543
0525e9ae
DG
544 assert(channel);
545
5a47c6a2 546 while ((ret = kernctl_create_stream(channel->fd)) >= 0) {
00e2e675 547 lks = trace_kernel_create_stream(channel->channel->name, count);
8c0faa1d 548 if (lks == NULL) {
799e2c4f
MD
549 ret = close(ret);
550 if (ret) {
551 PERROR("close");
552 }
8c0faa1d
DG
553 goto error;
554 }
555
556 lks->fd = ret;
7b395890
DG
557 /* Prevent fd duplication after execlp() */
558 ret = fcntl(lks->fd, F_SETFD, FD_CLOEXEC);
559 if (ret < 0) {
df0f840b 560 PERROR("fcntl session fd");
7b395890
DG
561 }
562
1624d5b7
JD
563 lks->tracefile_size = channel->channel->attr.tracefile_size;
564 lks->tracefile_count = channel->channel->attr.tracefile_count;
565
54012638 566 /* Add stream to channe stream list */
8c0faa1d
DG
567 cds_list_add(&lks->list, &channel->stream_list.head);
568 channel->stream_count++;
8c0faa1d 569
00e2e675
DG
570 /* Increment counter which represent CPU number. */
571 count++;
572
573 DBG("Kernel stream %s created (fd: %d, state: %d)", lks->name, lks->fd,
574 lks->state);
54012638 575 }
8c0faa1d
DG
576
577 return channel->stream_count;
578
579error:
54012638 580 return -1;
8c0faa1d
DG
581}
582
583/*
050349bb 584 * Open the metadata stream and set it to the kernel session.
8c0faa1d 585 */
f3ed775e 586int kernel_open_metadata_stream(struct ltt_kernel_session *session)
8c0faa1d
DG
587{
588 int ret;
589
0525e9ae
DG
590 assert(session);
591
8c0faa1d
DG
592 ret = kernctl_create_stream(session->metadata->fd);
593 if (ret < 0) {
df0f840b 594 PERROR("kernel create metadata stream");
8c0faa1d
DG
595 goto error;
596 }
597
598 DBG("Kernel metadata stream created (fd: %d)", ret);
599 session->metadata_stream_fd = ret;
7b395890
DG
600 /* Prevent fd duplication after execlp() */
601 ret = fcntl(session->metadata_stream_fd, F_SETFD, FD_CLOEXEC);
602 if (ret < 0) {
df0f840b 603 PERROR("fcntl session fd");
7b395890 604 }
aaf26714
DG
605
606 return 0;
607
608error:
54012638 609 return -1;
aaf26714 610}
2ef84c95
DG
611
612/*
9f19cc17 613 * Get the event list from the kernel tracer and return the number of elements.
2ef84c95 614 */
9f19cc17 615ssize_t kernel_list_events(int tracer_fd, struct lttng_event **events)
2ef84c95 616{
53efb85a 617 int fd, ret;
9f19cc17
DG
618 char *event;
619 size_t nbmem, count = 0;
2ef84c95 620 FILE *fp;
9f19cc17 621 struct lttng_event *elist;
2ef84c95 622
0525e9ae
DG
623 assert(events);
624
2ef84c95
DG
625 fd = kernctl_tracepoint_list(tracer_fd);
626 if (fd < 0) {
df0f840b 627 PERROR("kernel tracepoint list");
2ef84c95
DG
628 goto error;
629 }
630
631 fp = fdopen(fd, "r");
632 if (fp == NULL) {
df0f840b 633 PERROR("kernel tracepoint list fdopen");
61b73b12 634 goto error_fp;
2ef84c95
DG
635 }
636
637 /*
638 * Init memory size counter
639 * See kernel-ctl.h for explanation of this value
640 */
6725fe19 641 nbmem = KERNEL_EVENT_INIT_LIST_SIZE;
ba7f0ae5 642 elist = zmalloc(sizeof(struct lttng_event) * nbmem);
3b870559
MD
643 if (elist == NULL) {
644 PERROR("alloc list events");
645 count = -ENOMEM;
646 goto end;
647 }
2ef84c95 648
53efb85a 649 while (fscanf(fp, "event { name = %m[^;]; };\n", &event) == 1) {
6725fe19 650 if (count >= nbmem) {
3b870559 651 struct lttng_event *new_elist;
53efb85a 652 size_t new_nbmem;
3b870559 653
53efb85a
MD
654 new_nbmem = nbmem << 1;
655 DBG("Reallocating event list from %zu to %zu bytes",
656 nbmem, new_nbmem);
657 new_elist = realloc(elist, new_nbmem * sizeof(struct lttng_event));
3b870559 658 if (new_elist == NULL) {
df0f840b 659 PERROR("realloc list events");
3b870559
MD
660 free(event);
661 free(elist);
61b73b12
MD
662 count = -ENOMEM;
663 goto end;
2ef84c95 664 }
53efb85a
MD
665 /* Zero the new memory */
666 memset(new_elist + nbmem, 0,
667 (new_nbmem - nbmem) * sizeof(struct lttng_event));
668 nbmem = new_nbmem;
3b870559 669 elist = new_elist;
2ef84c95 670 }
99497cd0
MD
671 strncpy(elist[count].name, event, LTTNG_SYMBOL_NAME_LEN);
672 elist[count].name[LTTNG_SYMBOL_NAME_LEN - 1] = '\0';
67b9d018 673 elist[count].enabled = -1;
9f19cc17 674 count++;
3b870559 675 free(event);
2ef84c95
DG
676 }
677
9f19cc17 678 *events = elist;
ced2f820 679 DBG("Kernel list events done (%zu events)", count);
61b73b12 680end:
799e2c4f
MD
681 ret = fclose(fp); /* closes both fp and fd */
682 if (ret) {
683 PERROR("fclose");
684 }
9f19cc17 685 return count;
2ef84c95 686
61b73b12 687error_fp:
799e2c4f
MD
688 ret = close(fd);
689 if (ret) {
690 PERROR("close");
691 }
2ef84c95
DG
692error:
693 return -1;
694}
096102bd
DG
695
696/*
697 * Get kernel version and validate it.
698 */
699int kernel_validate_version(int tracer_fd)
700{
701 int ret;
702 struct lttng_kernel_tracer_version version;
c052142c 703 struct lttng_kernel_tracer_abi_version abi_version;
096102bd
DG
704
705 ret = kernctl_tracer_version(tracer_fd, &version);
706 if (ret < 0) {
707 ERR("Failed at getting the lttng-modules version");
708 goto error;
709 }
710
711 /* Validate version */
c052142c
MD
712 if (version.major != VERSION_MAJOR) {
713 ERR("Kernel tracer major version (%d) is not compatible with lttng-tools major version (%d)",
714 version.major, VERSION_MAJOR);
096102bd 715 goto error_version;
096102bd 716 }
c052142c
MD
717 ret = kernctl_tracer_abi_version(tracer_fd, &abi_version);
718 if (ret < 0) {
719 ERR("Failed at getting lttng-modules ABI version");
720 goto error;
721 }
722 if (abi_version.major != LTTNG_MODULES_ABI_MAJOR_VERSION) {
723 ERR("Kernel tracer ABI version (%d.%d) is not compatible with expected ABI major version (%d.*)",
724 abi_version.major, abi_version.minor,
725 LTTNG_MODULES_ABI_MAJOR_VERSION);
726 goto error;
727 }
728 DBG2("Kernel tracer version validated (%d.%d, ABI %d.%d)",
729 version.major, version.minor,
730 abi_version.major, abi_version.minor);
096102bd
DG
731 return 0;
732
733error_version:
096102bd
DG
734 ret = -1;
735
736error:
737 return ret;
738}
335a95b7
MD
739
740/*
741 * Kernel work-arounds called at the start of sessiond main().
742 */
743int init_kernel_workarounds(void)
744{
8936c33a 745 int ret;
335a95b7
MD
746 FILE *fp;
747
748 /*
749 * boot_id needs to be read once before being used concurrently
750 * to deal with a Linux kernel race. A fix is proposed for
751 * upstream, but the work-around is needed for older kernels.
752 */
753 fp = fopen("/proc/sys/kernel/random/boot_id", "r");
754 if (!fp) {
755 goto end_boot_id;
756 }
757 while (!feof(fp)) {
758 char buf[37] = "";
759
8936c33a
DG
760 ret = fread(buf, 1, sizeof(buf), fp);
761 if (ret < 0) {
762 /* Ignore error, we don't really care */
763 }
335a95b7 764 }
799e2c4f
MD
765 ret = fclose(fp);
766 if (ret) {
767 PERROR("fclose");
768 }
335a95b7 769end_boot_id:
335a95b7
MD
770 return 0;
771}
2f77fc4b
DG
772
773/*
774 * Complete teardown of a kernel session.
775 */
776void kernel_destroy_session(struct ltt_kernel_session *ksess)
777{
778 if (ksess == NULL) {
779 DBG3("No kernel session when tearing down session");
780 return;
781 }
782
783 DBG("Tearing down kernel session");
784
07b86b52 785 /*
15dc512a
DG
786 * Destroy channels on the consumer if at least one FD has been sent and we
787 * are in no output mode because the streams are in *no* monitor mode so we
788 * have to send a command to clean them up or else they leaked.
07b86b52 789 */
15dc512a 790 if (!ksess->output_traces && ksess->consumer_fds_sent) {
07b86b52
JD
791 int ret;
792 struct consumer_socket *socket;
793 struct lttng_ht_iter iter;
794
795 /* For each consumer socket. */
796 cds_lfht_for_each_entry(ksess->consumer->socks->ht, &iter.iter,
797 socket, node.node) {
798 struct ltt_kernel_channel *chan;
799
800 /* For each channel, ask the consumer to destroy it. */
801 cds_list_for_each_entry(chan, &ksess->channel_list.head, list) {
802 ret = kernel_consumer_destroy_channel(socket, chan);
803 if (ret < 0) {
804 /* Consumer is probably dead. Use next socket. */
805 continue;
806 }
807 }
808 }
809 }
810
2f77fc4b
DG
811 /* Close any relayd session */
812 consumer_output_send_destroy_relayd(ksess->consumer);
813
814 trace_kernel_destroy_session(ksess);
815}
fb5f35b6
DG
816
817/*
818 * Destroy a kernel channel object. It does not do anything on the tracer side.
819 */
820void kernel_destroy_channel(struct ltt_kernel_channel *kchan)
821{
822 struct ltt_kernel_session *ksess = NULL;
823
824 assert(kchan);
825 assert(kchan->channel);
826
827 DBG3("Kernel destroy channel %s", kchan->channel->name);
828
829 /* Update channel count of associated session. */
830 if (kchan->session) {
831 /* Keep pointer reference so we can update it after the destroy. */
832 ksess = kchan->session;
833 }
834
835 trace_kernel_destroy_channel(kchan);
836
837 /*
838 * At this point the kernel channel is not visible anymore. This is safe
839 * since in order to work on a visible kernel session, the tracing session
840 * lock (ltt_session.lock) MUST be acquired.
841 */
842 if (ksess) {
843 ksess->channel_count--;
844 }
845}
6dc3064a
DG
846
847/*
848 * Take a snapshot for a given kernel session.
849 *
2a06df8d 850 * Return 0 on success or else return a LTTNG_ERR code.
6dc3064a
DG
851 */
852int kernel_snapshot_record(struct ltt_kernel_session *ksess,
68808f4e 853 struct snapshot_output *output, int wait, uint64_t max_size_per_stream)
6dc3064a 854{
2a06df8d 855 int err, ret, saved_metadata_fd;
6dc3064a
DG
856 struct consumer_socket *socket;
857 struct lttng_ht_iter iter;
858 struct ltt_kernel_metadata *saved_metadata;
859
860 assert(ksess);
861 assert(ksess->consumer);
862 assert(output);
863
864 DBG("Kernel snapshot record started");
865
866 /* Save current metadata since the following calls will change it. */
867 saved_metadata = ksess->metadata;
868 saved_metadata_fd = ksess->metadata_stream_fd;
869
870 rcu_read_lock();
871
872 ret = kernel_open_metadata(ksess);
873 if (ret < 0) {
874 ret = LTTNG_ERR_KERN_META_FAIL;
875 goto error;
876 }
877
878 ret = kernel_open_metadata_stream(ksess);
879 if (ret < 0) {
880 ret = LTTNG_ERR_KERN_META_FAIL;
881 goto error_open_stream;
882 }
883
884 /* Send metadata to consumer and snapshot everything. */
885 cds_lfht_for_each_entry(ksess->consumer->socks->ht, &iter.iter,
886 socket, node.node) {
887 struct consumer_output *saved_output;
888 struct ltt_kernel_channel *chan;
6dc3064a
DG
889
890 /*
891 * Temporarly switch consumer output for our snapshot output. As long
892 * as the session lock is taken, this is safe.
893 */
894 saved_output = ksess->consumer;
895 ksess->consumer = output->consumer;
896
897 pthread_mutex_lock(socket->lock);
898 /* This stream must not be monitored by the consumer. */
07b86b52 899 ret = kernel_consumer_add_metadata(socket, ksess, 0);
6dc3064a 900 pthread_mutex_unlock(socket->lock);
07b86b52 901 /* Put back the saved consumer output into the session. */
6dc3064a
DG
902 ksess->consumer = saved_output;
903 if (ret < 0) {
904 ret = LTTNG_ERR_KERN_CONSUMER_FAIL;
905 goto error_consumer;
906 }
907
908 /* For each channel, ask the consumer to snapshot it. */
909 cds_list_for_each_entry(chan, &ksess->channel_list.head, list) {
07b86b52 910 pthread_mutex_lock(socket->lock);
6dc3064a 911 ret = consumer_snapshot_channel(socket, chan->fd, output, 0,
5c786ded
JD
912 ksess->uid, ksess->gid,
913 DEFAULT_KERNEL_TRACE_DIR, wait,
914 max_size_per_stream);
07b86b52 915 pthread_mutex_unlock(socket->lock);
6dc3064a
DG
916 if (ret < 0) {
917 ret = LTTNG_ERR_KERN_CONSUMER_FAIL;
2a06df8d
DG
918 (void) kernel_consumer_destroy_metadata(socket,
919 ksess->metadata);
6dc3064a
DG
920 goto error_consumer;
921 }
922 }
923
924 /* Snapshot metadata, */
07b86b52 925 pthread_mutex_lock(socket->lock);
6dc3064a 926 ret = consumer_snapshot_channel(socket, ksess->metadata->fd, output,
5c786ded
JD
927 1, ksess->uid, ksess->gid,
928 DEFAULT_KERNEL_TRACE_DIR, wait, max_size_per_stream);
07b86b52 929 pthread_mutex_unlock(socket->lock);
6dc3064a
DG
930 if (ret < 0) {
931 ret = LTTNG_ERR_KERN_CONSUMER_FAIL;
932 goto error_consumer;
933 }
07b86b52
JD
934
935 /*
936 * The metadata snapshot is done, ask the consumer to destroy it since
937 * it's not monitored on the consumer side.
938 */
939 (void) kernel_consumer_destroy_metadata(socket, ksess->metadata);
6dc3064a
DG
940 }
941
fac41e72
DG
942 ret = LTTNG_OK;
943
6dc3064a
DG
944error_consumer:
945 /* Close newly opened metadata stream. It's now on the consumer side. */
2a06df8d
DG
946 err = close(ksess->metadata_stream_fd);
947 if (err < 0) {
6dc3064a
DG
948 PERROR("close snapshot kernel");
949 }
950
951error_open_stream:
952 trace_kernel_destroy_metadata(ksess->metadata);
953error:
954 /* Restore metadata state.*/
955 ksess->metadata = saved_metadata;
956 ksess->metadata_stream_fd = saved_metadata_fd;
957
958 rcu_read_unlock();
959 return ret;
960}
834978fd
DG
961
962/*
963 * Get the syscall mask array from the kernel tracer.
964 *
965 * Return 0 on success else a negative value. In both case, syscall_mask should
966 * be freed.
967 */
968int kernel_syscall_mask(int chan_fd, char **syscall_mask, uint32_t *nr_bits)
969{
970 assert(syscall_mask);
971 assert(nr_bits);
972
973 return kernctl_syscall_mask(chan_fd, syscall_mask, nr_bits);
974}
This page took 0.089681 seconds and 4 git commands to generate.