Signed-off-by: David Goulet <dgoulet@efficios.com>
lttng_consumer_sync_trace_file(stream, orig_offset);
end:
lttng_consumer_sync_trace_file(stream, orig_offset);
end:
- pthread_mutex_unlock(&stream->lock);
/* Unlock only if ctrl socket used */
if (relayd && stream->metadata_flag) {
pthread_mutex_unlock(&relayd->ctrl_sock_mutex);
}
/* Unlock only if ctrl socket used */
if (relayd && stream->metadata_flag) {
pthread_mutex_unlock(&relayd->ctrl_sock_mutex);
}
+ pthread_mutex_unlock(&stream->lock);
rcu_read_unlock();
return written;
rcu_read_unlock();
return written;
- pthread_mutex_unlock(&stream->lock);
if (relayd && stream->metadata_flag) {
pthread_mutex_unlock(&relayd->ctrl_sock_mutex);
}
if (relayd && stream->metadata_flag) {
pthread_mutex_unlock(&relayd->ctrl_sock_mutex);
}
+ pthread_mutex_unlock(&stream->lock);
rcu_read_unlock();
return written;
rcu_read_unlock();
return written;
DBG("Consumer data available command on session id %" PRIu64, id);
DBG("Consumer data available command on session id %" PRIu64, id);
pthread_mutex_lock(&consumer_data.lock);
switch (consumer_data.type) {
pthread_mutex_lock(&consumer_data.lock);
switch (consumer_data.type) {
/* Ease our life a bit */
ht = consumer_data.stream_list_ht;
/* Ease our life a bit */
ht = consumer_data.stream_list_ht;