Fix: relayd: rotation failure for multi-domain session
[lttng-tools.git] / src / bin / lttng-relayd / viewer-stream.h
CommitLineData
7591bab1
MD
1#ifndef _VIEWER_STREAM_H
2#define _VIEWER_STREAM_H
3
2f8f53af 4/*
ab5be9fa
MJ
5 * Copyright (C) 2013 Julien Desfossez <jdesfossez@efficios.com>
6 * Copyright (C) 2013 David Goulet <dgoulet@efficios.com>
7 * Copyright (C) 2015 Mathieu Desnoyers <mathieu.desnoyers@efficios.com>
2f8f53af 8 *
ab5be9fa 9 * SPDX-License-Identifier: GPL-2.0-only
2f8f53af 10 *
2f8f53af
DG
11 */
12
2f8f53af
DG
13#include <limits.h>
14#include <inttypes.h>
15#include <pthread.h>
16
17#include <common/hashtable/hashtable.h>
18
19#include "ctf-trace.h"
20#include "lttng-viewer-abi.h"
2a174661 21#include "stream.h"
2f8f53af 22
2f8f53af
DG
23struct relay_stream;
24
25/*
7591bab1
MD
26 * The viewer stream's lifetime is the intersection of their viewer connection's
27 * lifetime and the duration during which at least:
28 * a) their input source is still active
29 * b) they still have data left to send to the client.
30 *
31 * This means that both the sessiond/consumerd connection or the viewer
32 * connection may tear down (and unpublish) a relay_viewer_stream.
33 *
34 * Viewer stream updates are protected by their associated stream's lock.
2f8f53af
DG
35 */
36struct relay_viewer_stream {
7591bab1 37 struct urcu_ref ref;
7591bab1
MD
38
39 /* Back ref to stream. */
40 struct relay_stream *stream;
41
ebb29c10 42 struct {
8bb66c3c 43 struct fs_handle *handle;
ebb29c10
JG
44 struct lttng_trace_chunk *trace_chunk;
45 } stream_file;
f8f3885c
MD
46 /* index file from which to read the index data. */
47 struct lttng_index_file *index_file;
80516611
JG
48 /*
49 * Last seen rotation count in stream.
50 *
51 * Sampled on every change to the viewer stream trace chunk,
52 * this allows the live server to determine if it saw the latest
53 * rotation that occurred on the receiving end.
54 */
55 uint64_t last_seen_rotation_count;
7591bab1 56
2f8f53af
DG
57 char *path_name;
58 char *channel_name;
7591bab1
MD
59
60 uint64_t current_tracefile_id;
7591bab1 61
a44ca2ca
MD
62 /*
63 * Counts the number of sent indexes. The "tag" associated
64 * with an index to send is the current index_received_seqcount,
65 * because we increment index_received_seqcount after sending
66 * each index. This index_received_seqcount counter can also be
67 * updated when catching up with the producer.
68 */
69 uint64_t index_sent_seqcount;
7591bab1
MD
70
71 /* Indicates if this stream has been sent to a viewer client. */
72 bool sent_flag;
73 /* For metadata stream, how much metadata has been sent. */
74 uint64_t metadata_sent;
75
2f8f53af
DG
76 struct lttng_ht_node_u64 stream_n;
77 struct rcu_head rcu_node;
2f8f53af
DG
78};
79
80struct relay_viewer_stream *viewer_stream_create(struct relay_stream *stream,
b66a15d1 81 struct lttng_trace_chunk *viewer_trace_chunk,
7591bab1
MD
82 enum lttng_viewer_seek seek_t);
83
84struct relay_viewer_stream *viewer_stream_get_by_id(uint64_t id);
85bool viewer_stream_get(struct relay_viewer_stream *vstream);
86void viewer_stream_put(struct relay_viewer_stream *vstream);
87int viewer_stream_rotate(struct relay_viewer_stream *vstream);
88bool viewer_stream_is_tracefile_seq_readable(struct relay_viewer_stream *vstream,
89 uint64_t seq);
90void print_viewer_streams(void);
3087b021
MD
91void viewer_stream_close_files(struct relay_viewer_stream *vstream);
92void viewer_stream_sync_tracefile_array_tail(struct relay_viewer_stream *vstream);
2f8f53af
DG
93
94#endif /* _VIEWER_STREAM_H */
This page took 0.050774 seconds and 4 git commands to generate.