Merge "Merge "Add shard ID to statsd atom for procstats collection" into rvc-dev am: b0f26f32d8 am: ddd439cf9e" into rvc-d1-dev-plus-aosp
This commit is contained in:
committed by
Android (Google) Code Review
commit
0370e42b1f
@@ -6131,6 +6131,10 @@ message ProcessStatsAvailablePagesProto {
|
||||
*/
|
||||
message ProcStats {
|
||||
optional ProcessStatsSectionProto proc_stats_section = 1;
|
||||
// Data pulled from device into this is sometimes sharded across multiple atoms to work around
|
||||
// a size limit. When this happens, this shard ID will contain an increasing 1-indexed integer
|
||||
// with the number of this shard.
|
||||
optional int32 shard_id = 2;
|
||||
}
|
||||
|
||||
/**
|
||||
|
||||
@@ -2575,11 +2575,17 @@ public class StatsPullAtomService extends SystemService {
|
||||
lastHighWaterMark, section, true, statsFiles, procStats);
|
||||
procStats.dumpAggregatedProtoForStatsd(protoStreams, MAX_PROCSTATS_RAW_SHARD_SIZE);
|
||||
|
||||
for (ProtoOutputStream proto : protoStreams) {
|
||||
if (proto.getBytes().length > 0) {
|
||||
for (int i = 0; i < protoStreams.length; i++) {
|
||||
byte[] bytes = protoStreams[i].getBytes(); // cache the value
|
||||
if (bytes.length > 0) {
|
||||
StatsEvent e = StatsEvent.newBuilder()
|
||||
.setAtomId(atomTag)
|
||||
.writeByteArray(proto.getBytes())
|
||||
.writeByteArray(bytes)
|
||||
// This is a shard ID, and is specified in the metric definition to be
|
||||
// a dimension. This will result in statsd using RANDOM_ONE_SAMPLE to
|
||||
// keep all the shards, as it thinks each shard is a different dimension
|
||||
// of data.
|
||||
.writeInt(i)
|
||||
.build();
|
||||
pulledData.add(e);
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user