2 * Copyright (C) 2013 - Julien Desfossez <jdesfossez@efficios.com>
3 * David Goulet <dgoulet@efficios.com>
5 * This program is free software; you can redistribute it and/or modify it
6 * under the terms of the GNU General Public License, version 2 only, as
7 * published by the Free Software Foundation.
9 * This program is distributed in the hope that it will be useful, but WITHOUT
10 * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
11 * FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License for
14 * You should have received a copy of the GNU General Public License along with
15 * this program; if not, write to the Free Software Foundation, Inc., 51
16 * Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA.
22 #include <common/common.h>
23 #include <common/utils.h>
25 #include "ctf-trace.h"
26 #include "lttng-relayd.h"
29 static uint64_t last_relay_ctf_trace_id
;
31 static void rcu_destroy_ctf_trace(struct rcu_head
*head
)
33 struct lttng_ht_node_str
*node
=
34 caa_container_of(head
, struct lttng_ht_node_str
, head
);
35 struct ctf_trace
*trace
=
36 caa_container_of(node
, struct ctf_trace
, node
);
42 * Destroy a ctf trace and all stream contained in it.
44 * MUST be called with the RCU read side lock.
46 void ctf_trace_destroy(struct ctf_trace
*obj
)
48 struct relay_stream
*stream
, *tmp_stream
;
52 * Getting to this point, every stream referenced to that object have put
53 * back their ref since the've been closed by the control side.
55 assert(!obj
->refcount
);
57 cds_list_for_each_entry_safe(stream
, tmp_stream
, &obj
->stream_list
,
59 stream_delete(relay_streams_ht
, stream
);
60 stream_destroy(stream
);
63 call_rcu(&obj
->node
.head
, rcu_destroy_ctf_trace
);
66 void ctf_trace_try_destroy(struct relay_session
*session
,
67 struct ctf_trace
*ctf_trace
)
73 * Considering no viewer attach to the session and the trace having no more
74 * stream attached, wipe the trace.
76 if (uatomic_read(&session
->viewer_refcount
) == 0 &&
77 uatomic_read(&ctf_trace
->refcount
) == 0) {
78 ctf_trace_delete(session
->ctf_traces_ht
, ctf_trace
);
79 ctf_trace_destroy(ctf_trace
);
84 * Create and return an allocated ctf_trace object. NULL on error.
86 struct ctf_trace
*ctf_trace_create(char *path_name
)
88 struct ctf_trace
*obj
;
92 obj
= zmalloc(sizeof(*obj
));
94 PERROR("ctf_trace alloc");
98 CDS_INIT_LIST_HEAD(&obj
->stream_list
);
100 obj
->id
= ++last_relay_ctf_trace_id
;
101 lttng_ht_node_init_str(&obj
->node
, path_name
);
103 DBG("Created ctf_trace %" PRIu64
" with path: %s", obj
->id
, path_name
);
110 * Return a ctf_trace object if found by id in the given hash table else NULL.
112 struct ctf_trace
*ctf_trace_find_by_path(struct lttng_ht
*ht
,
115 struct lttng_ht_node_str
*node
;
116 struct lttng_ht_iter iter
;
117 struct ctf_trace
*trace
= NULL
;
121 lttng_ht_lookup(ht
, (void *) path_name
, &iter
);
122 node
= lttng_ht_iter_get_node_str(&iter
);
124 DBG("CTF Trace path %s not found", path_name
);
127 trace
= caa_container_of(node
, struct ctf_trace
, node
);
134 * Add stream to a given hash table.
136 void ctf_trace_add(struct lttng_ht
*ht
, struct ctf_trace
*trace
)
141 lttng_ht_add_str(ht
, &trace
->node
);
145 * Delete stream from a given hash table.
147 void ctf_trace_delete(struct lttng_ht
*ht
, struct ctf_trace
*trace
)
150 struct lttng_ht_iter iter
;
155 iter
.iter
.node
= &trace
->node
.node
;
156 ret
= lttng_ht_del(ht
, &iter
);
This page took 0.075924 seconds and 4 git commands to generate.