| /* |
| * Copyright (C) 2020 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/prelude/table_functions/experimental_sched_upid.h" |
| |
| namespace perfetto { |
| namespace trace_processor { |
| namespace tables { |
| #define PERFETTO_TP_SCHED_UPID_TABLE_DEF(NAME, PARENT, C) \ |
| NAME(ExperimentalSchedUpidTable, "experimental_sched_upid") \ |
| PARENT(PERFETTO_TP_SCHED_SLICE_TABLE_DEF, C) \ |
| C(std::optional<UniquePid>, upid) |
| |
| PERFETTO_TP_TABLE(PERFETTO_TP_SCHED_UPID_TABLE_DEF); |
| |
| ExperimentalSchedUpidTable::~ExperimentalSchedUpidTable() = default; |
| } // namespace tables |
| |
| ExperimentalSchedUpid::ExperimentalSchedUpid( |
| const tables::SchedSliceTable& sched, |
| const tables::ThreadTable& thread) |
| : sched_slice_table_(&sched), thread_table_(&thread) {} |
| ExperimentalSchedUpid::~ExperimentalSchedUpid() = default; |
| |
| Table::Schema ExperimentalSchedUpid::CreateSchema() { |
| return tables::ExperimentalSchedUpidTable::ComputeStaticSchema(); |
| } |
| |
| std::string ExperimentalSchedUpid::TableName() { |
| return tables::ExperimentalSchedUpidTable::Name(); |
| } |
| |
| uint32_t ExperimentalSchedUpid::EstimateRowCount() { |
| return sched_slice_table_->row_count(); |
| } |
| |
| base::Status ExperimentalSchedUpid::ValidateConstraints( |
| const QueryConstraints&) { |
| return base::OkStatus(); |
| } |
| |
| base::Status ExperimentalSchedUpid::ComputeTable( |
| const std::vector<Constraint>&, |
| const std::vector<Order>&, |
| const BitVector&, |
| std::unique_ptr<Table>& table_return) { |
| if (!sched_upid_table_) { |
| sched_upid_table_ = tables::ExperimentalSchedUpidTable::ExtendParent( |
| *sched_slice_table_, ComputeUpidColumn()); |
| } |
| table_return.reset(new Table(sched_upid_table_->Copy())); |
| return base::OkStatus(); |
| } |
| |
| ColumnStorage<std::optional<UniquePid>> |
| ExperimentalSchedUpid::ComputeUpidColumn() { |
| ColumnStorage<std::optional<UniquePid>> upid; |
| for (uint32_t i = 0; i < sched_slice_table_->row_count(); ++i) { |
| upid.Append(thread_table_->upid()[sched_slice_table_->utid()[i]]); |
| } |
| return upid; |
| } |
| |
| } // namespace trace_processor |
| } // namespace perfetto |