X-Git-Url: https://git.lttng.org/?a=blobdiff_plain;f=src%2Fbin%2Flttng-sessiond%2Frotate.h;fp=src%2Fbin%2Flttng-sessiond%2Frotate.h;h=b2f006f3e2fc96bbf0260480e409772dc4e18cc5;hb=db66e57489e5014289dc1d831e1eac90ac4fc0da;hp=0000000000000000000000000000000000000000;hpb=b99a8d4211e26a847ca8916884354f159c999ad2;p=lttng-tools.git diff --git a/src/bin/lttng-sessiond/rotate.h b/src/bin/lttng-sessiond/rotate.h new file mode 100644 index 000000000..b2f006f3e --- /dev/null +++ b/src/bin/lttng-sessiond/rotate.h @@ -0,0 +1,51 @@ +/* + * Copyright (C) 2017 - Julien Desfossez + * + * This program is free software; you can redistribute it and/or modify it + * under the terms of the GNU General Public License, version 2 only, as + * published by the Free Software Foundation. + * + * This program is distributed in the hope that it will be useful, but WITHOUT + * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or + * FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License for + * more details. + * + * You should have received a copy of the GNU General Public License along with + * this program; if not, write to the Free Software Foundation, Inc., 51 + * Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA. + */ + +#ifndef ROTATE_H +#define ROTATE_H + +#include "rotation-thread.h" + +/* + * Key in channel_pending_rotate_ht to map a channel to a + * struct rotation_channel_info. + */ +struct rotation_channel_key { + uint64_t key; + enum lttng_domain_type domain; +}; + +/* + * Added in channel_pending_rotate_ht everytime we start the rotation of a + * channel. The consumer notifies the rotation thread with the channel_key to + * inform a rotation is complete, we use that information to lookup the related + * session from channel_pending_rotate_ht. + */ +struct rotation_channel_info { + uint64_t session_id; + struct rotation_channel_key channel_key; + struct cds_lfht_node rotate_channels_ht_node; +}; + +extern struct cds_lfht *channel_pending_rotate_ht; + +unsigned long hash_channel_key(struct rotation_channel_key *key); + +/* session lock must be held by this function's caller. */ +int rename_complete_chunk(struct ltt_session *session, time_t ts); + +#endif /* ROTATE_H */