Add jul.c/.h to sessiond code
authorDavid Goulet <dgoulet@efficios.com>
Mon, 30 Sep 2013 19:06:27 +0000 (15:06 -0400)
committerDavid Goulet <dgoulet@efficios.com>
Wed, 16 Oct 2013 14:18:22 +0000 (10:18 -0400)
This adds data structures to handle the JUL domain. The domain is added
to a ust session and created/destroyed in the trace-ust.c API.

Nothing is working yet, just putting the piece together.

Signed-off-by: David Goulet <dgoulet@efficios.com>
src/bin/lttng-sessiond/Makefile.am
src/bin/lttng-sessiond/jul.c [new file with mode: 0644]
src/bin/lttng-sessiond/jul.h [new file with mode: 0644]
src/bin/lttng-sessiond/trace-ust.c
src/bin/lttng-sessiond/trace-ust.h
src/common/defaults.h
tests/unit/Makefile.am

index 3d96907deac377f4e70ed64c5037ec6e9883f3b0..21b58591056512bae0f7ccedd66cb2dd0169b790 100644 (file)
@@ -26,7 +26,8 @@ lttng_sessiond_SOURCES = utils.c utils.h \
                        cmd.c cmd.h \
                        buffer-registry.c buffer-registry.h \
                        testpoint.h ht-cleanup.c \
-                       snapshot.c snapshot.h
+                       snapshot.c snapshot.h \
+                       jul.c jul.h
 
 if HAVE_LIBLTTNG_UST_CTL
 lttng_sessiond_SOURCES += trace-ust.c ust-registry.c ust-app.c \
diff --git a/src/bin/lttng-sessiond/jul.c b/src/bin/lttng-sessiond/jul.c
new file mode 100644 (file)
index 0000000..a38738c
--- /dev/null
@@ -0,0 +1,195 @@
+/*
+ * Copyright (C) 2013 - 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, 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.
+ *
+ * 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
+#include <assert.h>
+
+#include <common/common.h>
+
+#include "jul.h"
+#include "utils.h"
+
+/*
+ * URCU intermediate call to complete destroy a JUL event.
+ */
+static void destroy_event_jul_rcu(struct rcu_head *head)
+{
+       struct lttng_ht_node_str *node =
+               caa_container_of(head, struct lttng_ht_node_str, head);
+       struct jul_event *event =
+               caa_container_of(node, struct jul_event, node);
+
+       free(event);
+}
+
+/*
+ * Initialize an already allocated JUL domain object.
+ *
+ * Return 0 on success or else a negative errno value.
+ */
+int jul_init_domain(struct jul_domain *dom)
+{
+       int ret;
+
+       assert(dom);
+
+       dom->events = lttng_ht_new(0, LTTNG_HT_TYPE_STRING);
+       if (!dom->events) {
+               ret = -ENOMEM;
+               goto error;
+       }
+
+       return 0;
+
+error:
+       return ret;
+}
+
+/*
+ * Create a newly allocated JUL event data structure. If name is valid, it's
+ * copied into the created event.
+ *
+ * Return a new object else NULL on error.
+ */
+struct jul_event *jul_create_event(const char *name)
+{
+       struct jul_event *event;
+
+       DBG3("JUL create new event with name %s", name);
+
+       event = zmalloc(sizeof(*event));
+       if (!event) {
+               goto error;
+       }
+
+       if (name) {
+               strncpy(event->name, name, sizeof(event->name));
+               event->name[sizeof(event->name) - 1] = '\0';
+       }
+
+error:
+       return event;
+}
+
+/*
+ * Unique add of a JUL event to a given domain.
+ */
+void jul_add_event(struct jul_event *event, struct jul_domain *dom)
+{
+       assert(event);
+       assert(dom);
+       assert(dom->events);
+
+       DBG3("JUL adding event %s to domain", event->name);
+
+       lttng_ht_add_unique_str(dom->events, &event->node);
+}
+
+/*
+ * Find a JUL event in the given domain using name.
+ *
+ * RCU read side lock MUST be acquired.
+ *
+ * Return object if found else NULL.
+ */
+struct jul_event *jul_find_by_name(const char *name, struct jul_domain *dom)
+{
+       struct lttng_ht_node_str *node;
+       struct lttng_ht_iter iter;
+
+       assert(name);
+       assert(dom);
+       assert(dom->events);
+
+       lttng_ht_lookup(dom->events, (void *)name, &iter);
+       node = lttng_ht_iter_get_node_str(&iter);
+       if (node == NULL) {
+               goto error;
+       }
+
+       DBG3("JUL found by name %s in domain.", name);
+       return caa_container_of(node, struct jul_event, node);
+
+error:
+       DBG3("JUL NOT found by name %s in domain.", name);
+       return NULL;
+}
+
+/*
+ * Delete JUL event from given domain. Events hash table MUST be initialized.
+ */
+void jul_delete_event(struct jul_event *event, struct jul_domain *dom)
+{
+       int ret;
+       struct lttng_ht_iter iter;
+
+       assert(event);
+       assert(dom);
+       assert(dom->events);
+
+       DBG3("JUL deleting event %s from domain", event->name);
+
+       iter.iter.node = &event->node.node;
+       rcu_read_lock();
+       ret = lttng_ht_del(dom->events, &iter);
+       rcu_read_unlock();
+       assert(!ret);
+}
+
+/*
+ * Free given JUl event. After this call, the pointer is not usable anymore.
+ */
+void jul_destroy_event(struct jul_event *event)
+{
+       assert(event);
+
+       free(event);
+}
+
+/*
+ * Destroy a JUL domain completely. Note that the given pointer is NOT freed
+ * thus a reference can be passed to this function.
+ */
+void jul_destroy_domain(struct jul_domain *dom)
+{
+       struct lttng_ht_node_str *node;
+       struct lttng_ht_iter iter;
+
+       assert(dom);
+
+       DBG3("JUL destroy domain");
+
+       /*
+        * Just ignore if no events hash table exists. This is possible if for
+        * instance a JUL domain object was allocated but not initialized.
+        */
+       if (!dom->events) {
+               return;
+       }
+
+       rcu_read_lock();
+       cds_lfht_for_each_entry(dom->events->ht, &iter.iter, node, node) {
+               int ret;
+
+               ret = lttng_ht_del(dom->events, &iter);
+               assert(!ret);
+               call_rcu(&node->head, destroy_event_jul_rcu);
+       }
+       rcu_read_unlock();
+
+       ht_cleanup_push(dom->events);
+}
diff --git a/src/bin/lttng-sessiond/jul.h b/src/bin/lttng-sessiond/jul.h
new file mode 100644 (file)
index 0000000..1f7f6cd
--- /dev/null
@@ -0,0 +1,64 @@
+/*
+ * Copyright (C) 2013 - 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, 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.
+ *
+ * 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.
+ */
+
+#ifndef _JUL_H
+#define _JUL_H
+
+#include <common/hashtable/hashtable.h>
+#include <lttng/lttng.h>
+
+/*
+ * Java Util Logging event representation.
+ */
+struct jul_event {
+       /*
+        * Name of the event which is directly mapped to a Logger object name in
+        * the JUL API.
+        */
+       char name[LTTNG_SYMBOL_NAME_LEN];
+
+       /*
+        * Tells if the event is enabled or not on the JUL Agent.
+        */
+       unsigned int enabled:1;
+
+       /*
+        * Hash table nodes of the JUL domain. Indexed by name string.
+        */
+       struct lttng_ht_node_str node;
+};
+
+/*
+ * Top level data structure in a UST session containing JUL event name created
+ * for it.
+ */
+struct jul_domain {
+       /*
+        * Contains JUL event indexed by name.
+        */
+       struct lttng_ht *events;
+};
+
+int jul_init_domain(struct jul_domain *dom);
+struct jul_event *jul_create_event(const char *name);
+void jul_add_event(struct jul_event *event, struct jul_domain *dom);
+struct jul_event *jul_find_by_name(const char *name, struct jul_domain *dom);
+void jul_delete_event(struct jul_event *event, struct jul_domain *dom);
+void jul_destroy_event(struct jul_event *event);
+void jul_destroy_domain(struct jul_domain *dom);
+
+#endif /* _JUL_H */
index 8363ae2954912482900e2aa5f3eeeeb4cd7bd26f..b64597599caaaa9e127306f0c1b0bee806c508f0 100644 (file)
@@ -191,6 +191,7 @@ error:
  */
 struct ltt_ust_session *trace_ust_create_session(uint64_t session_id)
 {
+       int ret;
        struct ltt_ust_session *lus;
 
        /* Allocate a new ltt ust session */
@@ -218,6 +219,10 @@ struct ltt_ust_session *trace_ust_create_session(uint64_t session_id)
 
        /* Alloc UST global domain channels' HT */
        lus->domain_global.channels = lttng_ht_new(0, LTTNG_HT_TYPE_STRING);
+       ret = jul_init_domain(&lus->domain_jul);
+       if (ret < 0) {
+               goto error_consumer;
+       }
 
        lus->consumer = consumer_create_output(CONSUMER_DST_LOCAL);
        if (lus->consumer == NULL) {
@@ -238,6 +243,7 @@ struct ltt_ust_session *trace_ust_create_session(uint64_t session_id)
 
 error_consumer:
        ht_cleanup_push(lus->domain_global.channels);
+       jul_destroy_domain(&lus->domain_jul);
        free(lus);
 error:
        return NULL;
@@ -677,6 +683,7 @@ void trace_ust_destroy_session(struct ltt_ust_session *session)
 
        /* Cleaning up UST domain */
        destroy_domain_global(&session->domain_global);
+       jul_destroy_domain(&session->domain_jul);
 
        /* Cleanup UID buffer registry object(s). */
        cds_list_for_each_entry_safe(reg, sreg, &session->buffer_reg_uid_list,
index aa6ac408f1551b6ddd7521fac734cbf097b0afd6..f25573a80d8015e5ca69280a1419d0a256d0acc7 100644 (file)
@@ -27,6 +27,7 @@
 #include <common/defaults.h>
 
 #include "consumer.h"
+#include "jul.h"
 #include "ust-ctl.h"
 
 struct ltt_ust_ht_key {
@@ -84,6 +85,7 @@ struct ltt_ust_session {
        uint64_t id;    /* Unique identifier of session */
        int start_trace;
        struct ltt_ust_domain_global domain_global;
+       struct jul_domain domain_jul;
        /* UID/GID of the user owning the session */
        uid_t uid;
        gid_t gid;
index 0c9f134a91161369b1ffb21f9111edfc12fd0871..0682af63df6eb4904698c5aa0b9b99f8f5a61027 100644 (file)
 
 /* Default channel attributes */
 #define DEFAULT_CHANNEL_NAME            "channel0"
+/* Default JUL domain channel name. */
+#define DEFAULT_JUL_CHANNEL_NAME        "jul_channel"
+/* JUL default channel name. */
 #define DEFAULT_CHANNEL_OVERWRITE       0
 #define DEFAULT_CHANNEL_TRACEFILE_SIZE  0
 #define DEFAULT_CHANNEL_TRACEFILE_COUNT 0
index 871be38593b2999e8ae11980190c3ebd66e4fdc9..a8dec2bd96e91aa25da8e841d590a3d2717fd676 100644 (file)
@@ -56,6 +56,7 @@ UST_DATA_TRACE=$(top_builddir)/src/bin/lttng-sessiond/trace-ust.o \
                   $(top_builddir)/src/bin/lttng-sessiond/fd-limit.o \
                   $(top_builddir)/src/bin/lttng-sessiond/session.o \
                   $(top_builddir)/src/bin/lttng-sessiond/snapshot.o \
+                  $(top_builddir)/src/bin/lttng-sessiond/jul.o \
                   $(top_builddir)/src/common/.libs/uri.o \
                   $(top_builddir)/src/common/.libs/utils.o \
                   $(top_builddir)/src/common/health/libhealth.la \
This page took 0.041529 seconds and 4 git commands to generate.