2 * Copyright (C) 2011 - David Goulet <david.goulet@polymtl.ca>
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.
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.
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.
26 #include <sys/types.h>
32 #include <common/mi-lttng.h>
34 #include "../command.h"
37 #include <common/defaults.h>
38 #include <common/sessiond-comm/sessiond-comm.h>
39 #include <common/uri.h>
40 #include <common/utils.h>
41 #include <lttng/snapshot.h>
43 static char *opt_output_path
;
44 static char *opt_session_name
;
46 static char *opt_ctrl_url
;
47 static char *opt_data_url
;
48 static char *opt_shm_path
;
49 static int opt_no_consumer
;
50 static int opt_no_output
;
51 static int opt_snapshot
;
52 static unsigned int opt_live_timer
;
74 static struct mi_writer
*writer
;
76 static struct poptOption long_options
[] = {
77 /* longName, shortName, argInfo, argPtr, value, descrip, argDesc */
78 {"help", 'h', POPT_ARG_NONE
, NULL
, OPT_HELP
, NULL
, NULL
},
79 {"output", 'o', POPT_ARG_STRING
, &opt_output_path
, 0, NULL
, NULL
},
80 {"list-options", 0, POPT_ARG_NONE
, NULL
, OPT_LIST_OPTIONS
, NULL
, NULL
},
81 {"set-url", 'U', POPT_ARG_STRING
, &opt_url
, 0, 0, 0},
82 {"ctrl-url", 'C', POPT_ARG_STRING
, &opt_ctrl_url
, 0, 0, 0},
83 {"data-url", 'D', POPT_ARG_STRING
, &opt_data_url
, 0, 0, 0},
84 {"no-output", 0, POPT_ARG_VAL
, &opt_no_output
, 1, 0, 0},
85 {"no-consumer", 0, POPT_ARG_VAL
, &opt_no_consumer
, 1, 0, 0},
86 {"snapshot", 0, POPT_ARG_VAL
, &opt_snapshot
, 1, 0, 0},
87 {"live", 0, POPT_ARG_INT
| POPT_ARGFLAG_OPTIONAL
, 0, OPT_LIVE_TIMER
, 0, 0},
88 {"shm-path", 0, POPT_ARG_STRING
, &opt_shm_path
, 0, 0, 0},
93 * Please have a look at src/lib/lttng-ctl/lttng-ctl.c for more information on
94 * why this declaration exists and used ONLY in for this command.
96 extern int _lttng_create_session_ext(const char *name
, const char *url
,
97 const char *datetime
);
100 * Retrieve the created session and mi output it based on provided argument
101 * This is currently a summary of what was pretty printed and is subject to
104 static int mi_created_session(const char *session_name
)
106 int ret
, i
, count
, found
;
107 struct lttng_session
*sessions
;
109 /* session_name should not be null */
110 assert(session_name
);
113 count
= lttng_list_sessions(&sessions
);
116 ERR("%s", lttng_strerror(ret
));
121 ERR("Error session creation failed: session %s not found", session_name
);
122 ret
= -LTTNG_ERR_SESS_NOT_FOUND
;
127 for (i
= 0; i
< count
; i
++) {
128 if (strncmp(sessions
[i
].name
, session_name
, NAME_MAX
) == 0) {
130 ret
= mi_lttng_session(writer
, &sessions
[i
], 0);
139 ret
= -LTTNG_ERR_SESS_NOT_FOUND
;
151 * For a session name, set the consumer URLs.
153 static int set_consumer_url(const char *session_name
, const char *ctrl_url
,
154 const char *data_url
)
157 struct lttng_handle
*handle
;
159 assert(session_name
);
162 * Set handle with the session_name, but no domain. This implies that
163 * the actions taken with this handle apply on the tracing session
164 * rather then the domain-specific session.
166 handle
= lttng_create_handle(session_name
, NULL
);
167 if (handle
== NULL
) {
172 ret
= lttng_set_consumer_url(handle
, ctrl_url
, data_url
);
178 lttng_destroy_handle(handle
);
182 static int add_snapshot_output(const char *session_name
, const char *ctrl_url
,
183 const char *data_url
)
186 struct lttng_snapshot_output
*output
= NULL
;
188 assert(session_name
);
190 output
= lttng_snapshot_output_create();
197 ret
= lttng_snapshot_output_set_ctrl_url(ctrl_url
, output
);
204 ret
= lttng_snapshot_output_set_data_url(data_url
, output
);
210 /* This call, if successful, populates the id of the output object. */
211 ret
= lttng_snapshot_add_output(session_name
, output
);
217 lttng_snapshot_output_destroy(output
);
223 * Validate the combinations of passed options
226 * CMD_SUCCESS on success
228 static int validate_command_options(void)
230 int ret
= CMD_SUCCESS
;
231 if (opt_snapshot
&& opt_live_timer
) {
232 ERR("Snapshot and live modes are mutually exclusive.");
237 if ((!opt_ctrl_url
&& opt_data_url
) || (opt_ctrl_url
&& !opt_data_url
)) {
238 ERR("You need both control and data URL.");
248 * Create a session via direct calls to liblttng-ctl.
250 * Return CMD_SUCCESS on success, negative value on internal lttng errors and positive
251 * value on command errors.
253 static int create_session_basic (const char *session_name
,
258 const char* ctrl_url
,
259 const char* data_url
,
260 const char* shm_path
,
261 const char* datetime
)
263 /* Create session based on session creation */
264 int ret
= CMD_SUCCESS
;
265 const char *pathname
;
269 if (opt_relayd_path
) {
270 pathname
= opt_relayd_path
;
272 pathname
= INSTALL_BIN_PATH
"/lttng-relayd";
275 switch (session_type
) {
277 ret
= _lttng_create_session_ext(session_name
, url
, datetime
);
279 case SESSION_SNAPSHOT
:
280 if (output_type
== OUTPUT_NONE
) {
281 ERR("--no-output on a snapshot session is invalid");
282 ret
= CMD_UNSUPPORTED
;
285 ret
= lttng_create_session_snapshot(session_name
, url
);
288 if (output_type
== OUTPUT_NONE
) {
289 ERR("--no-output on a live session is invalid");
290 ret
= CMD_UNSUPPORTED
;
294 if (output_type
== OUTPUT_LOCAL
) {
295 ERR("Local file output on a live session is invalid");
296 ret
= CMD_UNSUPPORTED
;
299 if (output_type
!= OUTPUT_NET
&& !check_relayd() &&
300 spawn_relayd(pathname
, 0) < 0) {
304 ret
= lttng_create_session_live(session_name
, url
, live_timer
);
307 ERR("Unknown session type");
313 /* Don't set ret so the sessiond error is propagated. */
315 case LTTNG_ERR_EXIST_SESS
:
316 WARN("Session %s already exists", session_name
);
324 /* Configure the session based on the output type */
325 switch (output_type
) {
329 if (session_type
== SESSION_SNAPSHOT
) {
330 ret
= add_snapshot_output(session_name
, ctrl_url
,
332 } else if (ctrl_url
&& data_url
) {
334 * Normal sessions and live sessions behave the same way
335 * regarding consumer url.
337 ret
= set_consumer_url(session_name
, ctrl_url
, data_url
);
340 /* Destroy created session on errors */
341 lttng_destroy_session(session_name
);
348 ERR("Unknown output type");
354 * Set the session shared memory path
357 ret
= lttng_set_session_shm_path(session_name
, shm_path
);
359 lttng_destroy_session(session_name
);
367 static int generate_output(const char *session_name
,
372 const char* ctrl_url
,
373 const char* data_url
,
374 const char* shm_path
)
376 int ret
= CMD_SUCCESS
;
379 * TODO move this to after session name
380 * for now we only emulate previous behaviour.
382 if (session_type
!= SESSION_SNAPSHOT
) {
384 MSG("Control URL %s set for session %s", ctrl_url
, session_name
);
388 MSG("Data URL %s set for session %s", data_url
, session_name
);
392 if (url
&& output_type
== OUTPUT_LOCAL
) {
393 /* Remove the file:// */
394 if (strlen(url
) > strlen("file://")){
395 url
= url
+ strlen("file://");
399 MSG("Session %s created.", session_name
);
400 if (url
&& session_type
!= SESSION_SNAPSHOT
) {
401 MSG("Traces will be written in %s", url
);
404 MSG("Live timer set to %u usec", live_timer
);
406 } else if (session_type
== SESSION_SNAPSHOT
) {
408 MSG("Default snapshot output set to: %s", url
);
410 MSG("Snapshot mode set. Every channel enabled for that session will "
411 "be set to mmap output, and default to overwrite mode.");
415 MSG("Session %s set to shm_path: %s.", session_name
,
421 ret
= mi_created_session(session_name
);
432 * Create a tracing session.
433 * If no name is specified, a default name is generated.
435 * Returns one of the CMD_* result constants.
437 static int create_session(void)
442 int base_session_type
= SESSION_UNKNOWN
;
443 int base_output_type
= OUTPUT_UNKNOWN
;
444 char *base_session_name
= NULL
;
445 char *base_url
= NULL
;
446 char *base_ctrl_url
= NULL
;
447 char *base_data_url
= NULL
;
448 char *base_shm_path
= NULL
;
449 int base_live_timer
= 0;
454 struct tm
*timeinfo
= NULL
;
456 /* Temporary variables */
457 char *traces_path
= NULL
;
458 char *temp_url
= NULL
;
459 char *session_name_date
= NULL
;
460 char *tmp_url
= NULL
;
461 char *tmp_home_path
= NULL
;
462 struct lttng_uri
*uris
= NULL
;
463 ssize_t uri_array_size
= 0;
465 /* Option validation */
466 if (validate_command_options() != CMD_SUCCESS
) {
471 /* Get date and time for automatic session name/path */
473 timeinfo
= localtime(&rawtime
);
474 strftime(datetime
, sizeof(datetime
), "%Y%m%d-%H%M%S", timeinfo
);
476 /* Find the session type based on options */
477 if(base_session_type
== SESSION_UNKNOWN
) {
479 base_session_type
= SESSION_SNAPSHOT
;
480 } else if (opt_live_timer
) {
481 base_session_type
= SESSION_LIVE
;
483 base_session_type
= SESSION_NORMAL
;
488 * Session name handling
490 if (opt_session_name
) {
491 /* Override the session name */
492 if (strlen(opt_session_name
) > NAME_MAX
) {
493 ERR("Session name too long. Length must be lower or equal to %d",
495 ret
= LTTNG_ERR_SESSION_FAIL
;
496 free(session_name_date
);
500 * Check if the session name begins with "auto-" or is exactly "auto".
501 * Both are reserved for the default session name. See bug #449 to
502 * understand why we need to check both here.
504 if ((strncmp(opt_session_name
, DEFAULT_SESSION_NAME
"-",
505 strlen(DEFAULT_SESSION_NAME
) + 1) == 0) ||
506 (strncmp(opt_session_name
, DEFAULT_SESSION_NAME
,
507 strlen(DEFAULT_SESSION_NAME
)) == 0 &&
508 strlen(opt_session_name
) == strlen(DEFAULT_SESSION_NAME
))) {
509 ERR("%s is a reserved keyword for default session(s)",
510 DEFAULT_SESSION_NAME
);
516 base_session_name
= strndup(opt_session_name
, NAME_MAX
);
517 if (!base_session_name
) {
518 PERROR("Strdup session name");
523 ret
= asprintf(&session_name_date
, "%s-%s", base_session_name
, datetime
);
525 PERROR("Asprintf session name");
528 DBG("Session name from command option set to %s", base_session_name
);
529 } else if (base_session_name
) {
530 ret
= asprintf(&session_name_date
, "%s-%s", base_session_name
, datetime
);
532 PERROR("Asprintf session name");
536 /* Generate a name */
537 /* TODO: use asprint */
538 ret
= asprintf(&base_session_name
, DEFAULT_SESSION_NAME
"-%s", datetime
);
540 PERROR("Asprintf generated session name");
543 session_name_date
= strdup(base_session_name
);
544 DBG("Auto session name set to %s", base_session_name
);
553 * If any of those options are present clear all output related data.
555 if (opt_output_path
|| opt_url
|| (opt_ctrl_url
&& opt_data_url
) || opt_no_output
) {
556 /* Overwrite output */
561 base_ctrl_url
= NULL
;
562 base_data_url
= NULL
;
565 if (opt_output_path
) {
567 traces_path
= utils_expand_path(opt_output_path
);
573 /* Create URL string from the local file system path */
574 ret
= asprintf(&temp_url
, "file://%s", traces_path
);
576 PERROR("asprintf url path");
582 } else if (opt_url
) { /* Handling URL (-U opt) */
583 base_url
= strdup(opt_url
);
584 } else if (opt_data_url
&& opt_ctrl_url
) {
586 * With both control and data, we'll be setting the consumer URL
587 * after session creation thus use no URL.
589 base_ctrl_url
= strdup(opt_ctrl_url
);
590 base_data_url
= strdup(opt_data_url
);
591 } else if (!(opt_no_output
|| base_output_type
== OUTPUT_NONE
||
592 base_url
|| base_ctrl_url
|| base_data_url
)) {
593 /* Generate default output depending on the session type */
594 switch (base_session_type
) {
597 case SESSION_SNAPSHOT
:
598 /* Default to a local path */
599 tmp_home_path
= utils_get_home_dir();
600 if (tmp_home_path
== NULL
) {
601 ERR("HOME path not found.\n \
602 Please specify an output path using -o, --output PATH");
607 ret
= asprintf(&tmp_url
,
608 "file://%s/" DEFAULT_TRACE_DIR_NAME
"/%s",
609 tmp_home_path
, session_name_date
);
612 PERROR("asprintf trace dir name");
620 /* Default to a net output */
621 ret
= asprintf(&tmp_url
, "net://127.0.0.1");
623 PERROR("asprintf default live URL");
630 ERR("Unknown session type");
637 * Shared memory path handling
640 ret
= asprintf(&base_shm_path
, "%s/%s", opt_shm_path
, session_name_date
);
642 PERROR("asprintf shm_path");
648 * Live timer handling
650 if (opt_live_timer
) {
651 base_live_timer
= opt_live_timer
;
654 /* Get output type from urls */
656 /* Get lttng uris from single url */
657 uri_array_size
= uri_parse_str_urls(base_url
, NULL
, &uris
);
658 if (uri_array_size
< 0) {
662 } else if (base_ctrl_url
&& base_data_url
) {
663 uri_array_size
= uri_parse_str_urls(base_ctrl_url
, base_data_url
, &uris
);
664 if (uri_array_size
< 0) {
673 switch (uri_array_size
) {
675 base_output_type
= OUTPUT_NONE
;
678 base_output_type
= OUTPUT_LOCAL
;
681 base_output_type
= OUTPUT_NET
;
688 ret
= create_session_basic (base_session_name
,
701 ret
= generate_output (base_session_name
,
713 /* Init lttng session config */
714 ret
= config_init(base_session_name
);
724 /* Session temp stuff */
725 free(session_name_date
);
730 ERR("%s", lttng_strerror(ret
));
732 free(base_session_name
);
743 * Spawn a session daemon by forking and execv.
745 static int spawn_sessiond(char *pathname
)
750 MSG("Spawning a session daemon");
754 * Spawn session daemon in daemon mode.
756 execlp(pathname
, "lttng-sessiond",
757 "--daemonize", NULL
);
758 /* execlp only returns if error happened */
759 if (errno
== ENOENT
) {
760 ERR("No session daemon found. Use --sessiond-path.");
764 kill(getppid(), SIGTERM
); /* wake parent */
766 } else if (pid
> 0) {
768 * In daemon mode (--daemonize), sessiond only exits when
769 * it's ready to accept commands.
773 pid_t wait_pid_ret
= waitpid(pid
, &status
, 0);
775 if (wait_pid_ret
< 0) {
776 if (errno
== EINTR
) {
784 if (WIFSIGNALED(status
)) {
785 ERR("Session daemon was killed by signal %d",
789 } else if (WIFEXITED(status
)) {
790 DBG("Session daemon terminated normally (exit status: %d)",
791 WEXITSTATUS(status
));
793 if (WEXITSTATUS(status
) != 0) {
794 ERR("Session daemon terminated with an error (exit status: %d)",
795 WEXITSTATUS(status
));
817 * Check if the session daemon is available using
818 * the liblttngctl API for the check. If not, try to
821 static int launch_sessiond(void)
824 char *pathname
= NULL
;
826 ret
= lttng_session_daemon_alive();
828 /* Sessiond is alive, not an error */
833 /* Try command line option path */
834 pathname
= opt_sessiond_path
;
836 /* Try LTTNG_SESSIOND_PATH env variable */
837 if (pathname
== NULL
) {
838 pathname
= getenv(DEFAULT_SESSIOND_PATH_ENV
);
841 /* Try with configured path */
842 if (pathname
== NULL
) {
843 if (CONFIG_SESSIOND_BIN
[0] != '\0') {
844 pathname
= CONFIG_SESSIOND_BIN
;
848 /* Try the default path */
849 if (pathname
== NULL
) {
850 pathname
= INSTALL_BIN_PATH
"/lttng-sessiond";
853 DBG("Session daemon binary path: %s", pathname
);
855 /* Check existence and permissions */
856 ret
= access(pathname
, F_OK
| X_OK
);
858 ERR("No such file or access denied: %s", pathname
);
862 ret
= spawn_sessiond(pathname
);
865 ERR("Problem occurred while launching session daemon (%s)",
872 * The 'create <options>' first level command
874 * Returns one of the CMD_* result constants.
876 int cmd_create(int argc
, const char **argv
)
878 int opt
, ret
= CMD_SUCCESS
, command_ret
= CMD_SUCCESS
, success
= 1;
879 char *opt_arg
= NULL
;
880 static poptContext pc
;
882 pc
= poptGetContext(NULL
, argc
, argv
, long_options
, 0);
883 poptReadDefaultConfig(pc
, 0);
885 while ((opt
= poptGetNextOpt(pc
)) != -1) {
890 case OPT_LIST_OPTIONS
:
891 list_cmd_options(stdout
, long_options
);
898 opt_arg
= poptGetOptArg(pc
);
900 /* Set up default values. */
901 opt_live_timer
= (uint32_t) DEFAULT_LTTNG_LIVE_TIMER
;
902 DBG("Session live timer interval set to default value %d",
907 v
= strtoul(opt_arg
, NULL
, 0);
908 if (errno
!= 0 || !isdigit(opt_arg
[0])) {
909 ERR("Wrong value in --live parameter: %s", opt_arg
);
913 if (v
!= (uint32_t) v
) {
914 ERR("32-bit overflow in --live parameter: %s", opt_arg
);
919 ERR("Live timer interval must be greater than zero");
923 opt_live_timer
= (uint32_t) v
;
924 DBG("Session live timer interval set to %d", opt_live_timer
);
933 if (opt_no_consumer
) {
934 MSG("The option --no-consumer is obsolete. Use --no-output now.");
939 /* Spawn a session daemon if needed */
940 if (!opt_no_sessiond
) {
941 ret
= launch_sessiond();
948 /* MI initialization */
950 writer
= mi_lttng_writer_create(fileno(stdout
), lttng_opt_mi
);
952 ret
= -LTTNG_ERR_NOMEM
;
956 /* Open command element */
957 ret
= mi_lttng_writer_command_open(writer
,
958 mi_lttng_element_command_create
);
964 /* Open output element */
965 ret
= mi_lttng_writer_open_element(writer
,
966 mi_lttng_element_command_output
);
972 opt_session_name
= (char*) poptGetArg(pc
);
974 command_ret
= create_session();
981 /* Close output element */
982 ret
= mi_lttng_writer_close_element(writer
);
989 ret
= mi_lttng_writer_write_element_bool(writer
,
990 mi_lttng_element_command_success
, success
);
996 /* Command element close */
997 ret
= mi_lttng_writer_command_close(writer
);
1006 if (writer
&& mi_lttng_writer_destroy(writer
)) {
1007 /* Preserve original error code */
1008 ret
= ret
? ret
: -LTTNG_ERR_MI_IO_FAIL
;
1011 /* Overwrite ret if an error occurred in create_session() */
1012 ret
= command_ret
? command_ret
: ret
;
1014 poptFreeContext(pc
);