X-Git-Url: https://git.lttng.org/?p=lttng-tools.git;a=blobdiff_plain;f=src%2Fbin%2Flttng-relayd%2Fctf-trace.hpp;fp=src%2Fbin%2Flttng-relayd%2Fctf-trace.hpp;h=dbf7d3fa21166d533507550f02261e41b26e887e;hp=0000000000000000000000000000000000000000;hb=c9e313bc594f40a86eed237dce222c0fc99c957f;hpb=4878de5c7deb512bbdac4fdfc498907efa06fb7c diff --git a/src/bin/lttng-relayd/ctf-trace.hpp b/src/bin/lttng-relayd/ctf-trace.hpp new file mode 100644 index 000000000..dbf7d3fa2 --- /dev/null +++ b/src/bin/lttng-relayd/ctf-trace.hpp @@ -0,0 +1,67 @@ +#ifndef _CTF_TRACE_H +#define _CTF_TRACE_H + +/* + * Copyright (C) 2013 Julien Desfossez + * Copyright (C) 2013 David Goulet + * Copyright (C) 2015 Mathieu Desnoyers + * + * SPDX-License-Identifier: GPL-2.0-only + * + */ + +#include +#include + +#include + +#include "session.hpp" +#include "stream.hpp" +#include "viewer-stream.hpp" + +struct ctf_trace { + struct urcu_ref ref; /* Every stream has a ref on the trace. */ + struct relay_session *session; /* Back ref to trace session */ + + /* Trace sub-folder relative to the session output path. */ + char *path; + + /* + * The ctf_trace lock nests inside the session lock. + */ + pthread_mutex_t lock; + uint64_t id; + struct relay_viewer_stream *viewer_metadata_stream; /* RCU protected */ + + /* + * Relay streams associated with this ctf trace. + * Updates are protected by the stream_list lock. + * Traversals are protected by RCU. + */ + struct cds_list_head stream_list; + pthread_mutex_t stream_list_lock; + + /* + * Node within session trace hash table. Node is indexed by + * stream path name. + */ + struct lttng_ht_node_str node; + struct rcu_head rcu_node; /* For call_rcu teardown. */ + + /* + * True if the metadata stream of this trace was sent the viewer in the + * past. + */ + bool metadata_stream_sent_to_viewer; +}; + +struct ctf_trace *ctf_trace_get_by_path_or_create(struct relay_session *session, + const char *subpath); +bool ctf_trace_get(struct ctf_trace *trace); +void ctf_trace_put(struct ctf_trace *trace); + +int ctf_trace_close(struct ctf_trace *trace); + +struct relay_viewer_stream *ctf_trace_get_viewer_metadata_stream(struct ctf_trace *trace); + +#endif /* _CTF_TRACE_H */