[dns] slice summary tracks

Author: LalitMaganti

ui/src/plugins/dev.perfetto.ProcessSummary/index.ts

@@ -30,10 +30,10 @@ import {
   ProcessSchedulingTrack,
 } from './process_scheduling_track';
 import {
-  Config as ProcessSummaryTrackConfig,
-  PROCESS_SUMMARY_TRACK_KIND,
-  ProcessSummaryTrack,
-} from './process_summary_track';
+  Config as SliceTrackSummaryConfig,
+  SLICE_TRACK_SUMMARY_KIND,
+  SliceTrackSummary,
+} from './slice_track_summary';
 
 // This plugin is responsible for adding summary tracks for process and thread
 // groups.
@@ -55,12 +55,12 @@ export default class implements PerfettoPlugin {
       name: `__process_scheduling_${uuidv4Sql()}`,
       on: `__intrinsic_sched_slice(utid)`,
     });
-    // Makes the queries in `ProcessSummaryTrack` significantly faster.
+    // Makes the queries in `SliceTrackSummary` significantly faster.
     // TODO(lalitm): figure out a better way to do this without hardcoding this
     // here.
     await createPerfettoIndex({
       engine: ctx.engine,
-      name: `__process_summary_${uuidv4Sql()}`,
+      name: `__slice_track_summary_${uuidv4Sql()}`,
       on: `__intrinsic_slice(track_id)`,
     });
 
@@ -188,7 +188,7 @@ export default class implements PerfettoPlugin {
           subtitle,
         });
       } else {
-        const config: ProcessSummaryTrackConfig = {
+        const config: SliceTrackSummaryConfig = {
           pidForColor,
           upid,
           utid,
@@ -197,10 +197,10 @@ export default class implements PerfettoPlugin {
         ctx.tracks.registerTrack({
           uri,
           tags: {
-            kinds: [PROCESS_SUMMARY_TRACK_KIND],
+            kinds: [SLICE_TRACK_SUMMARY_KIND],
           },
           chips,
-          renderer: new ProcessSummaryTrack(ctx.engine, config),
+          renderer: new SliceTrackSummary(ctx, uri, config),
           subtitle,
         });
       }
@@ -246,7 +246,7 @@ export default class implements PerfettoPlugin {
       return;
     }
 
-    const config: ProcessSummaryTrackConfig = {
+    const config: SliceTrackSummaryConfig = {
       pidForColor: 2,
       upid: it.upid,
       utid: it.utid,
@@ -255,9 +255,9 @@ export default class implements PerfettoPlugin {
     ctx.tracks.registerTrack({
       uri: '/kernel',
       tags: {
-        kinds: [PROCESS_SUMMARY_TRACK_KIND],
+        kinds: [SLICE_TRACK_SUMMARY_KIND],
       },
-      renderer: new ProcessSummaryTrack(ctx.engine, config),
+      renderer: new SliceTrackSummary(ctx, '/kernel', config),
     });
   }
 }

ui/src/plugins/dev.perfetto.ProcessSummary/process_summary_track.ts

@@ -0,0 +1,92 @@
+// Copyright (C) 2025 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.
+
+import {BaseCounterTrack} from '../../components/tracks/base_counter_track';
+import {Trace} from '../../public/trace';
+import {createUnionDataset, Dataset} from '../../trace_processor/dataset';
+import {LONG} from '../../trace_processor/query_result';
+
+export const SLICE_TRACK_SUMMARY_KIND = 'SliceTrackSummary';
+
+export interface Config {
+  pidForColor: number | bigint;
+  upid: number | null;
+  utid: number | null;
+}
+
+export class SliceTrackSummary extends BaseCounterTrack {
+  constructor(trace: Trace, uri: string, _config: Config) {
+    super(trace, uri);
+  }
+
+  async onInit() {
+    // Include the intervals module
+    await this.engine.query('INCLUDE PERFETTO MODULE intervals.overlap');
+  }
+
+  getSqlSource(): string {
+    // Get the TrackNode for this track
+    const trackNode = this.trace.workspaces.currentWorkspace.getTrackByUri(
+      this.uri,
+    );
+    if (trackNode === undefined) {
+      // If we can't find our track node, return empty query
+      return 'select cast(0 as bigint) as ts, cast(0 as real) as value where 0';
+    }
+
+    // Get all child track datasets
+    const childDatasets: Dataset[] = [];
+    for (const child of trackNode.children) {
+      if (child.uri === undefined) continue;
+
+      const childTrack = this.trace.tracks.getTrack(child.uri);
+      if (childTrack === undefined) continue;
+
+      const dataset = childTrack.renderer.getDataset?.();
+      if (dataset !== undefined) {
+        childDatasets.push(dataset);
+      }
+    }
+
+    // If no child datasets, return empty query
+    if (childDatasets.length === 0) {
+      return 'select cast(0 as bigint) as ts, cast(0 as real) as value where 0';
+    }
+
+    // Create a union of all child datasets
+    const unionDataset = createUnionDataset(childDatasets).optimize();
+
+    // Check if the union dataset implements the required schema (ts and dur columns)
+    const requiredSchema = {ts: LONG, dur: LONG};
+    if (!unionDataset.implements(requiredSchema)) {
+      // Dataset doesn't have ts/dur, can't create summary
+      return 'select cast(0 as bigint) as ts, cast(0 as real) as value where 0';
+    }
+
+    // Use intervals_overlap_count to compute the number of active intervals
+    // across all child tracks at any point in time
+    return `
+      select ts, cast(value as real) as value
+      from intervals_overlap_count!(
+        (
+          select ts, dur
+          from (${unionDataset.query()})
+          where dur != -1
+        ),
+        ts,
+        dur
+      )
+    `;
+  }
+}