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
);
41 static void rcu_destroy_stream(struct rcu_head
*head
)
43 struct relay_stream
*stream
=
44 caa_container_of(head
, struct relay_stream
, rcu_node
);
46 stream_destroy(stream
);
50 * Destroy a ctf trace and all stream contained in it.
52 * MUST be called with the RCU read side lock.
54 void ctf_trace_destroy(struct ctf_trace
*obj
)
56 struct relay_stream
*stream
, *tmp_stream
;
60 * Getting to this point, every stream referenced to that object have put
61 * back their ref since the've been closed by the control side.
63 assert(!obj
->refcount
);
65 cds_list_for_each_entry_safe(stream
, tmp_stream
, &obj
->stream_list
,
67 stream_delete(relay_streams_ht
, stream
);
68 call_rcu(&stream
->rcu_node
, rcu_destroy_stream
);
71 call_rcu(&obj
->node
.head
, rcu_destroy_ctf_trace
);
74 void ctf_trace_try_destroy(struct relay_session
*session
,
75 struct ctf_trace
*ctf_trace
)
81 * Considering no viewer attach to the session and the trace having no more
82 * stream attached, wipe the trace.
84 if (uatomic_read(&session
->viewer_refcount
) == 0 &&
85 uatomic_read(&ctf_trace
->refcount
) == 0) {
86 ctf_trace_delete(session
->ctf_traces_ht
, ctf_trace
);
87 ctf_trace_destroy(ctf_trace
);
92 * Create and return an allocated ctf_trace object. NULL on error.
94 struct ctf_trace
*ctf_trace_create(char *path_name
)
96 struct ctf_trace
*obj
;
100 obj
= zmalloc(sizeof(*obj
));
102 PERROR("ctf_trace alloc");
106 CDS_INIT_LIST_HEAD(&obj
->stream_list
);
108 obj
->id
= ++last_relay_ctf_trace_id
;
109 lttng_ht_node_init_str(&obj
->node
, path_name
);
111 DBG("Created ctf_trace %" PRIu64
" with path: %s", obj
->id
, path_name
);
118 * Return a ctf_trace object if found by id in the given hash table else NULL.
120 struct ctf_trace
*ctf_trace_find_by_path(struct lttng_ht
*ht
,
123 struct lttng_ht_node_str
*node
;
124 struct lttng_ht_iter iter
;
125 struct ctf_trace
*trace
= NULL
;
129 lttng_ht_lookup(ht
, (void *) path_name
, &iter
);
130 node
= lttng_ht_iter_get_node_str(&iter
);
132 DBG("CTF Trace path %s not found", path_name
);
135 trace
= caa_container_of(node
, struct ctf_trace
, node
);
142 * Add stream to a given hash table.
144 void ctf_trace_add(struct lttng_ht
*ht
, struct ctf_trace
*trace
)
149 lttng_ht_add_str(ht
, &trace
->node
);
153 * Delete stream from a given hash table.
155 void ctf_trace_delete(struct lttng_ht
*ht
, struct ctf_trace
*trace
)
158 struct lttng_ht_iter iter
;
163 iter
.iter
.node
= &trace
->node
.node
;
164 ret
= lttng_ht_del(ht
, &iter
);
This page took 0.04848 seconds and 4 git commands to generate.