X-Git-Url: https://git.lttng.org/?p=lttng-tools.git;a=blobdiff_plain;f=src%2Fbin%2Flttng-sessiond%2Ftrace-kernel.c;h=cbafd12bd45ebbb35177894136a30e0cf7269ca5;hp=0c14052e1a37aeb986ab51ab14e6578caa3d0ad9;hb=HEAD;hpb=850767541647c102a299d7fbc39c97555ac70224

diff --git a/src/bin/lttng-sessiond/trace-kernel.c b/src/bin/lttng-sessiond/trace-kernel.c
deleted file mode 100644
index 0c14052e1..000000000
--- a/src/bin/lttng-sessiond/trace-kernel.c
+++ /dev/null
@@ -1,480 +0,0 @@
-/*
- * Copyright (C)  2011 - David Goulet <david.goulet@polymtl.ca>
- *
- * This program is free software; you can redistribute it and/or modify
- * it under the terms of the GNU General Public License, version 2 only,
- * as published by the Free Software Foundation.
- *
- * This program is distributed in the hope that it will be useful,
- * but WITHOUT ANY WARRANTY; without even the implied warranty of
- * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
- * GNU General Public License for more details.
- *
- * You should have received a copy of the GNU General Public License along
- * with this program; if not, write to the Free Software Foundation, Inc.,
- * 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA.
- */
-
-#define _GNU_SOURCE
-#include <stdio.h>
-#include <stdlib.h>
-#include <string.h>
-#include <unistd.h>
-
-#include <common/common.h>
-#include <common/defaults.h>
-
-#include "consumer.h"
-#include "trace-kernel.h"
-
-/*
- * Find the channel name for the given kernel session.
- */
-struct ltt_kernel_channel *trace_kernel_get_channel_by_name(
-		char *name, struct ltt_kernel_session *session)
-{
-	struct ltt_kernel_channel *chan;
-
-	assert(session);
-	assert(name);
-
-	/*
-	 * If we receive an empty string for channel name, it means the
-	 * default channel name is requested.
-	 */
-	if (name[0] == '\0')
-		name = DEFAULT_CHANNEL_NAME;
-
-	DBG("Trying to find channel %s", name);
-
-	cds_list_for_each_entry(chan, &session->channel_list.head, list) {
-		if (strcmp(name, chan->channel->name) == 0) {
-			DBG("Found channel by name %s", name);
-			return chan;
-		}
-	}
-
-	return NULL;
-}
-
-/*
- * Find the event name for the given channel.
- */
-struct ltt_kernel_event *trace_kernel_get_event_by_name(
-		char *name, struct ltt_kernel_channel *channel)
-{
-	struct ltt_kernel_event *ev;
-
-	assert(name);
-	assert(channel);
-
-	cds_list_for_each_entry(ev, &channel->events_list.head, list) {
-		if (strcmp(name, ev->event->name) == 0) {
-			DBG("Found event by name %s for channel %s", name,
-					channel->channel->name);
-			return ev;
-		}
-	}
-
-	return NULL;
-}
-
-/*
- * Allocate and initialize a kernel session data structure.
- *
- * Return pointer to structure or NULL.
- */
-struct ltt_kernel_session *trace_kernel_create_session(void)
-{
-	struct ltt_kernel_session *lks = NULL;
-
-	/* Allocate a new ltt kernel session */
-	lks = zmalloc(sizeof(struct ltt_kernel_session));
-	if (lks == NULL) {
-		PERROR("create kernel session zmalloc");
-		goto alloc_error;
-	}
-
-	/* Init data structure */
-	lks->fd = -1;
-	lks->metadata_stream_fd = -1;
-	lks->channel_count = 0;
-	lks->stream_count_global = 0;
-	lks->metadata = NULL;
-	CDS_INIT_LIST_HEAD(&lks->channel_list.head);
-
-	lks->consumer = consumer_create_output(CONSUMER_DST_LOCAL);
-	if (lks->consumer == NULL) {
-		goto error;
-	}
-
-	/*
-	 * The tmp_consumer stays NULL until a set_consumer_uri command is
-	 * executed. At this point, the consumer should be nullify until an
-	 * enable_consumer command. This assignment is symbolic since we've zmalloc
-	 * the struct.
-	 */
-	lks->tmp_consumer = NULL;
-
-	return lks;
-
-error:
-	free(lks);
-
-alloc_error:
-	return NULL;
-}
-
-/*
- * Allocate and initialize a kernel channel data structure.
- *
- * Return pointer to structure or NULL.
- */
-struct ltt_kernel_channel *trace_kernel_create_channel(
-		struct lttng_channel *chan)
-{
-	struct ltt_kernel_channel *lkc;
-
-	assert(chan);
-
-	lkc = zmalloc(sizeof(struct ltt_kernel_channel));
-	if (lkc == NULL) {
-		PERROR("ltt_kernel_channel zmalloc");
-		goto error;
-	}
-
-	lkc->channel = zmalloc(sizeof(struct lttng_channel));
-	if (lkc->channel == NULL) {
-		PERROR("lttng_channel zmalloc");
-		free(lkc);
-		goto error;
-	}
-	memcpy(lkc->channel, chan, sizeof(struct lttng_channel));
-
-	/*
-	 * If we receive an empty string for channel name, it means the
-	 * default channel name is requested.
-	 */
-	if (chan->name[0] == '\0') {
-		strncpy(lkc->channel->name, DEFAULT_CHANNEL_NAME,
-			sizeof(lkc->channel->name));
-	}
-	lkc->channel->name[LTTNG_UST_SYM_NAME_LEN - 1] = '\0';
-
-	lkc->fd = -1;
-	lkc->stream_count = 0;
-	lkc->event_count = 0;
-	lkc->enabled = 1;
-	lkc->ctx = NULL;
-	/* Init linked list */
-	CDS_INIT_LIST_HEAD(&lkc->events_list.head);
-	CDS_INIT_LIST_HEAD(&lkc->stream_list.head);
-
-	return lkc;
-
-error:
-	return NULL;
-}
-
-/*
- * Allocate and initialize a kernel event. Set name and event type.
- *
- * Return pointer to structure or NULL.
- */
-struct ltt_kernel_event *trace_kernel_create_event(struct lttng_event *ev)
-{
-	struct ltt_kernel_event *lke;
-	struct lttng_kernel_event *attr;
-
-	assert(ev);
-
-	lke = zmalloc(sizeof(struct ltt_kernel_event));
-	attr = zmalloc(sizeof(struct lttng_kernel_event));
-	if (lke == NULL || attr == NULL) {
-		PERROR("kernel event zmalloc");
-		goto error;
-	}
-
-	switch (ev->type) {
-	case LTTNG_EVENT_PROBE:
-		attr->instrumentation = LTTNG_KERNEL_KPROBE;
-		attr->u.kprobe.addr = ev->attr.probe.addr;
-		attr->u.kprobe.offset = ev->attr.probe.offset;
-		strncpy(attr->u.kprobe.symbol_name,
-				ev->attr.probe.symbol_name, LTTNG_KERNEL_SYM_NAME_LEN);
-		attr->u.kprobe.symbol_name[LTTNG_KERNEL_SYM_NAME_LEN - 1] = '\0';
-		break;
-	case LTTNG_EVENT_FUNCTION:
-		attr->instrumentation = LTTNG_KERNEL_KRETPROBE;
-		attr->u.kretprobe.addr = ev->attr.probe.addr;
-		attr->u.kretprobe.offset = ev->attr.probe.offset;
-		strncpy(attr->u.kretprobe.symbol_name,
-				ev->attr.probe.symbol_name, LTTNG_KERNEL_SYM_NAME_LEN);
-		attr->u.kretprobe.symbol_name[LTTNG_KERNEL_SYM_NAME_LEN - 1] = '\0';
-		break;
-	case LTTNG_EVENT_FUNCTION_ENTRY:
-		attr->instrumentation = LTTNG_KERNEL_FUNCTION;
-		strncpy(attr->u.ftrace.symbol_name,
-				ev->attr.ftrace.symbol_name, LTTNG_KERNEL_SYM_NAME_LEN);
-		attr->u.ftrace.symbol_name[LTTNG_KERNEL_SYM_NAME_LEN - 1] = '\0';
-		break;
-	case LTTNG_EVENT_TRACEPOINT:
-		attr->instrumentation = LTTNG_KERNEL_TRACEPOINT;
-		break;
-	case LTTNG_EVENT_SYSCALL:
-		attr->instrumentation = LTTNG_KERNEL_SYSCALL;
-		break;
-	case LTTNG_EVENT_ALL:
-		attr->instrumentation = LTTNG_KERNEL_ALL;
-		break;
-	default:
-		ERR("Unknown kernel instrumentation type (%d)", ev->type);
-		goto error;
-	}
-
-	/* Copy event name */
-	strncpy(attr->name, ev->name, LTTNG_KERNEL_SYM_NAME_LEN);
-	attr->name[LTTNG_KERNEL_SYM_NAME_LEN - 1] = '\0';
-
-	/* Setting up a kernel event */
-	lke->fd = -1;
-	lke->event = attr;
-	lke->enabled = 1;
-
-	return lke;
-
-error:
-	free(lke);
-	free(attr);
-	return NULL;
-}
-
-/*
- * Allocate and initialize a kernel metadata.
- *
- * Return pointer to structure or NULL.
- */
-struct ltt_kernel_metadata *trace_kernel_create_metadata(void)
-{
-	struct ltt_kernel_metadata *lkm;
-	struct lttng_channel *chan;
-
-	lkm = zmalloc(sizeof(struct ltt_kernel_metadata));
-	chan = zmalloc(sizeof(struct lttng_channel));
-	if (lkm == NULL || chan == NULL) {
-		PERROR("kernel metadata zmalloc");
-		goto error;
-	}
-
-	/* Set default attributes */
-	chan->attr.overwrite = DEFAULT_CHANNEL_OVERWRITE;
-	chan->attr.subbuf_size = default_get_metadata_subbuf_size();
-	chan->attr.num_subbuf = DEFAULT_METADATA_SUBBUF_NUM;
-	chan->attr.switch_timer_interval = DEFAULT_KERNEL_CHANNEL_SWITCH_TIMER;
-	chan->attr.read_timer_interval = DEFAULT_KERNEL_CHANNEL_READ_TIMER;
-	chan->attr.output = DEFAULT_KERNEL_CHANNEL_OUTPUT;
-
-	/* Init metadata */
-	lkm->fd = -1;
-	lkm->conf = chan;
-
-	return lkm;
-
-error:
-	free(lkm);
-	free(chan);
-	return NULL;
-}
-
-/*
- * Allocate and initialize a kernel stream. The stream is set to ACTIVE_FD by
- * default.
- *
- * Return pointer to structure or NULL.
- */
-struct ltt_kernel_stream *trace_kernel_create_stream(const char *name,
-		unsigned int count)
-{
-	int ret;
-	struct ltt_kernel_stream *lks;
-
-	assert(name);
-
-	lks = zmalloc(sizeof(struct ltt_kernel_stream));
-	if (lks == NULL) {
-		PERROR("kernel stream zmalloc");
-		goto error;
-	}
-
-	/* Set name */
-	ret = snprintf(lks->name, sizeof(lks->name), "%s_%d", name, count);
-	if (ret < 0) {
-		PERROR("snprintf stream name");
-		goto error;
-	}
-	lks->name[sizeof(lks->name) - 1] = '\0';
-
-	/* Init stream */
-	lks->fd = -1;
-	lks->state = 0;
-	lks->cpu = count;
-
-	return lks;
-
-error:
-	return NULL;
-}
-
-/*
- * Cleanup kernel stream structure.
- */
-void trace_kernel_destroy_stream(struct ltt_kernel_stream *stream)
-{
-	assert(stream);
-
-	DBG("[trace] Closing stream fd %d", stream->fd);
-	/* Close kernel fd */
-	if (stream->fd >= 0) {
-		int ret;
-
-		ret = close(stream->fd);
-		if (ret) {
-			PERROR("close");
-		}
-	}
-	/* Remove from stream list */
-	cds_list_del(&stream->list);
-
-	free(stream);
-}
-
-/*
- * Cleanup kernel event structure.
- */
-void trace_kernel_destroy_event(struct ltt_kernel_event *event)
-{
-	assert(event);
-
-	if (event->fd >= 0) {
-		int ret;
-
-		DBG("[trace] Closing event fd %d", event->fd);
-		/* Close kernel fd */
-		ret = close(event->fd);
-		if (ret) {
-			PERROR("close");
-		}
-	} else {
-		DBG("[trace] Tearing down event (no associated fd)");
-	}
-
-	/* Remove from event list */
-	cds_list_del(&event->list);
-
-	free(event->event);
-	free(event);
-}
-
-/*
- * Cleanup kernel channel structure.
- */
-void trace_kernel_destroy_channel(struct ltt_kernel_channel *channel)
-{
-	struct ltt_kernel_stream *stream, *stmp;
-	struct ltt_kernel_event *event, *etmp;
-	int ret;
-
-	assert(channel);
-
-	DBG("[trace] Closing channel fd %d", channel->fd);
-	/* Close kernel fd */
-	if (channel->fd >= 0) {
-		ret = close(channel->fd);
-		if (ret) {
-			PERROR("close");
-		}
-	}
-
-	/* For each stream in the channel list */
-	cds_list_for_each_entry_safe(stream, stmp, &channel->stream_list.head, list) {
-		trace_kernel_destroy_stream(stream);
-	}
-
-	/* For each event in the channel list */
-	cds_list_for_each_entry_safe(event, etmp, &channel->events_list.head, list) {
-		trace_kernel_destroy_event(event);
-	}
-
-	/* Remove from channel list */
-	cds_list_del(&channel->list);
-
-	free(channel->channel);
-	free(channel->ctx);
-	free(channel);
-}
-
-/*
- * Cleanup kernel metadata structure.
- */
-void trace_kernel_destroy_metadata(struct ltt_kernel_metadata *metadata)
-{
-	assert(metadata);
-
-	DBG("[trace] Closing metadata fd %d", metadata->fd);
-	/* Close kernel fd */
-	if (metadata->fd >= 0) {
-		int ret;
-
-		ret = close(metadata->fd);
-		if (ret) {
-			PERROR("close");
-		}
-	}
-
-	free(metadata->conf);
-	free(metadata);
-}
-
-/*
- * Cleanup kernel session structure
- *
- * Should *NOT* be called with RCU read-side lock held.
- */
-void trace_kernel_destroy_session(struct ltt_kernel_session *session)
-{
-	struct ltt_kernel_channel *channel, *ctmp;
-	int ret;
-
-	assert(session);
-
-	DBG("[trace] Closing session fd %d", session->fd);
-	/* Close kernel fds */
-	if (session->fd >= 0) {
-		ret = close(session->fd);
-		if (ret) {
-			PERROR("close");
-		}
-	}
-
-	if (session->metadata_stream_fd >= 0) {
-		DBG("[trace] Closing metadata stream fd %d", session->metadata_stream_fd);
-		ret = close(session->metadata_stream_fd);
-		if (ret) {
-			PERROR("close");
-		}
-	}
-
-	if (session->metadata != NULL) {
-		trace_kernel_destroy_metadata(session->metadata);
-	}
-
-	cds_list_for_each_entry_safe(channel, ctmp, &session->channel_list.head, list) {
-		trace_kernel_destroy_channel(channel);
-	}
-
-	/* Wipe consumer output object */
-	consumer_destroy_output(session->consumer);
-	consumer_destroy_output(session->tmp_consumer);
-
-	free(session);
-}