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.
25 #include <sys/types.h>
29 #include "../command.h"
32 #include <common/defaults.h>
33 #include <common/sessiond-comm/sessiond-comm.h>
34 #include <common/uri.h>
35 #include <common/utils.h>
37 static char *opt_output_path
;
38 static char *opt_session_name
;
40 static char *opt_ctrl_url
;
41 static char *opt_data_url
;
42 static int opt_no_consumer
;
43 static int opt_disable_consumer
;
50 static struct poptOption long_options
[] = {
51 /* longName, shortName, argInfo, argPtr, value, descrip, argDesc */
52 {"help", 'h', POPT_ARG_NONE
, NULL
, OPT_HELP
, NULL
, NULL
},
53 {"output", 'o', POPT_ARG_STRING
, &opt_output_path
, 0, NULL
, NULL
},
54 {"list-options", 0, POPT_ARG_NONE
, NULL
, OPT_LIST_OPTIONS
, NULL
, NULL
},
55 {"set-uri", 'U', POPT_ARG_STRING
, &opt_url
, 0, 0, 0},
56 {"ctrl-uri", 'C', POPT_ARG_STRING
, &opt_ctrl_url
, 0, 0, 0},
57 {"data-uri", 'D', POPT_ARG_STRING
, &opt_data_url
, 0, 0, 0},
58 {"no-consumer", 0, POPT_ARG_VAL
, &opt_no_consumer
, 1, 0, 0},
59 {"disable-consumer", 0, POPT_ARG_VAL
, &opt_disable_consumer
, 1, 0, 0},
66 static void usage(FILE *ofp
)
68 fprintf(ofp
, "usage: lttng create [NAME] [OPTIONS] \n");
70 fprintf(ofp
, "Without a given NAME, the default is 'auto-<yyyymmdd>-<hhmmss>'\n");
72 fprintf(ofp
, "Options:\n");
73 fprintf(ofp
, " -h, --help Show this help\n");
74 fprintf(ofp
, " --list-options Simple listing of options\n");
75 fprintf(ofp
, " -o, --output PATH Specify output path for traces\n");
77 fprintf(ofp
, "Extended Options:\n");
79 fprintf(ofp
, "Using these options, each API call can be controlled individually.\n");
81 fprintf(ofp
, " -U, --set-url=URL Set URL destination of the trace data.\n");
82 fprintf(ofp
, " It is persistent for the session lifetime.\n");
83 fprintf(ofp
, " This will set both data and control URL.\n");
84 fprintf(ofp
, " You can change it with the enable-consumer cmd\n");
85 fprintf(ofp
, " -C, --ctrl-url=URL Set control path URL. (Must use -D also)\n");
86 fprintf(ofp
, " -D, --data-url=URL Set data path URL. (Must use -C also)\n");
87 fprintf(ofp
, " --no-consumer Don't activate a consumer for this session.\n");
88 fprintf(ofp
, " --disable-consumer\n");
89 fprintf(ofp
, " Disable consumer for this session.\n");
91 fprintf(ofp
, "Please refer to the man page (lttng(1)) for more information on network\n");
92 fprintf(ofp
, "streaming mechanisms and explanation of the control and data port\n");
93 fprintf(ofp
, "You must have a running remote lttng-relayd for network streaming\n");
95 fprintf(ofp
, "URL format is has followed:\n");
97 fprintf(ofp
, " proto://[HOST|IP][:PORT1[:PORT2]][/TRACE_PATH]\n");
99 fprintf(ofp
, " Supported protocols are (proto):\n");
100 fprintf(ofp
, " > file://...\n");
101 fprintf(ofp
, " Local filesystem full path.\n");
103 fprintf(ofp
, " > net[4|6]://...\n");
104 fprintf(ofp
, " This will use the default network transport layer which is\n");
105 fprintf(ofp
, " TCP for both control (PORT1) and data port (PORT2).\n");
106 fprintf(ofp
, " The default ports are respectively 5342 and 5343.\n");
108 fprintf(ofp
, " > tcp[4|6]://...\n");
109 fprintf(ofp
, " Can only be used with -C and -D together\n");
111 fprintf(ofp
, "NOTE: IPv6 address MUST be enclosed in brackets '[]' (rfc2732)\n");
113 fprintf(ofp
, "Examples:\n");
114 fprintf(ofp
, " # lttng create -U net://192.168.1.42\n");
115 fprintf(ofp
, " Uses TCP and default ports for the given destination.\n");
116 fprintf(ofp
, " # lttng create -U net6://[fe80::f66d:4ff:fe53:d220]\n");
117 fprintf(ofp
, " Uses TCP, default ports and IPv6.\n");
118 fprintf(ofp
, " # lttng create s1 -U net://myhost.com:3229\n");
119 fprintf(ofp
, " Set the consumer to the remote HOST on port 3229 for control.\n");
124 * For a session name, set the consumer URLs.
126 static int set_consumer_url(const char *session_name
, const char *ctrl_url
,
127 const char *data_url
)
130 struct lttng_handle
*handle
;
131 struct lttng_domain dom
;
133 assert(session_name
);
136 * Set handle with the session name and the domain set to 0. This means to
137 * the session daemon that the next action applies on the tracing session
138 * rather then the domain specific session.
140 memset(&dom
, 0, sizeof(dom
));
142 handle
= lttng_create_handle(session_name
, &dom
);
143 if (handle
== NULL
) {
148 ret
= lttng_set_consumer_url(handle
, ctrl_url
, data_url
);
154 MSG("Control URL %s set for session %s", ctrl_url
, session_name
);
158 MSG("Data URL %s set for session %s", data_url
, session_name
);
162 lttng_destroy_handle(handle
);
167 * For a session name, enable the consumer.
169 static int enable_consumer(const char *session_name
)
172 struct lttng_handle
*handle
;
173 struct lttng_domain dom
;
175 assert(session_name
);
178 * Set handle with the session name and the domain set to 0. This means to
179 * the session daemon that the next action applies on the tracing session
180 * rather then the domain specific session.
182 * XXX: This '0' value should be a domain enum value.
184 memset(&dom
, 0, sizeof(dom
));
186 handle
= lttng_create_handle(session_name
, 0);
187 if (handle
== NULL
) {
192 ret
= lttng_enable_consumer(handle
);
197 MSG("Consumer enabled for session %s", session_name
);
200 lttng_destroy_handle(handle
);
205 * For a session name, disable the consumer.
207 static int disable_consumer(const char *session_name
)
210 struct lttng_handle
*handle
;
212 assert(session_name
);
215 * Set handle with the session name and the domain set to 0. This means to
216 * the session daemon that the next action applies on the tracing session
217 * rather then the domain specific session.
219 * XXX: This '0' value should be a domain enum value.
221 handle
= lttng_create_handle(session_name
, 0);
222 if (handle
== NULL
) {
227 ret
= lttng_disable_consumer(handle
);
233 MSG("Consumer disabled for session %s", session_name
);
240 * Create a tracing session.
241 * If no name is specified, a default name is generated.
243 * Returns one of the CMD_* result constants.
245 static int create_session(void)
248 char *session_name
, *traces_path
= NULL
, *alloc_path
= NULL
;
249 char *alloc_url
= NULL
, *url
= NULL
, datetime
[16];
253 /* Get date and time for automatic session name/path */
255 timeinfo
= localtime(&rawtime
);
256 strftime(datetime
, sizeof(datetime
), "%Y%m%d-%H%M%S", timeinfo
);
258 /* Auto session name creation */
259 if (opt_session_name
== NULL
) {
260 ret
= asprintf(&session_name
, DEFAULT_SESSION_NAME
"%s", datetime
);
262 PERROR("asprintf session name");
265 DBG("Auto session name set to %s", session_name
);
267 session_name
= opt_session_name
;
270 if (opt_no_consumer
) {
272 } else if (opt_output_path
!= NULL
) {
273 traces_path
= utils_expand_path(opt_output_path
);
274 if (traces_path
== NULL
) {
279 /* Create URL string from the local filesytem path */
280 ret
= asprintf(&alloc_url
, "file://%s", traces_path
);
282 PERROR("asprintf url path");
286 /* URL to use in the lttng_create_session() call */
288 MSG("Trace(s) output set to %s", traces_path
);
289 } else if (opt_url
) { /* Handling URL (-U opt) */
291 MSG("Trace(s) output set to %s", url
);
292 } else if (opt_ctrl_url
== NULL
&& opt_data_url
== NULL
) {
293 /* Auto output path */
294 alloc_path
= config_get_default_path();
295 if (alloc_path
== NULL
) {
296 ERR("HOME path not found.\n \
297 Please specify an output path using -o, --output PATH");
301 alloc_path
= strdup(alloc_path
);
303 ret
= asprintf(&alloc_url
, "file://%s/" DEFAULT_TRACE_DIR_NAME
,
306 PERROR("asprintf trace dir name");
312 MSG("Trace(s) output set to %s", alloc_url
+ strlen("file://"));
315 ret
= lttng_create_session(session_name
, url
);
317 /* Don't set ret so lttng can interpret the sessiond error. */
319 case LTTCOMM_EXIST_SESS
:
320 WARN("Session %s already exists", session_name
);
326 if (opt_session_name
== NULL
) {
327 MSG("Session created with default name %s", session_name
);
329 MSG("Session %s created.", session_name
);
332 if (opt_ctrl_url
|| opt_data_url
) {
333 /* Setting up control URI (-C or/and -D opt) */
334 ret
= set_consumer_url(session_name
, opt_ctrl_url
, opt_data_url
);
339 ret
= enable_consumer(session_name
);
345 if (opt_disable_consumer
&& !opt_no_consumer
) {
346 ret
= disable_consumer(session_name
);
352 /* Init lttng session config */
353 ret
= config_init(session_name
);
362 if (opt_session_name
== NULL
) {
375 ERR("%s", lttng_strerror(ret
));
381 * The 'create <options>' first level command
383 * Returns one of the CMD_* result constants.
385 int cmd_create(int argc
, const char **argv
)
387 int opt
, ret
= CMD_SUCCESS
;
388 static poptContext pc
;
390 pc
= poptGetContext(NULL
, argc
, argv
, long_options
, 0);
391 poptReadDefaultConfig(pc
, 0);
393 while ((opt
= poptGetNextOpt(pc
)) != -1) {
398 case OPT_LIST_OPTIONS
:
399 list_cmd_options(stdout
, long_options
);
408 opt_session_name
= (char*) poptGetArg(pc
);
410 ret
= create_session();
This page took 0.040188 seconds and 5 git commands to generate.