ExternalVendorCode/genode
1
0
Fork 0
mirror of https://github.com/genodelabs/genode.git synced 2025-05-25 19:54:26 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

test/trace: use for_each_new_entry

Browse Source 
genodelabs/genode#4434
This commit is contained in:
Johannes Schlatow 2022-02-22 11:26:49 +01:00 committed by Norman Feske
parent c763890f04
commit f4d0f1624a
1 changed files with 12 additions and 18 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

30
repos/os/src/test/trace/main.cc
View File

@ -20,6 +20,7 @@
#include <base/component.h> #include <base/component.h>
#include <base/heap.h> #include <base/heap.h>
#include <base/sleep.h> #include <base/sleep.h>
#include <trace/trace_buffer.h>
using namespace Genode; using namespace Genode;
@ -68,8 +69,8 @@ class Trace_buffer_monitor
char _buf[MAX_ENTRY_BUF]; char _buf[MAX_ENTRY_BUF];
Region_map &_rm; Region_map &_rm;
Trace::Subject_id _id; Trace::Subject_id _id;
Trace::Buffer *_buffer; Trace::Buffer *_buffer_raw;
Trace::Buffer::Entry _curr_entry; Trace_buffer _buffer;
const char *_terminate_entry(Trace::Buffer::Entry const &entry) const char *_terminate_entry(Trace::Buffer::Entry const &entry)
{ {
@ -85,37 +86,30 @@ class Trace_buffer_monitor
Trace::Subject_id id, Trace::Subject_id id,
Dataspace_capability ds_cap) Dataspace_capability ds_cap)
: :
_rm(rm), _id(id), _buffer(rm.attach(ds_cap)), _rm(rm), _id(id), _buffer_raw(rm.attach(ds_cap)),
_curr_entry(_buffer->first()) _buffer(*_buffer_raw)
{ {
log("monitor " log("monitor "
"subject:", _id.id, " " "subject:", _id.id, " "
"buffer:", Hex((addr_t)_buffer)); "buffer:", Hex((addr_t)_buffer_raw));
} }
~Trace_buffer_monitor() ~Trace_buffer_monitor()
{ {
if (_buffer) { _rm.detach(_buffer); } if (_buffer_raw) { _rm.detach(_buffer_raw); }
} }
Trace::Subject_id id() { return _id; }; Trace::Subject_id id() { return _id; };
void dump() void dump()
{ {
log("overflows: ", _buffer->wrapped());
log("read all remaining events"); log("read all remaining events");
_buffer.for_each_new_entry([&] (Trace::Buffer::Entry &entry) {
for (; !_curr_entry.head(); _curr_entry = _buffer->next(_curr_entry)) { char const * const data = _terminate_entry(entry);
if (_curr_entry.last())
_curr_entry = _buffer->first();
/* omit empty entries */
if (_curr_entry.empty())
continue;
char const * const data = _terminate_entry(_curr_entry);
if (data) { log(data); } if (data) { log(data); }
}
return true;
});
} }
}; };