blob: 36facd63db918b48962a9585a92a9ac331452083 [file] [log] [blame]
/*
* 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 "src/trace_processor/db/column.h"
#include "src/trace_processor/db/column_storage.h"
#include "src/trace_processor/tables/py_tables_unittest_py.h"
#include "test/gtest_and_gmock.h"
namespace perfetto {
namespace trace_processor {
namespace tables {
TestEventTable::~TestEventTable() = default;
TestEventChildTable::~TestEventChildTable() = default;
TestSliceTable::~TestSliceTable() = default;
TestArgsTable::~TestArgsTable() = default;
namespace {
class PyTablesUnittest : public ::testing::Test {
protected:
StringPool pool_;
TestEventTable event_{&pool_};
TestEventChildTable event_child_{&pool_, &event_};
TestSliceTable slice_{&pool_, &event_};
TestArgsTable args_{&pool_};
};
TEST_F(PyTablesUnittest, EventTableProprties) {
ASSERT_STREQ(TestEventTable::Name(), "event");
ASSERT_EQ(TestEventTable::ColumnIndex::id, 0u);
ASSERT_EQ(TestEventTable::ColumnIndex::type, 1u);
ASSERT_EQ(TestEventTable::ColumnIndex::ts, 2u);
ASSERT_EQ(TestEventTable::ColumnIndex::arg_set_id, 3u);
ASSERT_EQ(TestEventTable::ColumnFlag::ts,
Column::Flag::kSorted | Column::Flag::kNonNull);
ASSERT_EQ(TestEventTable::ColumnFlag::arg_set_id, Column::Flag::kNonNull);
}
TEST_F(PyTablesUnittest, ArgsTableProprties) {
ASSERT_STREQ(TestArgsTable::Name(), "args");
ASSERT_EQ(TestArgsTable::ColumnIndex::id, 0u);
ASSERT_EQ(TestArgsTable::ColumnIndex::type, 1u);
ASSERT_EQ(TestArgsTable::ColumnIndex::arg_set_id, 2u);
ASSERT_EQ(TestArgsTable::ColumnFlag::arg_set_id, Column::Flag::kSorted |
Column::Flag::kSetId |
Column::Flag::kNonNull);
}
TEST_F(PyTablesUnittest, InsertEvent) {
event_.Insert(TestEventTable::Row(100, 0));
ASSERT_EQ(event_.type().GetString(0).ToStdString(), "event");
ASSERT_EQ(event_.ts()[0], 100);
ASSERT_EQ(event_.arg_set_id()[0], 0u);
}
TEST_F(PyTablesUnittest, InsertEventSpecifyCols) {
TestEventTable::Row row;
row.ts = 100;
row.arg_set_id = 0;
event_.Insert(row);
ASSERT_EQ(event_.type().GetString(0).ToStdString(), "event");
ASSERT_EQ(event_.ts()[0], 100);
ASSERT_EQ(event_.arg_set_id()[0], 0u);
}
TEST_F(PyTablesUnittest, MutableColumn) {
event_.Insert(TestEventTable::Row(100, 0));
ASSERT_EQ((*event_.mutable_ts())[0], 100);
ASSERT_EQ((*event_.mutable_arg_set_id())[0], 0u);
}
TEST_F(PyTablesUnittest, ShrinkToFit) {
event_.Insert(TestEventTable::Row(100, 0));
event_.ShrinkToFit();
// Unfortunately given the loose restrictions on shrink_to_fit provided by the
// standard library, we cannot really assert anything. Just call the method to
// ensure it doesn't cause crashes.
}
TEST_F(PyTablesUnittest, FindById) {
auto id_and_row = event_.Insert(TestEventTable::Row(100, 0));
auto row_ref = event_.FindById(id_and_row.id);
ASSERT_EQ(row_ref->ToRowNumber().row_number(), id_and_row.row);
ASSERT_EQ(row_ref->id(), id_and_row.id);
ASSERT_EQ(row_ref->ts(), 100);
ASSERT_EQ(row_ref->arg_set_id(), 0u);
}
TEST_F(PyTablesUnittest, ChildFindById) {
event_.Insert(TestEventTable::Row(50, 0));
auto id_and_row = slice_.Insert(TestSliceTable::Row(100, 0, 10));
auto row_ref = slice_.FindById(id_and_row.id);
ASSERT_EQ(row_ref->ToRowNumber().row_number(), id_and_row.row);
ASSERT_EQ(row_ref->id(), id_and_row.id);
ASSERT_EQ(row_ref->ts(), 100);
ASSERT_EQ(row_ref->arg_set_id(), 0u);
ASSERT_EQ(row_ref->dur(), 10u);
}
TEST_F(PyTablesUnittest, ChildTableStatics) {
ASSERT_EQ(TestSliceTable::ColumnFlag::dur, Column::Flag::kNonNull);
ASSERT_EQ(TestSliceTable::ColumnIndex::id, 0u);
ASSERT_EQ(TestSliceTable::ColumnIndex::type, 1u);
ASSERT_EQ(TestSliceTable::ColumnIndex::ts, 2u);
ASSERT_EQ(TestSliceTable::ColumnIndex::arg_set_id, 3u);
ASSERT_EQ(TestSliceTable::ColumnIndex::dur, 4u);
}
TEST_F(PyTablesUnittest, ParentAndChildInsert) {
event_.Insert(TestEventTable::Row(50, 0));
slice_.Insert(TestSliceTable::Row(100, 1, 10));
event_.Insert(TestEventTable::Row(150, 2));
slice_.Insert(TestSliceTable::Row(200, 3, 20));
ASSERT_EQ(event_.row_count(), 4u);
ASSERT_EQ(event_.id()[0], TestEventTable::Id{0});
ASSERT_EQ(event_.type().GetString(0), "event");
ASSERT_EQ(event_.ts()[0], 50);
ASSERT_EQ(event_.id()[1], TestEventTable::Id{1});
ASSERT_EQ(event_.type().GetString(1), "slice");
ASSERT_EQ(event_.ts()[1], 100);
ASSERT_EQ(event_.id()[2], TestEventTable::Id{2});
ASSERT_EQ(event_.type().GetString(2), "event");
ASSERT_EQ(event_.ts()[2], 150);
ASSERT_EQ(event_.id()[3], TestEventTable::Id{3});
ASSERT_EQ(event_.type().GetString(3), "slice");
ASSERT_EQ(event_.ts()[3], 200);
ASSERT_EQ(slice_.row_count(), 2u);
ASSERT_EQ(slice_.id()[0], TestEventTable::Id{1});
ASSERT_EQ(slice_.type().GetString(0), "slice");
ASSERT_EQ(slice_.ts()[0], 100);
ASSERT_EQ(slice_.dur()[0], 10);
ASSERT_EQ(slice_.id()[1], TestEventTable::Id{3});
ASSERT_EQ(slice_.type().GetString(1), "slice");
ASSERT_EQ(slice_.ts()[1], 200);
ASSERT_EQ(slice_.dur()[1], 20);
}
TEST_F(PyTablesUnittest, Extend) {
event_.Insert(TestEventTable::Row(50, 0));
event_.Insert(TestEventTable::Row(100, 1));
event_.Insert(TestEventTable::Row(150, 2));
ColumnStorage<int64_t> dur;
dur.Append(512);
dur.Append(1024);
dur.Append(2048);
auto slice_ext = TestSliceTable::ExtendParent(event_, std::move(dur));
ASSERT_EQ(slice_ext->row_count(), 3u);
ASSERT_EQ(
slice_ext->columns()[TestSliceTable::ColumnIndex::ts].Get(0).AsLong(),
50);
ASSERT_EQ(
slice_ext->columns()[TestSliceTable::ColumnIndex::dur].Get(0).AsLong(),
512);
ASSERT_EQ(
slice_ext->columns()[TestSliceTable::ColumnIndex::ts].Get(1).AsLong(),
100);
ASSERT_EQ(
slice_ext->columns()[TestSliceTable::ColumnIndex::dur].Get(1).AsLong(),
1024);
ASSERT_EQ(
slice_ext->columns()[TestSliceTable::ColumnIndex::ts].Get(2).AsLong(),
150);
ASSERT_EQ(
slice_ext->columns()[TestSliceTable::ColumnIndex::dur].Get(2).AsLong(),
2048);
}
TEST_F(PyTablesUnittest, SelectAndExtend) {
event_.Insert(TestEventTable::Row(50, 0));
event_.Insert(TestEventTable::Row(100, 1));
event_.Insert(TestEventTable::Row(150, 2));
std::vector<TestEventTable::RowNumber> rows;
rows.emplace_back(TestEventTable::RowNumber(1));
ColumnStorage<int64_t> dur;
dur.Append(1024);
auto slice_ext = TestSliceTable::SelectAndExtendParent(
event_, std::move(rows), std::move(dur));
ASSERT_EQ(slice_ext->row_count(), 1u);
ASSERT_EQ(
slice_ext->columns()[TestSliceTable::ColumnIndex::ts].Get(0).AsLong(),
100);
ASSERT_EQ(
slice_ext->columns()[TestSliceTable::ColumnIndex::dur].Get(0).AsLong(),
1024);
}
TEST_F(PyTablesUnittest, SetIdColumns) {
StringPool pool;
TestArgsTable table{&pool};
table.Insert(TestArgsTable::Row(0, 100));
table.Insert(TestArgsTable::Row(0, 200));
table.Insert(TestArgsTable::Row(2, 200));
table.Insert(TestArgsTable::Row(3, 300));
table.Insert(TestArgsTable::Row(4, 200));
table.Insert(TestArgsTable::Row(4, 500));
table.Insert(TestArgsTable::Row(4, 900));
table.Insert(TestArgsTable::Row(4, 200));
table.Insert(TestArgsTable::Row(8, 400));
ASSERT_EQ(table.row_count(), 9u);
ASSERT_TRUE(table.arg_set_id().IsSetId());
// Verify that not-present ids are not returned.
{
static constexpr uint32_t kFilterArgSetId = 1;
auto res = table.Filter({table.arg_set_id().eq(kFilterArgSetId)});
ASSERT_EQ(res.row_count(), 0u);
}
{
static constexpr uint32_t kFilterArgSetId = 9;
auto res = table.Filter({table.arg_set_id().eq(kFilterArgSetId)});
ASSERT_EQ(res.row_count(), 0u);
}
// Verify that kSetId flag is correctly removed after filtering/sorting.
{
static constexpr uint32_t kFilterArgSetId = 3;
auto res = table.Filter({table.arg_set_id().eq(kFilterArgSetId)});
ASSERT_EQ(res.row_count(), 1u);
ASSERT_FALSE(res.GetColumnByName("arg_set_id")->IsSetId());
}
{
auto res = table.Sort({table.type().descending()});
ASSERT_FALSE(res.GetColumnByName("arg_set_id")->IsSetId());
}
uint32_t arg_set_id_col_idx =
static_cast<uint32_t>(TestArgsTable::ColumnIndex::arg_set_id);
// Verify that filtering equality for real arg set ids works as expected.
{
static constexpr uint32_t kFilterArgSetId = 4;
auto res = table.Filter({table.arg_set_id().eq(kFilterArgSetId)});
ASSERT_EQ(res.row_count(), 4u);
for (auto it = res.IterateRows(); it; it.Next()) {
uint32_t arg_set_id =
static_cast<uint32_t>(it.Get(arg_set_id_col_idx).AsLong());
ASSERT_EQ(arg_set_id, kFilterArgSetId);
}
}
{
static constexpr uint32_t kFilterArgSetId = 0;
auto res = table.Filter({table.arg_set_id().eq(kFilterArgSetId)});
ASSERT_EQ(res.row_count(), 2u);
for (auto it = res.IterateRows(); it; it.Next()) {
uint32_t arg_set_id =
static_cast<uint32_t>(it.Get(arg_set_id_col_idx).AsLong());
ASSERT_EQ(arg_set_id, kFilterArgSetId);
}
}
{
static constexpr uint32_t kFilterArgSetId = 8;
auto res = table.Filter({table.arg_set_id().eq(kFilterArgSetId)});
ASSERT_EQ(res.row_count(), 1u);
for (auto it = res.IterateRows(); it; it.Next()) {
uint32_t arg_set_id =
static_cast<uint32_t>(it.Get(arg_set_id_col_idx).AsLong());
ASSERT_EQ(arg_set_id, kFilterArgSetId);
}
}
// Verify that filtering equality for arg set ids after filtering another
// column works.
{
static constexpr uint32_t kFilterArgSetId = 4;
auto res = table.Filter(
{table.int_value().eq(200), table.arg_set_id().eq(kFilterArgSetId)});
ASSERT_EQ(res.row_count(), 2u);
for (auto it = res.IterateRows(); it; it.Next()) {
uint32_t arg_set_id =
static_cast<uint32_t>(it.Get(arg_set_id_col_idx).AsLong());
ASSERT_EQ(arg_set_id, kFilterArgSetId);
}
}
}
} // namespace
} // namespace tables
} // namespace trace_processor
} // namespace perfetto