| /* |
| * 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 |