blob: 55b3f43f24caea1a05652335d809b2a77e043b92 (
plain)
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
|
// Copyright 2021 The Pigweed Authors
//
// 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
//
// https://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 "pw_trace_tokenized/trace_rpc_service_nanopb.h"
#include "pw_log/log.h"
#include "pw_preprocessor/util.h"
#include "pw_trace_tokenized/trace_buffer.h"
#include "pw_trace_tokenized/trace_tokenized.h"
namespace pw::trace {
pw::Status TraceService::Enable(const pw_trace_TraceEnableMessage& request,
pw_trace_TraceEnableMessage& response) {
TokenizedTrace::Instance().Enable(request.enable);
response.enable = TokenizedTrace::Instance().IsEnabled();
return PW_STATUS_OK;
}
pw::Status TraceService::IsEnabled(const pw_trace_Empty&,
pw_trace_TraceEnableMessage& response) {
response.enable = TokenizedTrace::Instance().IsEnabled();
return PW_STATUS_OK;
}
void TraceService::GetTraceData(
const pw_trace_Empty&, ServerWriter<pw_trace_TraceDataMessage>& writer) {
pw_trace_TraceDataMessage buffer = pw_trace_TraceDataMessage_init_default;
size_t size = 0;
pw::ring_buffer::PrefixedEntryRingBuffer* trace_buffer =
pw::trace::GetBuffer();
while (trace_buffer->PeekFront(
std::as_writable_bytes(std::span(buffer.data.bytes)), &size) !=
pw::Status::OutOfRange()) {
trace_buffer->PopFront()
.IgnoreError(); // TODO(pwbug/387): Handle Status properly
buffer.data.size = size;
pw::Status status = writer.Write(buffer);
if (!status.ok()) {
PW_LOG_ERROR("Error sending trace; abandoning trace dump. Error: %s",
status.str());
break;
}
}
writer.Finish().IgnoreError(); // TODO(pwbug/387): Handle Status properly
}
} // namespace pw::trace
|
