summary |
shortlog |
log |
commit | commitdiff |
tree
raw |
patch |
inline | side by side (from parent 1:
a5bbe8f)
Signed-off-by: Jérémie Galarneau <jeremie.galarneau@efficios.com>
Signed-off-by: David Goulet <dgoulet@efficios.com>
lttng_ht_node_init_u64(&chan->wait_fd_node,
chan->wait_fd);
lttng_ht_node_init_u64(&chan->wait_fd_node,
chan->wait_fd);
lttng_ht_add_unique_u64(channel_ht,
&chan->wait_fd_node);
lttng_ht_add_unique_u64(channel_ht,
&chan->wait_fd_node);
/* Add channel to the global poll events list */
lttng_poll_add(&events, chan->wait_fd,
LPOLLIN | LPOLLPRI);
break;
case CONSUMER_CHANNEL_DEL:
{
/* Add channel to the global poll events list */
lttng_poll_add(&events, chan->wait_fd,
LPOLLIN | LPOLLPRI);
break;
case CONSUMER_CHANNEL_DEL:
{
chan = consumer_find_channel(key);
if (!chan) {
chan = consumer_find_channel(key);
if (!chan) {
ERR("UST consumer get channel key %" PRIu64 " not found for del channel", key);
break;
}
ERR("UST consumer get channel key %" PRIu64 " not found for del channel", key);
break;
}
if (!uatomic_sub_return(&chan->refcount, 1)) {
consumer_del_channel(chan);
}
if (!uatomic_sub_return(&chan->refcount, 1)) {
consumer_del_channel(chan);
}
goto restart;
}
case CONSUMER_CHANNEL_QUIT:
goto restart;
}
case CONSUMER_CHANNEL_QUIT: