X-Git-Url: https://git.liburcu.org/?a=blobdiff_plain;f=libust%2Fmarker-control.c;h=3d509525508a0446e828e1b3fecc165bcf75a560;hb=30ffe2794fc413035208cdd2a7a061bc208e210f;hp=b4b7ce1a72d7d017cc34c6b05050efc2f0fb3773;hpb=f7b16408b00ecce757bdde940853a48534b25edd;p=ust.git

diff --git a/libust/marker-control.c b/libust/marker-control.c
index b4b7ce1..3d50952 100644
--- a/libust/marker-control.c
+++ b/libust/marker-control.c
@@ -15,19 +15,23 @@
  * License along with this library; if not, write to the Free Software
  * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA  02110-1301 USA
  *
- * LTT marker control module over /proc
+ */
+
+/* This file contains a high-level API for activating and deactivating markers,
+ * and making sure markers in a given library can be released when the library
+ * is unloaded.
  */
 
 #include <ctype.h>
 #include <stdlib.h>
 
 #include "tracer.h"
-#include "usterr.h"
+#include "usterr_signal_safe.h"
 
 #define DEFAULT_CHANNEL "cpu"
 #define DEFAULT_PROBE "default"
 
-LIST_HEAD(probes_list);
+CDS_LIST_HEAD(probes_list);
 
 /*
  * Mutex protecting the probe slab cache.
@@ -43,11 +47,11 @@ struct ltt_available_probe default_probe = {
 };
 
 //ust//static struct kmem_cache *markers_loaded_cachep;
-static LIST_HEAD(markers_loaded_list);
+static CDS_LIST_HEAD(markers_loaded_list);
 /*
  * List sorted by name strcmp order.
  */
-static LIST_HEAD(probes_registered_list);
+static CDS_LIST_HEAD(probes_registered_list);
 
 //ust// static struct proc_dir_entry *pentry;
 
@@ -60,7 +64,7 @@ static struct ltt_available_probe *get_probe_from_name(const char *pname)
 
 	if (!pname)
 		pname = DEFAULT_PROBE;
-	list_for_each_entry(iter, &probes_registered_list, node) {
+	cds_list_for_each_entry(iter, &probes_registered_list, node) {
 		comparison = strcmp(pname, iter->name);
 		if (!comparison)
 			found = 1;
@@ -104,19 +108,19 @@ int ltt_probe_register(struct ltt_available_probe *pdata)
 	struct ltt_available_probe *iter;
 
 	pthread_mutex_lock(&probes_mutex);
-	list_for_each_entry_reverse(iter, &probes_registered_list, node) {
+	cds_list_for_each_entry_reverse(iter, &probes_registered_list, node) {
 		comparison = strcmp(pdata->name, iter->name);
 		if (!comparison) {
 			ret = -EBUSY;
 			goto end;
 		} else if (comparison > 0) {
 			/* We belong to the location right after iter. */
-			list_add(&pdata->node, &iter->node);
+			cds_list_add(&pdata->node, &iter->node);
 			goto end;
 		}
 	}
 	/* Should be added at the head of the list */
-	list_add(&pdata->node, &probes_registered_list);
+	cds_list_add(&pdata->node, &probes_registered_list);
 end:
 	pthread_mutex_unlock(&probes_mutex);
 	return ret;
@@ -131,17 +135,17 @@ int ltt_probe_unregister(struct ltt_available_probe *pdata)
 	struct ltt_active_marker *amark, *tmp;
 
 	pthread_mutex_lock(&probes_mutex);
-	list_for_each_entry_safe(amark, tmp, &markers_loaded_list, node) {
+	cds_list_for_each_entry_safe(amark, tmp, &markers_loaded_list, node) {
 		if (amark->probe == pdata) {
 			ret = marker_probe_unregister_private_data(
 				pdata->probe_func, amark);
 			if (ret)
 				goto end;
-			list_del(&amark->node);
+			cds_list_del(&amark->node);
 			free(amark);
 		}
 	}
-	list_del(&pdata->node);
+	cds_list_del(&pdata->node);
 end:
 	pthread_mutex_unlock(&probes_mutex);
 	return ret;
@@ -185,7 +189,7 @@ int ltt_marker_connect(const char *channel, const char *mname,
 	if (ret)
 		free(pdata);
 	else
-		list_add(&pdata->node, &markers_loaded_list);
+		cds_list_add(&pdata->node, &markers_loaded_list);
 end:
 	pthread_mutex_unlock(&probes_mutex);
 	ltt_unlock_traces();
@@ -223,7 +227,7 @@ int ltt_marker_disconnect(const char *channel, const char *mname,
 	if (ret)
 		goto end;
 	else {
-		list_del(&pdata->node);
+		cds_list_del(&pdata->node);
 		free(pdata);
 	}
 end:
@@ -387,10 +391,10 @@ static void disconnect_all_markers(void)
 {
 	struct ltt_active_marker *pdata, *tmp;
 
-	list_for_each_entry_safe(pdata, tmp, &markers_loaded_list, node) {
+	cds_list_for_each_entry_safe(pdata, tmp, &markers_loaded_list, node) {
 		marker_probe_unregister_private_data(pdata->probe->probe_func,
 			pdata);
-		list_del(&pdata->node);
+		cds_list_del(&pdata->node);
 		free(pdata);
 	}
 }