X-Git-Url: http://git.lttng.org./?a=blobdiff_plain;f=libtracectl%2Ftracectl.c;h=3732bc03714ae585297dd3b933e86a912b3c7a29;hb=46ef48cdf8b64608a4f679500bc34293b9f0b649;hp=aca3abc207ae81ad60067778e717a7c11b3ebe92;hpb=68c1021b2136a6aea5dbbe138c5103e30b5d8712;p=lttng-ust.git

diff --git a/libtracectl/tracectl.c b/libtracectl/tracectl.c
index aca3abc2..3732bc03 100644
--- a/libtracectl/tracectl.c
+++ b/libtracectl/tracectl.c
@@ -4,102 +4,648 @@
 #include <sys/types.h>
 #include <sys/socket.h>
 #include <sys/un.h>
-#define UNIX_PATH_MAX 108
+#include <sched.h>
+#include <fcntl.h>
+
+#include "marker.h"
+#include "tracer.h"
+#include "localerr.h"
+#include "ustcomm.h"
+#include "relay.h" /* FIXME: remove */
+
+//#define USE_CLONE
 
-//#define SOCKETDIR "/var/run/ust/socks"
-#define SOCKETDIR "/tmp/socks"
-#define SOCKETDIRLEN sizeof(SOCKETDIR)
 #define USTSIGNAL SIGIO
 
-#define DBG(fmt, args...) fprintf(stderr, fmt "\n", ## args)
-#define WARN(fmt, args...) fprintf(stderr, "usertrace: WARNING: " fmt "\n", ## args)
-#define ERR(fmt, args...) fprintf(stderr, "usertrace: ERROR: " fmt "\n", ## args)
-#define PERROR(call) perror("usertrace: ERROR: " call)
+#define MAX_MSG_SIZE (100)
+#define MSG_NOTIF 1
+#define MSG_REGISTER_NOTIF 2
+
+char consumer_stack[10000];
+
+static struct ustcomm_app ustcomm_app;
 
 struct tracecmd { /* no padding */
 	uint32_t size;
 	uint16_t command;
 };
 
+//struct listener_arg {
+//	int pipe_fd;
+//};
 
-pid_t mypid;
-char mysocketfile[UNIX_PATH_MAX] = "";
+struct trctl_msg {
+	/* size: the size of all the fields except size itself */
+	uint32_t size;
+	uint16_t type;
+	/* Only the necessary part of the payload is transferred. It
+         * may even be none of it.
+         */
+	char payload[94];
+};
 
-void do_command(struct tracecmd *cmd)
+struct consumer_channel {
+	int fd;
+	struct ltt_channel_struct *chan;
+};
+
+int consumer(void *arg)
 {
+	int result;
+	int fd;
+	char str[] = "Hello, this is the consumer.\n";
+	struct ltt_trace_struct *trace;
+	struct consumer_channel *consumer_channels;
+	int i;
+	char trace_name[] = "auto";
+
+	ltt_lock_traces();
+	trace = _ltt_trace_find(trace_name);
+	ltt_unlock_traces();
+
+	if(trace == NULL) {
+		CPRINTF("cannot find trace!");
+		return 1;
+	}
+
+	consumer_channels = (struct consumer_channel *) malloc(trace->nr_channels * sizeof(struct consumer_channel));
+	if(consumer_channels == NULL) {
+		ERR("malloc returned NULL");
+		return 1;
+	}
+
+	CPRINTF("opening trace files");
+	for(i=0; i<trace->nr_channels; i++) {
+		char tmp[100];
+		struct ltt_channel_struct *chan = &trace->channels[i];
+
+		consumer_channels[i].chan = chan;
+
+		snprintf(tmp, sizeof(tmp), "trace/%s_0", chan->channel_name);
+		result = consumer_channels[i].fd = open(tmp, O_WRONLY | O_CREAT | O_TRUNC, 00600);
+		if(result == -1) {
+			perror("open");
+			return -1;
+		}
+		CPRINTF("\topened trace file %s", tmp);
+		
+	}
+	CPRINTF("done opening trace files");
+
+	for(;;) {
+		/*wait*/
+
+		for(i=0; i<trace->nr_channels; i++) {
+			struct rchan *rchan = consumer_channels[i].chan->trans_channel_data;
+			struct rchan_buf *rbuf = rchan->buf;
+			struct ltt_channel_buf_struct *lttbuf = consumer_channels[i].chan->buf;
+			long consumed_old;
+
+			result = ltt_do_get_subbuf(rbuf, lttbuf, &consumed_old);
+			if(result < 0) {
+				DBG("ltt_do_get_subbuf: error: %s", strerror(-result));
+			}
+			else {
+				DBG("success!");
+
+				result = write(consumer_channels[i].fd, rbuf->buf_data + (consumed_old & (2 * 4096-1)), 4096);
+				ltt_do_put_subbuf(rbuf, lttbuf, consumed_old);
+			}
+		}
+
+		sleep(1);
+	}
 }
 
-void receive_commands()
+void start_consumer(void)
 {
-}
+#ifdef USE_CLONE
+	int result;
 
-/* The signal handler itself. */
+	result = clone(consumer, consumer_stack+sizeof(consumer_stack)-1, CLONE_FS | CLONE_FILES | CLONE_VM | CLONE_SIGHAND | CLONE_THREAD, NULL);
+	if(result == -1) {
+		perror("clone");
+	}
+#else
+	pthread_t thread;
 
-void sighandler(int sig)
+	pthread_create(&thread, NULL, consumer, NULL);
+#endif
+}
+
+static void print_markers(void)
 {
-	DBG("sighandler");
-	receive_commands();
+	struct marker_iter iter;
+
+	lock_markers();
+	marker_iter_reset(&iter);
+	marker_iter_start(&iter);
+
+	while(iter.marker) {
+		fprintf(stderr, "marker: %s_%s \"%s\"\n", iter.marker->channel, iter.marker->name, iter.marker->format);
+		marker_iter_next(&iter);
+	}
+	unlock_markers();
 }
 
-/* Called by the app signal handler to chain it to us. */
+void do_command(struct tracecmd *cmd)
+{
+}
 
-void chain_signal()
+void receive_commands()
 {
-	sighandler(USTSIGNAL);
 }
 
-int init_socket()
+int fd_notif = -1;
+void notif_cb(void)
 {
 	int result;
-	int fd;
-	char pidstr[6];
-	int pidlen;
+	struct trctl_msg msg;
 
-	struct sockaddr_un addr;
-	
-	result = fd = socket(PF_UNIX, SOCK_SEQPACKET, 0);
+	/* FIXME: fd_notif should probably be protected by a spinlock */
+
+	if(fd_notif == -1)
+		return;
+
+	msg.type = MSG_NOTIF;
+	msg.size = sizeof(msg.type);
+
+	/* FIXME: don't block here */
+	result = write(fd_notif, &msg, msg.size+sizeof(msg.size));
 	if(result == -1) {
-		PERROR("socket");
-		return -1;
+		PERROR("write");
+		return;
 	}
+}
 
-	addr.sun_family = AF_UNIX;
+static int inform_consumer_daemon(void)
+{
+	ustcomm_request_consumer(getpid(), "metadata");
+	ustcomm_request_consumer(getpid(), "ust");
+}
+
+int listener_main(void *p)
+{
+	int result;
 
-	result = snprintf(addr.sun_path, UNIX_PATH_MAX, "%s/%d", SOCKETDIR, mypid);
-	if(result >= UNIX_PATH_MAX) {
-		ERR("string overflow allocating socket name");
-		goto close_sock;
+	DBG("LISTENER");
+
+	for(;;) {
+		uint32_t size;
+		struct sockaddr_un addr;
+		socklen_t addrlen = sizeof(addr);
+		char trace_name[] = "auto";
+		char trace_type[] = "ustrelay";
+		char *recvbuf;
+		int len;
+		struct ustcomm_source src;
+
+		result = ustcomm_app_recv_message(&ustcomm_app, &recvbuf, &src, -1);
+		if(result <= 0) {
+			WARN("error in ustcomm_app_recv_message");
+			continue;
+		}
+
+		DBG("received a message! it's: %s\n", recvbuf);
+		len = strlen(recvbuf);
+
+		if(!strcmp(recvbuf, "print_markers")) {
+			print_markers();
+		}
+		else if(!strcmp(recvbuf, "trace_setup")) {
+			DBG("trace setup");
+
+			result = ltt_trace_setup(trace_name);
+			if(result < 0) {
+				ERR("ltt_trace_setup failed");
+				return;
+			}
+
+			result = ltt_trace_set_type(trace_name, trace_type);
+			if(result < 0) {
+				ERR("ltt_trace_set_type failed");
+				return;
+			}
+		}
+		else if(!strcmp(recvbuf, "trace_alloc")) {
+			DBG("trace alloc");
+
+			result = ltt_trace_alloc(trace_name);
+			if(result < 0) {
+				ERR("ltt_trace_alloc failed");
+				return;
+			}
+		}
+		else if(!strcmp(recvbuf, "trace_start")) {
+			DBG("trace start");
+
+			result = ltt_trace_start(trace_name);
+			if(result < 0) {
+				ERR("ltt_trace_start failed");
+				continue;
+			}
+		}
+		else if(!strcmp(recvbuf, "trace_stop")) {
+			DBG("trace stop");
+
+			result = ltt_trace_stop(trace_name);
+			if(result < 0) {
+				ERR("ltt_trace_stop failed");
+				return;
+			}
+		}
+		else if(!strcmp(recvbuf, "trace_destroy")) {
+
+			DBG("trace destroy");
+
+			result = ltt_trace_destroy(trace_name);
+			if(result < 0) {
+				ERR("ltt_trace_destroy failed");
+				return;
+			}
+		}
+		else if(nth_token_is(recvbuf, "get_shmid", 0) == 1) {
+			struct ltt_trace_struct *trace;
+			char trace_name[] = "auto";
+			int i;
+			char *channel_name;
+
+			DBG("get_shmid");
+
+			channel_name = nth_token(recvbuf, 1);
+			if(channel_name == NULL) {
+				ERR("get_shmid: cannot parse channel");
+				goto next_cmd;
+			}
+
+			ltt_lock_traces();
+			trace = _ltt_trace_find(trace_name);
+			ltt_unlock_traces();
+
+			if(trace == NULL) {
+				CPRINTF("cannot find trace!");
+				return 1;
+			}
+
+			for(i=0; i<trace->nr_channels; i++) {
+				struct rchan *rchan = trace->channels[i].trans_channel_data;
+				struct rchan_buf *rbuf = rchan->buf;
+
+				if(!strcmp(trace->channels[i].channel_name, channel_name)) {
+					char *reply;
+
+					DBG("the shmid for the requested channel is %d", rbuf->shmid);
+					asprintf(&reply, "%d", rbuf->shmid);
+
+					result = ustcomm_send_reply(&ustcomm_app.server, reply, &src);
+					if(result) {
+						ERR("listener: get_shmid: ustcomm_send_reply failed");
+						goto next_cmd;
+					}
+
+					free(reply);
+
+					break;
+				}
+			}
+		}
+		else if(nth_token_is(recvbuf, "get_n_subbufs", 0) == 1) {
+			struct ltt_trace_struct *trace;
+			char trace_name[] = "auto";
+			int i;
+			char *channel_name;
+
+			DBG("get_n_subbufs");
+
+			channel_name = nth_token(recvbuf, 1);
+			if(channel_name == NULL) {
+				ERR("get_n_subbufs: cannot parse channel");
+				goto next_cmd;
+			}
+
+			ltt_lock_traces();
+			trace = _ltt_trace_find(trace_name);
+			ltt_unlock_traces();
+
+			if(trace == NULL) {
+				CPRINTF("cannot find trace!");
+				return 1;
+			}
+
+			for(i=0; i<trace->nr_channels; i++) {
+				struct rchan *rchan = trace->channels[i].trans_channel_data;
+
+				if(!strcmp(trace->channels[i].channel_name, channel_name)) {
+					char *reply;
+
+					DBG("the n_subbufs for the requested channel is %d", rchan->n_subbufs);
+					asprintf(&reply, "%d", rchan->n_subbufs);
+
+					result = ustcomm_send_reply(&ustcomm_app.server, reply, &src);
+					if(result) {
+						ERR("listener: get_n_subbufs: ustcomm_send_reply failed");
+						goto next_cmd;
+					}
+
+					free(reply);
+
+					break;
+				}
+			}
+		}
+		else if(nth_token_is(recvbuf, "get_subbuf_size", 0) == 1) {
+			struct ltt_trace_struct *trace;
+			char trace_name[] = "auto";
+			int i;
+			char *channel_name;
+
+			DBG("get_subbuf_size");
+
+			channel_name = nth_token(recvbuf, 1);
+			if(channel_name == NULL) {
+				ERR("get_subbuf_size: cannot parse channel");
+				goto next_cmd;
+			}
+
+			ltt_lock_traces();
+			trace = _ltt_trace_find(trace_name);
+			ltt_unlock_traces();
+
+			if(trace == NULL) {
+				CPRINTF("cannot find trace!");
+				return 1;
+			}
+
+			for(i=0; i<trace->nr_channels; i++) {
+				struct rchan *rchan = trace->channels[i].trans_channel_data;
+
+				if(!strcmp(trace->channels[i].channel_name, channel_name)) {
+					char *reply;
+
+					DBG("the subbuf_size for the requested channel is %d", rchan->subbuf_size);
+					asprintf(&reply, "%d", rchan->subbuf_size);
+
+					result = ustcomm_send_reply(&ustcomm_app.server, reply, &src);
+					if(result) {
+						ERR("listener: get_subbuf_size: ustcomm_send_reply failed");
+						goto next_cmd;
+					}
+
+					free(reply);
+
+					break;
+				}
+			}
+		}
+		else if(nth_token_is(recvbuf, "load_probe_lib", 0) == 1) {
+			char *libfile;
+
+			libfile = nth_token(recvbuf, 1);
+
+			DBG("load_probe_lib loading %s", libfile);
+		}
+		else if(nth_token_is(recvbuf, "get_subbuffer", 0) == 1) {
+			struct ltt_trace_struct *trace;
+			char trace_name[] = "auto";
+			int i;
+			char *channel_name;
+
+			DBG("get_subbuf");
+
+			channel_name = nth_token(recvbuf, 1);
+			if(channel_name == NULL) {
+				ERR("get_subbuf: cannot parse channel");
+				goto next_cmd;
+			}
+
+			ltt_lock_traces();
+			trace = _ltt_trace_find(trace_name);
+			ltt_unlock_traces();
+
+			if(trace == NULL) {
+				CPRINTF("cannot find trace!");
+				return 1;
+			}
+
+			for(i=0; i<trace->nr_channels; i++) {
+				struct rchan *rchan = trace->channels[i].trans_channel_data;
+
+				if(!strcmp(trace->channels[i].channel_name, channel_name)) {
+					struct rchan_buf *rbuf = rchan->buf;
+					struct ltt_channel_buf_struct *lttbuf = trace->channels[i].buf;
+					char *reply;
+					long consumed_old=0;
+
+					result = ltt_do_get_subbuf(rbuf, lttbuf, &consumed_old);
+					if(result < 0) {
+						DBG("ltt_do_get_subbuf: error: %s", strerror(-result));
+						asprintf(&reply, "%s %ld", "UNAVAIL", 0);
+					}
+					else {
+						DBG("ltt_do_get_subbuf: success");
+						asprintf(&reply, "%s %ld", "OK", consumed_old);
+					}
+
+					result = ustcomm_send_reply(&ustcomm_app.server, reply, &src);
+					if(result) {
+						ERR("listener: get_subbuf: ustcomm_send_reply failed");
+						goto next_cmd;
+					}
+
+					free(reply);
+
+					break;
+				}
+			}
+		}
+		else if(nth_token_is(recvbuf, "put_subbuffer", 0) == 1) {
+			struct ltt_trace_struct *trace;
+			char trace_name[] = "auto";
+			int i;
+			char *channel_name;
+			long consumed_old;
+			char *consumed_old_str;
+			char *endptr;
+
+			DBG("put_subbuf");
+
+			channel_name = strdup_malloc(nth_token(recvbuf, 1));
+			if(channel_name == NULL) {
+				ERR("put_subbuf_size: cannot parse channel");
+				goto next_cmd;
+			}
+
+			consumed_old_str = strdup_malloc(nth_token(recvbuf, 2));
+			if(consumed_old_str == NULL) {
+				ERR("put_subbuf: cannot parse consumed_old");
+				goto next_cmd;
+			}
+			consumed_old = strtol(consumed_old_str, &endptr, 10);
+			if(*endptr != '\0') {
+				ERR("put_subbuf: invalid value for consumed_old");
+				goto next_cmd;
+			}
+
+			ltt_lock_traces();
+			trace = _ltt_trace_find(trace_name);
+			ltt_unlock_traces();
+
+			if(trace == NULL) {
+				CPRINTF("cannot find trace!");
+				return 1;
+			}
+
+			for(i=0; i<trace->nr_channels; i++) {
+				struct rchan *rchan = trace->channels[i].trans_channel_data;
+
+				if(!strcmp(trace->channels[i].channel_name, channel_name)) {
+					struct rchan_buf *rbuf = rchan->buf;
+					struct ltt_channel_buf_struct *lttbuf = trace->channels[i].buf;
+					char *reply;
+					long consumed_old=0;
+
+					result = ltt_do_put_subbuf(rbuf, lttbuf, consumed_old);
+					if(result < 0) {
+						WARN("ltt_do_put_subbuf: error");
+					}
+					else {
+						DBG("ltt_do_put_subbuf: success");
+					}
+					asprintf(&reply, "%s", "OK", consumed_old);
+
+					result = ustcomm_send_reply(&ustcomm_app.server, reply, &src);
+					if(result) {
+						ERR("listener: put_subbuf: ustcomm_send_reply failed");
+						goto next_cmd;
+					}
+
+					free(reply);
+
+					break;
+				}
+			}
+
+			free(channel_name);
+			free(consumed_old_str);
+		}
+		else if(nth_token_is(recvbuf, "get_notifications", 0) == 1) {
+			struct ltt_trace_struct *trace;
+			char trace_name[] = "auto";
+			int i;
+			char *channel_name;
+
+			DBG("get_notifications");
+
+			channel_name = strdup_malloc(nth_token(recvbuf, 1));
+			if(channel_name == NULL) {
+				ERR("put_subbuf_size: cannot parse channel");
+				goto next_cmd;
+			}
+
+			ltt_lock_traces();
+			trace = _ltt_trace_find(trace_name);
+			ltt_unlock_traces();
+
+			if(trace == NULL) {
+				CPRINTF("cannot find trace!");
+				return 1;
+			}
+
+			for(i=0; i<trace->nr_channels; i++) {
+				struct rchan *rchan = trace->channels[i].trans_channel_data;
+				int fd;
+
+				if(!strcmp(trace->channels[i].channel_name, channel_name)) {
+					struct rchan_buf *rbuf = rchan->buf;
+					struct ltt_channel_buf_struct *lttbuf = trace->channels[i].buf;
+
+					result = fd = ustcomm_app_detach_client(&ustcomm_app, &src);
+					if(result == -1) {
+						ERR("ustcomm_app_detach_client failed");
+						goto next_cmd;
+					}
+
+					lttbuf->wake_consumer_arg = (void *) fd;
+
+					smp_wmb();
+
+					lttbuf->call_wake_consumer = 1;
+
+					break;
+				}
+			}
+
+			free(channel_name);
+		}
+		else {
+			ERR("unable to parse message: %s", recvbuf);
+		}
+
+	next_cmd:
+		free(recvbuf);
 	}
-	//DBG("opening socket at %s", addr.sun_path);
+}
+
+static char listener_stack[16384];
 
-	result = bind(fd, (struct sockaddr *)&addr, sizeof(addr));
+void create_listener(void)
+{
+	int result;
+	static char listener_stack[16384];
+	//char *listener_stack = malloc(16384);
+
+#ifdef USE_CLONE
+	result = clone(listener_main, listener_stack+sizeof(listener_stack)-1, CLONE_FS | CLONE_FILES | CLONE_VM | CLONE_SIGHAND | CLONE_THREAD, NULL);
 	if(result == -1) {
-		PERROR("bind");
-		goto close_sock;
+		perror("clone");
 	}
+#else
+	pthread_t thread;
 
-	strcpy(mysocketfile, addr.sun_path);
+	pthread_create(&thread, NULL, listener_main, NULL);
+#endif
+}
 
-	close_sock:
-	close(fd);
+/* The signal handler itself. Signals must be setup so there cannot be
+   nested signals. */
 
-	return -1;
+void sighandler(int sig)
+{
+	static char have_listener = 0;
+	DBG("sighandler");
+
+	if(!have_listener) {
+		create_listener();
+		have_listener = 1;
+	}
 }
 
-void destroy_socket()
+/* Called by the app signal handler to chain it to us. */
+
+void chain_signal(void)
 {
-	int result;
+	sighandler(USTSIGNAL);
+}
 
-	if(mysocketfile[0] == '\0')
-		return;
+static int init_socket(void)
+{
+	return ustcomm_init_app(getpid(), &ustcomm_app);
+}
 
-	result = unlink(mysocketfile);
-	if(result == -1) {
-		PERROR("unlink");
-	}
+static void destroy_socket(void)
+{
+//	int result;
+//
+//	if(mysocketfile[0] == '\0')
+//		return;
+//
+//	result = unlink(mysocketfile);
+//	if(result == -1) {
+//		PERROR("unlink");
+//	}
 }
 
-int init_signal_handler(void)
+static int init_signal_handler(void)
 {
 	/* Attempt to handler SIGIO. If the main program wants to
 	 * handle it, fine, it'll override us. They it'll have to
@@ -130,15 +676,118 @@ int init_signal_handler(void)
 	return 0;
 }
 
-void __attribute__((constructor)) init()
+static void auto_probe_connect(struct marker *m)
 {
 	int result;
 
-	mypid = getpid();
+	result = ltt_marker_connect(m->channel, m->name, "default");
+	if(result)
+		ERR("ltt_marker_connect");
 
-	/* if using instead seperate thread, then should create thread */
-	result = init_signal_handler();
+	DBG("just auto connected marker %s %s to probe default", m->channel, m->name);
+}
+
+/* Wake the consumer of a buffer 
+ *
+ * wake_consumer_cb is called in tracing context so it must haste.
+ *
+ * FIXME: don't do a system call here; maybe schedule work to be done
+ * in listener context? Once this is done in listener context, we can
+ * check for the return value of send_message_fd and remove the fd if necessary
+ *
+ * @arg: the buffer
+ * @finished: 0: subbuffer full; 1: buffer being destroyed
+ */
+
+static void wake_consumer_cb(void *arg, int finished)
+{
+	struct ltt_channel_buf_struct *ltt_buf = (struct ltt_channel_buf_struct *) arg;
+	int fd = (int)ACCESS_ONCE(arg);
+
+	if(!finished) {
+		send_message_fd(fd, "consume", NULL);
+	}
+	else {
+		send_message_fd(fd, "destroyed", NULL);
+	}
+}
+
+static void __attribute__((constructor(101))) init0()
+{
+	DBG("UST_AUTOPROBE constructor");
+	if(getenv("UST_AUTOPROBE")) {
+		marker_set_new_marker_cb(auto_probe_connect);
+	}
+
+	relay_set_wake_consumer(wake_consumer_cb);
+}
+
+static void fini(void);
+
+static void __attribute__((constructor(1000))) init()
+{
+	int result;
+
+	DBG("UST_TRACE constructor");
+
+	/* Must create socket before signal handler to prevent races.
+         */
 	result = init_socket();
+	if(result == -1) {
+		ERR("init_socket error");
+		return;
+	}
+	result = init_signal_handler();
+	if(result == -1) {
+		ERR("init_signal_handler error");
+		return;
+	}
+
+	if(getenv("UST_TRACE")) {
+		char trace_name[] = "auto";
+		char trace_type[] = "ustrelay";
+
+		DBG("starting early tracing");
+
+		/* Ensure marker control is initialized */
+		init_marker_control();
+
+		/* Ensure relay is initialized */
+		init_ustrelay_transport();
+
+		/* Ensure markers are initialized */
+		init_markers();
+
+		/* In case. */
+		ltt_channels_register("ust");
+
+		result = ltt_trace_setup(trace_name);
+		if(result < 0) {
+			ERR("ltt_trace_setup failed");
+			return;
+		}
+
+		result = ltt_trace_set_type(trace_name, trace_type);
+		if(result < 0) {
+			ERR("ltt_trace_set_type failed");
+			return;
+		}
+
+		result = ltt_trace_alloc(trace_name);
+		if(result < 0) {
+			ERR("ltt_trace_alloc failed");
+			return;
+		}
+
+		result = ltt_trace_start(trace_name);
+		if(result < 0) {
+			ERR("ltt_trace_start failed");
+			return;
+		}
+		//start_consumer();
+		inform_consumer_daemon();
+	}
+
 
 	return;
 
@@ -149,7 +798,27 @@ void __attribute__((constructor)) init()
 /* This is only called if we terminate normally, not with an unhandled signal,
  * so we cannot rely on it. */
 
-void __attribute__((destructor)) fini()
+static void __attribute__((destructor)) fini()
 {
+	int result;
+
+	/* if trace running, finish it */
+
+	DBG("destructor stopping traces");
+
+	result = ltt_trace_stop("auto");
+	if(result == -1) {
+		ERR("ltt_trace_stop error");
+	}
+
+	result = ltt_trace_destroy("auto");
+	if(result == -1) {
+		ERR("ltt_trace_destroy error");
+	}
+
+	/* FIXME: wait for the consumer to be done */
+	DBG("waiting 5 sec for consume");
+	sleep(5);
+
 	destroy_socket();
 }