X-Git-Url: https://git.lttng.org/?a=blobdiff_plain;f=src%2Fbin%2Flttng%2Futils.c;h=885f498b73c72340dedc99ae67a3ca5d226ed8ab;hb=f3b3a67b8a5a7b2e4f7637d261a9e356d233ae23;hp=d52d4622a9c3f3b1dfa34decf94d20bceaa8ecfa;hpb=1dac0189ed7311146ff2cfc6605bac81213ee90b;p=lttng-tools.git

diff --git a/src/bin/lttng/utils.c b/src/bin/lttng/utils.c
index d52d4622a..885f498b7 100644
--- a/src/bin/lttng/utils.c
+++ b/src/bin/lttng/utils.c
@@ -15,7 +15,6 @@
  * 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA.
  */
 
-#define _GNU_SOURCE
 #define _LGPL_SOURCE
 #include <assert.h>
 #include <stdlib.h>
@@ -26,9 +25,12 @@
 #include <signal.h>
 #include <netinet/in.h>
 #include <arpa/inet.h>
+#include <inttypes.h>
+#include <unistd.h>
 
 #include <common/error.h>
 #include <common/utils.h>
+#include <common/defaults.h>
 
 #include "conf.h"
 #include "utils.h"
@@ -401,3 +403,117 @@ error:
 error_socket:
 	return ret;
 }
+
+int print_missing_or_multiple_domains(unsigned int sum)
+{
+	int ret = 0;
+
+	if (sum == 0) {
+		ERR("Please specify a domain (-k/-u/-j).");
+		ret = -1;
+	} else if (sum > 1) {
+		ERR("Multiple domains specified.");
+		ret = -1;
+	}
+
+	return ret;
+}
+
+/*
+ * Get the discarded events and lost packet counts.
+ */
+void print_session_stats(const char *session_name)
+{
+	int count, nb_domains, domain_idx, channel_idx, session_idx;
+	struct lttng_domain *domains;
+	struct lttng_channel *channels;
+	uint64_t discarded_events_total = 0, lost_packets_total = 0;
+	struct lttng_session *sessions = NULL;
+	const struct lttng_session *selected_session = NULL;
+
+	count = lttng_list_sessions(&sessions);
+	if (count < 1) {
+		ERR("Failed to retrieve session descriptions while printing session statistics.");
+		goto end;
+	}
+
+	/* Identify the currently-selected sessions. */
+	for (session_idx = 0; session_idx < count; session_idx++) {
+		if (!strcmp(session_name, sessions[session_idx].name)) {
+			selected_session = &sessions[session_idx];
+			break;
+		}
+	}
+	if (!selected_session) {
+		ERR("Failed to retrieve session \"%s\" description while printing session statistics.", session_name);
+		goto end;
+	}
+
+	nb_domains = lttng_list_domains(session_name, &domains);
+	if (nb_domains < 0) {
+		goto end;
+	}
+	for (domain_idx = 0; domain_idx < nb_domains; domain_idx++) {
+		struct lttng_handle *handle = lttng_create_handle(session_name,
+				&domains[domain_idx]);
+
+		if (!handle) {
+			ERR("Failed to create session handle while printing session statistics.");
+			goto end;
+		}
+
+		count = lttng_list_channels(handle, &channels);
+		for (channel_idx = 0; channel_idx < count; channel_idx++) {
+			int ret;
+			uint64_t discarded_events = 0, lost_packets = 0;
+			struct lttng_channel *channel = &channels[channel_idx];
+
+			ret = lttng_channel_get_discarded_event_count(channel,
+					&discarded_events);
+			if (ret) {
+				ERR("Failed to retrieve discarded event count from channel %s",
+						channel->name);
+			}
+
+			ret = lttng_channel_get_lost_packet_count(channel,
+					&lost_packets);
+			if (ret) {
+				ERR("Failed to retrieve lost packet count from channel %s",
+						channel->name);
+			}
+
+			discarded_events_total += discarded_events;
+			lost_packets_total += lost_packets;
+		}
+		lttng_destroy_handle(handle);
+	}
+	if (discarded_events_total > 0 && !selected_session->snapshot_mode) {
+		MSG("[warning] %" PRIu64 " events discarded, please refer to "
+				"the documentation on channel configuration.",
+				discarded_events_total);
+	}
+	if (lost_packets_total > 0 && !selected_session->snapshot_mode) {
+		MSG("[warning] %" PRIu64 " packets lost, please refer to "
+				"the documentation on channel configuration.",
+				lost_packets_total);
+	}
+
+end:
+	free(sessions);
+}
+
+int show_cmd_help(const char *cmd_name, const char *help_msg)
+{
+	int ret;
+	char page_name[32];
+
+	ret = sprintf(page_name, "lttng-%s", cmd_name);
+	assert(ret > 0 && ret < 32);
+	ret = utils_show_help(1, page_name, help_msg);
+	if (ret && !help_msg) {
+		ERR("Cannot view man page `lttng-%s(1)`", cmd_name);
+		perror("exec");
+	}
+
+	return ret;
+}