X-Git-Url: http://git.efficios.com/?p=lttng-tools.git;a=blobdiff_plain;f=src%2Fbin%2Flttng-relayd%2Fctf-trace.c;h=4ca6dba1e40c489bdd92f6a0a90636d5841dd94e;hp=27009efc38270bd0e46adc6b046f59134c8b5b12;hb=ce4d40839ac3beef1a58730d3636a522497bc60f;hpb=f22dd89135f6b1749cd75735f04e3cb309da12c1 diff --git a/src/bin/lttng-relayd/ctf-trace.c b/src/bin/lttng-relayd/ctf-trace.c index 27009efc3..4ca6dba1e 100644 --- a/src/bin/lttng-relayd/ctf-trace.c +++ b/src/bin/lttng-relayd/ctf-trace.c @@ -75,17 +75,7 @@ void ctf_trace_release(struct urcu_ref *ref) */ bool ctf_trace_get(struct ctf_trace *trace) { - bool has_ref = false; - - /* Confirm that the trace refcount has not reached 0. */ - pthread_mutex_lock(&trace->reflock); - if (trace->ref.refcount != 0) { - has_ref = true; - urcu_ref_get(&trace->ref); - } - pthread_mutex_unlock(&trace->reflock); - - return has_ref; + return urcu_ref_get_unless_zero(&trace->ref); } /* @@ -123,7 +113,6 @@ static struct ctf_trace *ctf_trace_create(struct relay_session *session, trace->session = session; urcu_ref_init(&trace->ref); pthread_mutex_init(&trace->lock, NULL); - pthread_mutex_init(&trace->reflock, NULL); pthread_mutex_init(&trace->stream_list_lock, NULL); lttng_ht_add_str(session->ctf_traces_ht, &trace->node); @@ -168,9 +157,7 @@ end: void ctf_trace_put(struct ctf_trace *trace) { rcu_read_lock(); - pthread_mutex_lock(&trace->reflock); urcu_ref_put(&trace->ref, ctf_trace_release); - pthread_mutex_unlock(&trace->reflock); rcu_read_unlock(); }