diff options
Diffstat (limited to 'pw_trace_tokenized/trace_rpc_service_nanopb.cc')
| -rw-r--r-- | pw_trace_tokenized/trace_rpc_service_nanopb.cc | 63 |
1 files changed, 63 insertions, 0 deletions
diff --git a/pw_trace_tokenized/trace_rpc_service_nanopb.cc b/pw_trace_tokenized/trace_rpc_service_nanopb.cc new file mode 100644 index 000000000..a6893da1f --- /dev/null +++ b/pw_trace_tokenized/trace_rpc_service_nanopb.cc @@ -0,0 +1,63 @@ +// 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(ServerContext&, + 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(ServerContext&, + const pw_trace_Empty&, + pw_trace_TraceEnableMessage& response) { + response.enable = TokenizedTrace::Instance().IsEnabled(); + return PW_STATUS_OK; +} + +void TraceService::GetTraceData( + ServerContext&, + 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(); + 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(); +} +} // namespace pw::trace
\ No newline at end of file |