projects
/
lttng-tools.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
consumerd: remove unused function consumer_del_data_stream
[lttng-tools.git]
/
src
/
bin
/
lttng-relayd
/
index.h
diff --git
a/src/bin/lttng-relayd/index.h
b/src/bin/lttng-relayd/index.h
index 15c4ac8cd8201b906e458a4e819416004a9a1d1e..8466e91a468b501cc7bc14ac2a2aaeac0f1e87a2 100644
(file)
--- a/
src/bin/lttng-relayd/index.h
+++ b/
src/bin/lttng-relayd/index.h
@@
-29,24
+29,27
@@
#include "stream-fd.h"
struct relay_stream;
#include "stream-fd.h"
struct relay_stream;
+struct relay_connection;
+struct lttcomm_relayd_index;
struct relay_index {
/*
* index lock nests inside stream lock.
*/
struct relay_index {
/*
* index lock nests inside stream lock.
*/
- pthread_mutex_t reflock; /* Protects refcounting. */
struct urcu_ref ref; /* Reference from getters. */
struct relay_stream *stream; /* Back ref to stream */
pthread_mutex_t lock;
/*
struct urcu_ref ref; /* Reference from getters. */
struct relay_stream *stream; /* Back ref to stream */
pthread_mutex_t lock;
/*
- *
FD
on which to write the index data. May differ from
- * stream->index_f
d
due to tracefile rotation.
+ *
index file
on which to write the index data. May differ from
+ * stream->index_f
ile
due to tracefile rotation.
*/
*/
- struct
stream_fd *index_fd
;
+ struct
lttng_index_file *index_file
;
/* Index packet data. This is the data that is written on disk. */
struct ctf_packet_index index_data;
/* Index packet data. This is the data that is written on disk. */
struct ctf_packet_index index_data;
+ /* Data + padding size of this packet, filled by the data thread. */
+ uint64_t total_size;
bool has_index_data;
bool flushed;
bool has_index_data;
bool flushed;
@@
-64,8
+67,9
@@
struct relay_index {
struct relay_index *relay_index_get_by_id_or_create(struct relay_stream *stream,
uint64_t net_seq_num);
void relay_index_put(struct relay_index *index);
struct relay_index *relay_index_get_by_id_or_create(struct relay_stream *stream,
uint64_t net_seq_num);
void relay_index_put(struct relay_index *index);
-int relay_index_set_fd(struct relay_index *index, struct stream_fd *index_fd,
- uint64_t data_offset);
+int relay_index_set_file(struct relay_index *index,
+ struct lttng_index_file *index_file,
+ uint64_t data_offset);
int relay_index_set_data(struct relay_index *index,
const struct ctf_packet_index *data);
int relay_index_try_flush(struct relay_index *index);
int relay_index_set_data(struct relay_index *index,
const struct ctf_packet_index *data);
int relay_index_try_flush(struct relay_index *index);
@@
-73,5
+77,9
@@
int relay_index_try_flush(struct relay_index *index);
void relay_index_close_all(struct relay_stream *stream);
void relay_index_close_partial_fd(struct relay_stream *stream);
uint64_t relay_index_find_last(struct relay_stream *stream);
void relay_index_close_all(struct relay_stream *stream);
void relay_index_close_partial_fd(struct relay_stream *stream);
uint64_t relay_index_find_last(struct relay_stream *stream);
+int relay_index_switch_all_files(struct relay_stream *stream);
+int relay_index_set_control_data(struct relay_index *index,
+ const struct lttcomm_relayd_index *data,
+ unsigned int minor_version);
#endif /* _RELAY_INDEX_H */
#endif /* _RELAY_INDEX_H */
This page took
0.025903 seconds
and
5
git commands to generate.