projects
/
lttng-tools.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
relayd: track the live viewer worker thread's epoll fd
[lttng-tools.git]
/
src
/
bin
/
lttng-relayd
/
session.h
diff --git
a/src/bin/lttng-relayd/session.h
b/src/bin/lttng-relayd/session.h
index 228873300cab6f134465d8a6fa208b36dfc94d5d..43f76a4aad54eadc7ac3e53f311bab00a748653b 100644
(file)
--- a/
src/bin/lttng-relayd/session.h
+++ b/
src/bin/lttng-relayd/session.h
@@
-28,7
+28,7
@@
#include <lttng/constant.h>
#include <common/hashtable/hashtable.h>
#include <lttng/constant.h>
#include <common/hashtable/hashtable.h>
-#include <common/
compat/
uuid.h>
+#include <common/uuid.h>
#include <common/trace-chunk.h>
#include <common/optional.h>
#include <common/trace-chunk.h>
#include <common/optional.h>
@@
-53,9
+53,17
@@
struct relay_session {
*/
lttng_uuid sessiond_uuid;
LTTNG_OPTIONAL(time_t) creation_time;
*/
lttng_uuid sessiond_uuid;
LTTNG_OPTIONAL(time_t) creation_time;
+ /* Must _not_ be empty for 2.4+ peers. */
char session_name[LTTNG_NAME_MAX];
char hostname[LTTNG_HOST_NAME_MAX];
char base_path[LTTNG_PATH_MAX];
char session_name[LTTNG_NAME_MAX];
char hostname[LTTNG_HOST_NAME_MAX];
char base_path[LTTNG_PATH_MAX];
+ /*
+ * Session output path relative to relayd's output path.
+ * Will be empty when interacting with peers < 2.11 since their
+ * streams' path are expressed relative to the relay daemon's
+ * output path.
+ */
+ char output_path[LTTNG_PATH_MAX];
uint32_t live_timer;
/* Session in snapshot mode. */
uint32_t live_timer;
/* Session in snapshot mode. */
@@
-87,6
+95,10
@@
struct relay_session {
*/
bool aborted;
*/
bool aborted;
+ bool session_name_contains_creation_time;
+ /* Whether session has performed an explicit rotation. */
+ bool has_rotated;
+
/* Contains ctf_trace object of that session indexed by path name. */
struct lttng_ht *ctf_traces_ht;
/* Contains ctf_trace object of that session indexed by path name. */
struct lttng_ht *ctf_traces_ht;
@@
-122,6
+134,11
@@
struct relay_session {
struct cds_list_head viewer_session_node;
struct lttng_trace_chunk *current_trace_chunk;
struct lttng_trace_chunk *pending_closure_trace_chunk;
struct cds_list_head viewer_session_node;
struct lttng_trace_chunk *current_trace_chunk;
struct lttng_trace_chunk *pending_closure_trace_chunk;
+ /*
+ * Prevent live viewers from taking of copy of the chunk
+ * while new chunk has a temporary directory name.
+ */
+ bool ongoing_rotation;
struct rcu_head rcu_node; /* For call_rcu teardown. */
};
struct rcu_head rcu_node; /* For call_rcu teardown. */
};
@@
-134,7
+151,8
@@
struct relay_session *session_create(const char *session_name,
const uint64_t *current_chunk_id,
const time_t *creation_time,
uint32_t major,
const uint64_t *current_chunk_id,
const time_t *creation_time,
uint32_t major,
- uint32_t minor);
+ uint32_t minor,
+ bool session_name_contains_creation_timestamp);
struct relay_session *session_get_by_id(uint64_t id);
bool session_get(struct relay_session *session);
void session_put(struct relay_session *session);
struct relay_session *session_get_by_id(uint64_t id);
bool session_get(struct relay_session *session);
void session_put(struct relay_session *session);
@@
-142,6
+160,9
@@
void session_put(struct relay_session *session);
int session_close(struct relay_session *session);
int session_abort(struct relay_session *session);
int session_close(struct relay_session *session);
int session_abort(struct relay_session *session);
+struct lttng_directory_handle *session_create_output_directory_handle(
+ struct relay_session *session);
+
void print_sessions(void);
#endif /* _SESSION_H */
void print_sessions(void);
#endif /* _SESSION_H */
This page took
0.025122 seconds
and
5
git commands to generate.