xored_key = (uint64_t)(key->session_id ^ key->bits_per_long ^ key->uid);
return hash_key_u64(&xored_key, seed);
xored_key = (uint64_t)(key->session_id ^ key->bits_per_long ^ key->uid);
return hash_key_u64(&xored_key, seed);
rcu_read_lock();
nodep = cds_lfht_add_unique(ht->ht, ht->hash_fct(reg, lttng_ht_seed),
ht->match_fct, reg, ®->node.node);
rcu_read_lock();
nodep = cds_lfht_add_unique(ht->ht, ht->hash_fct(reg, lttng_ht_seed),
ht->match_fct, reg, ®->node.node);
void buffer_reg_stream_add(struct buffer_reg_stream *stream,
struct buffer_reg_channel *channel)
{
void buffer_reg_stream_add(struct buffer_reg_stream *stream,
struct buffer_reg_channel *channel)
{
pthread_mutex_lock(&channel->stream_list_lock);
cds_list_add_tail(&stream->lnode, &channel->streams);
pthread_mutex_lock(&channel->stream_list_lock);
cds_list_add_tail(&stream->lnode, &channel->streams);
void buffer_reg_channel_add(struct buffer_reg_session *session,
struct buffer_reg_channel *channel)
{
void buffer_reg_channel_add(struct buffer_reg_session *session,
struct buffer_reg_channel *channel)
{
iter.iter.node = ®p->node.node;
ret = lttng_ht_del(session->channels, &iter);
iter.iter.node = ®p->node.node;
ret = lttng_ht_del(session->channels, &iter);
cds_lfht_for_each_entry(regp->channels->ht, &iter.iter, reg_chan,
node.node) {
ret = lttng_ht_del(regp->channels, &iter);
cds_lfht_for_each_entry(regp->channels->ht, &iter.iter, reg_chan,
node.node) {
ret = lttng_ht_del(regp->channels, &iter);
rcu_read_lock();
iter.iter.node = ®p->node.node;
ret = lttng_ht_del(buffer_registry_uid, &iter);
rcu_read_lock();
iter.iter.node = ®p->node.node;
ret = lttng_ht_del(buffer_registry_uid, &iter);
iter.iter.node = ®p->node.node;
ret = lttng_ht_del(buffer_registry_pid, &iter);
iter.iter.node = ®p->node.node;
ret = lttng_ht_del(buffer_registry_pid, &iter);