Mi: mi backend + mi for command version
[lttng-tools.git] / src / bin / lttng / commands / view.c
index c4724415c31bca500e8054a8dc9411f9d140c7e5..dcd4d66245fb5049fa241c00feb771fdf52d93ba 100644 (file)
@@ -1,18 +1,18 @@
 /*
  * Copyright (C) 2011 - David Goulet <dgoulet@efficios.com>
  *
- * This program is free software; you can redistribute it and/or modify it
- * under the terms of the GNU General Public License as published by the Free
- * Software Foundation; only version 2 of the License.
+ * 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.
+ * 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., 59 Temple
- * Place - Suite 330, Boston, MA  02111-1307, USA.
+ * 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
@@ -76,6 +76,9 @@ static struct viewers {
        { NULL, VIEWER_USER_DEFINED },
 };
 
+/* Is the session we are trying to view is in live mode. */
+static int session_live_mode;
+
 /*
  * usage
  */
@@ -88,6 +91,7 @@ static void usage(FILE *ofp)
        fprintf(ofp, "Where SESSION_NAME is an optional session name. If not specified, lttng will\n");
        fprintf(ofp, "get it from the configuration file (.lttngrc).\n");
        fprintf(ofp, "\n");
+       fprintf(ofp, "Options:\n");
        fprintf(ofp, "  -h, --help               Show this help\n");
        fprintf(ofp, "      --list-options       Simple listing of options\n");
        fprintf(ofp, "  -t, --trace-path PATH    Trace directory path for the viewer\n");
@@ -178,20 +182,38 @@ static char **alloc_argv_from_local_opts(const char **opts, size_t opts_len,
                const char *trace_path)
 {
        char **argv;
-       size_t size;
+       size_t size, mem_len;
+
+
+       /* Add one for the NULL terminating element. */
+       mem_len = opts_len + 1;
+       if (session_live_mode) {
+               /* Add 3 option for the live mode being "-i lttng-live URL". */
+               mem_len += 3;
+       } else {
+               /* Add option for the trace path. */
+               mem_len += 1;
+       }
 
-       size = sizeof(char *) * opts_len;
+       size = sizeof(char *) * mem_len;
 
        /* Add two here for the trace_path and the NULL terminating element. */
-       argv = malloc(size + 2);
+       argv = malloc(size);
        if (argv == NULL) {
                goto error;
        }
 
        memcpy(argv, opts, size);
 
-       argv[opts_len] = (char *)trace_path;
-       argv[opts_len + 1] = NULL;
+       if (session_live_mode) {
+               argv[opts_len] = "-i";
+               argv[opts_len + 1] = "lttng-live";
+               argv[opts_len + 2] = (char *) trace_path;
+               argv[opts_len + 3] = NULL;
+       } else {
+               argv[opts_len] = (char *) trace_path;
+               argv[opts_len + 1] = NULL;
+       }
 
 error:
        return argv;
@@ -258,7 +280,11 @@ static int spawn_viewer(const char *trace_path)
 
        ret = execvp(viewer_bin, argv);
        if (ret) {
-               PERROR("exec: %s", viewer_bin);
+               if (errno == ENOENT) {
+                       ERR("%s not found on the system", viewer_bin);
+               } else {
+                       PERROR("exec: %s", viewer_bin);
+               }
                free(argv);
                ret = CMD_FATAL;
                goto error;
@@ -268,13 +294,39 @@ error:
        return ret;
 }
 
+/*
+ * Build the live path we need for the lttng live view.
+ */
+static char *build_live_path(char *session_name)
+{
+       int ret;
+       char *path = NULL;
+       char hostname[HOST_NAME_MAX];
+
+       ret = gethostname(hostname, sizeof(hostname));
+       if (ret < 0) {
+               perror("gethostname");
+               goto error;
+       }
+
+       ret = asprintf(&path, "net://localhost/host/%s/%s", hostname,
+                       session_name);
+       if (ret < 0) {
+               perror("asprintf live path");
+               goto error;
+       }
+
+error:
+       return path;
+}
+
 /*
  * Exec viewer if found and use session name path.
  */
 static int view_trace(void)
 {
-       int ret, count, i, found = 0;
-       char *session_name, *trace_path;
+       int ret;
+       char *session_name, *trace_path = NULL;
        struct lttng_session *sessions = NULL;
 
        /*
@@ -309,6 +361,8 @@ static int view_trace(void)
        DBG("Viewing trace for session %s", session_name);
 
        if (session_name) {
+               int i, count, found = 0;
+
                /* Getting all sessions */
                count = lttng_list_sessions(&sessions);
                if (count < 0) {
@@ -333,7 +387,28 @@ static int view_trace(void)
                        goto free_sessions;
                }
 
-               trace_path = sessions[i].path;
+               session_live_mode = sessions[i].live_timer_interval;
+
+               DBG("Session live mode set to %d", session_live_mode);
+
+               if (sessions[i].enabled && !session_live_mode) {
+                       WARN("Session %s is running. Please stop it before reading it.",
+                                       session_name);
+                       ret = CMD_ERROR;
+                       goto free_sessions;
+               }
+
+               /* If the timer interval is set we are in live mode. */
+               if (session_live_mode) {
+                       trace_path = build_live_path(session_name);
+                       if (!trace_path) {
+                               ret = CMD_ERROR;
+                               goto free_sessions;
+                       }
+               } else {
+                       /* Get file system session path. */
+                       trace_path = sessions[i].path;
+               }
        } else {
                trace_path = opt_trace_path;
        }
@@ -346,12 +421,11 @@ static int view_trace(void)
                goto free_sessions;
        }
 
-       ret = CMD_SUCCESS;
-
 free_sessions:
-       if (sessions) {
-               free(sessions);
+       if (session_live_mode) {
+               free(trace_path);
        }
+       free(sessions);
 free_error:
        if (opt_session_name == NULL) {
                free(session_name);
@@ -371,6 +445,10 @@ int cmd_view(int argc, const char **argv)
        pc = poptGetContext(NULL, argc, argv, long_options, 0);
        poptReadDefaultConfig(pc, 0);
 
+       if (lttng_opt_mi) {
+               WARN("mi does not apply to view command");
+       }
+
        while ((opt = poptGetNextOpt(pc)) != -1) {
                switch (opt) {
                case OPT_HELP:
This page took 0.025772 seconds and 4 git commands to generate.