15#ifdef USE_TRACING_INSTRUMENTATION_LTTNG
18#undef TRACEPOINT_PROVIDER
19#define TRACEPOINT_PROVIDER tor_cc
21#undef TRACEPOINT_INCLUDE
22#define TRACEPOINT_INCLUDE "./src/core/or/lttng_cc.inc"
24#if !defined(LTTNG_CC_INC) || defined(TRACEPOINT_HEADER_MULTI_READ)
27#include <lttng/tracepoint.h>
34TRACEPOINT_EVENT(tor_cc, flow_decide_xon,
37 ctf_integer(uint64_t, stream_id,
TO_CONN(stream)->global_identifier)
38 ctf_integer(
size_t, written_bytes, n_written)
39 ctf_integer(uint32_t, drained_bytes_current, stream->drained_bytes)
40 ctf_integer(uint32_t, drained_bytes_previous, stream->prev_drained_bytes)
41 ctf_integer(uint32_t, ewma_drain_rate_last, stream->ewma_rate_last_sent)
42 ctf_integer(uint32_t, ewma_drain_rate_current, stream->ewma_drain_rate)
43 ctf_integer(
size_t, outbuf_len,
44 connection_get_outbuf_len(
TO_CONN(stream)))
49TRACEPOINT_EVENT(tor_cc, flow_decide_xon_drain_start,
52 ctf_integer(uint64_t, stream_id,
TO_CONN(stream)->global_identifier)
53 ctf_integer(uint32_t, drained_bytes_current, stream->drained_bytes)
54 ctf_integer(uint32_t, drained_bytes_previous, stream->prev_drained_bytes)
55 ctf_integer(uint32_t, ewma_drain_rate_last, stream->ewma_rate_last_sent)
56 ctf_integer(uint32_t, ewma_drain_rate_current, stream->ewma_drain_rate)
57 ctf_integer(
size_t, outbuf_len,
58 connection_get_outbuf_len(
TO_CONN(stream)))
64TRACEPOINT_EVENT(tor_cc, flow_decide_xon_drain_update,
67 ctf_integer(uint64_t, stream_id,
TO_CONN(stream)->global_identifier)
68 ctf_integer(uint32_t, drained_bytes_current, stream->drained_bytes)
69 ctf_integer(uint32_t, drained_bytes_previous, stream->prev_drained_bytes)
70 ctf_integer(uint32_t, new_drain_rate, drain_rate)
71 ctf_integer(uint32_t, ewma_drain_rate_last, stream->ewma_rate_last_sent)
72 ctf_integer(uint32_t, ewma_drain_rate_current, stream->ewma_drain_rate)
73 ctf_integer(
size_t, outbuf_len,
74 connection_get_outbuf_len(
TO_CONN(stream)))
79TRACEPOINT_EVENT(tor_cc, flow_decide_xon_rate_change,
82 ctf_integer(uint64_t, stream_id,
TO_CONN(stream)->global_identifier)
83 ctf_integer(uint32_t, drained_bytes_current, stream->drained_bytes)
84 ctf_integer(uint32_t, drained_bytes_previous, stream->prev_drained_bytes)
85 ctf_integer(uint32_t, ewma_drain_rate_last, stream->ewma_rate_last_sent)
86 ctf_integer(uint32_t, ewma_drain_rate_current, stream->ewma_drain_rate)
87 ctf_integer(
size_t, outbuf_len,
88 connection_get_outbuf_len(
TO_CONN(stream)))
94TRACEPOINT_EVENT(tor_cc, flow_decide_xon_partial_drain,
97 ctf_integer(uint64_t, stream_id,
TO_CONN(stream)->global_identifier)
98 ctf_integer(uint32_t, drained_bytes_current, stream->drained_bytes)
99 ctf_integer(uint32_t, drained_bytes_previous, stream->prev_drained_bytes)
100 ctf_integer(uint32_t, ewma_drain_rate_last, stream->ewma_rate_last_sent)
101 ctf_integer(uint32_t, ewma_drain_rate_current, stream->ewma_drain_rate)
102 ctf_integer(
size_t, outbuf_len,
103 connection_get_outbuf_len(
TO_CONN(stream)))
109TRACEPOINT_EVENT(tor_cc, flow_decide_xon_drain_doubled,
112 ctf_integer(uint64_t, stream_id,
TO_CONN(stream)->global_identifier)
113 ctf_integer(uint32_t, drained_bytes_current, stream->drained_bytes)
114 ctf_integer(uint32_t, drained_bytes_previous, stream->prev_drained_bytes)
115 ctf_integer(uint32_t, ewma_drain_rate_last, stream->ewma_rate_last_sent)
116 ctf_integer(uint32_t, ewma_drain_rate_current, stream->ewma_drain_rate)
117 ctf_integer(
size_t, outbuf_len,
118 connection_get_outbuf_len(
TO_CONN(stream)))
125TRACEPOINT_EVENT(tor_cc, flow_decide_xoff_sending,
128 ctf_integer(uint64_t, stream_id,
TO_CONN(stream)->global_identifier)
129 ctf_integer(uint32_t, drained_bytes_current, stream->drained_bytes)
130 ctf_integer(uint32_t, drained_bytes_previous, stream->prev_drained_bytes)
131 ctf_integer(uint32_t, ewma_drain_rate_last, stream->ewma_rate_last_sent)
132 ctf_integer(uint32_t, ewma_drain_rate_current, stream->ewma_drain_rate)
133 ctf_integer(
size_t, outbuf_len,
134 connection_get_outbuf_len(
TO_CONN(stream)))
143TRACEPOINT_EVENT(tor_cc, bdp_update,
145 uint64_t, curr_rtt_usec),
147 ctf_integer(uint64_t, circuit_ptr, circ)
148 ctf_integer(uint32_t, n_circ_id, circ->n_circ_id)
149 ctf_integer(uint64_t, min_rtt_usec, cc->min_rtt_usec)
150 ctf_integer(uint64_t, curr_rtt_usec, curr_rtt_usec)
151 ctf_integer(uint64_t, ewma_rtt_usec, cc->ewma_rtt_usec)
152 ctf_integer(uint64_t, max_rtt_usec, cc->max_rtt_usec)
153 ctf_integer(uint64_t, bdp_cwnd_rtt, cc->bdp)
160#include <lttng/tracepoint-event.h>