unsigned int metadata_out; /* Bytes consumed from stream */
int finalized; /* Has channel been finalized */
wait_queue_head_t read_wait; /* Reader buffer-level wait queue */
- struct list_head list; /* Stream list */
+ struct list_head node; /* Stream list */
struct lttng_transport *transport;
uint64_t version; /* Current version of the metadata cache */
bool coherent; /* Stream in a coherent state */
struct lttng_kernel_ring_buffer *buf = stream->priv;
mutex_lock(&stream->metadata_cache->lock);
- list_del(&stream->list);
+ list_del(&stream->node);
mutex_unlock(&stream->metadata_cache->lock);
kref_put(&stream->metadata_cache->refcount, metadata_cache_destroy);
module_put(stream->transport->owner);
goto fd_error;
mutex_lock(&session->priv->metadata_cache->lock);
- list_add(&metadata_stream->list,
+ list_add(&metadata_stream->node,
&session->priv->metadata_cache->metadata_stream);
mutex_unlock(&session->priv->metadata_cache->lock);
return ret;
_lttng_channel_destroy(chan_priv->pub);
}
mutex_lock(&session->priv->metadata_cache->lock);
- list_for_each_entry(metadata_stream, &session->priv->metadata_cache->metadata_stream, list)
+ list_for_each_entry(metadata_stream, &session->priv->metadata_cache->metadata_stream, node)
_lttng_metadata_channel_hangup(metadata_stream);
mutex_unlock(&session->priv->metadata_cache->lock);
lttng_id_tracker_fini(&session->pid_tracker);
memset(cache->data, 0, cache->cache_alloc);
cache->metadata_written = 0;
cache->version++;
- list_for_each_entry(stream, &session->priv->metadata_cache->metadata_stream, list) {
+ list_for_each_entry(stream, &session->priv->metadata_cache->metadata_stream, node) {
stream->metadata_out = 0;
stream->metadata_in = 0;
}
if (atomic_dec_return(&session->priv->metadata_cache->producing) == 0) {
struct lttng_metadata_stream *stream;
- list_for_each_entry(stream, &session->priv->metadata_cache->metadata_stream, list)
+ list_for_each_entry(stream, &session->priv->metadata_cache->metadata_stream, node)
wake_up_interruptible(&stream->read_wait);
mutex_unlock(&session->priv->metadata_cache->lock);
}