1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
|
/*
* Copyright (C) 2019 The Android Open Source Project
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
#include "perfetto/tracing/event_context.h"
#include "perfetto/tracing/internal/track_event_interned_fields.h"
#include "protos/perfetto/trace/interned_data/interned_data.pbzero.h"
#include "protos/perfetto/trace/track_event/track_event.pbzero.h"
namespace perfetto {
EventContext::EventContext(
EventContext::TracePacketHandle trace_packet,
internal::TrackEventIncrementalState* incremental_state,
const internal::TrackEventTlsState* tls_state)
: trace_packet_(std::move(trace_packet)),
event_(trace_packet_->set_track_event()),
incremental_state_(incremental_state),
tls_state_(tls_state) {}
EventContext::~EventContext() {
if (!trace_packet_)
return;
// When the track event is finalized (i.e., the context is destroyed), we
// should flush any newly seen interned data to the trace. The data has
// earlier been written to a heap allocated protobuf message
// (|serialized_interned_data|). Here we just need to flush it to the main
// trace.
auto& serialized_interned_data = incremental_state_->serialized_interned_data;
if (PERFETTO_LIKELY(serialized_interned_data.empty()))
return;
auto ranges = serialized_interned_data.GetRanges();
trace_packet_->AppendScatteredBytes(
perfetto::protos::pbzero::TracePacket::kInternedDataFieldNumber,
&ranges[0], ranges.size());
// Reset the message but keep one buffer allocated for future use.
serialized_interned_data.Reset();
}
protos::pbzero::DebugAnnotation* EventContext::AddDebugAnnotation(
const char* name) {
auto annotation = event()->add_debug_annotations();
annotation->set_name_iid(
internal::InternedDebugAnnotationName::Get(this, name));
return annotation;
}
} // namespace perfetto
|
