Searched refs:protoStreams (Results 1 – 2 of 2) sorted by relevance
2357 public void dumpAggregatedProtoForStatsd(ProtoOutputStream[] protoStreams, in dumpAggregatedProtoForStatsd() argument2360 dumpProtoPreamble(protoStreams[shardIndex]); in dumpAggregatedProtoForStatsd()2369 if (protoStreams[shardIndex].getRawSize() > maxRawShardSizeBytes) { in dumpAggregatedProtoForStatsd()2371 if (shardIndex >= protoStreams.length) { in dumpAggregatedProtoForStatsd()2377 dumpProtoPreamble(protoStreams[shardIndex]); in dumpAggregatedProtoForStatsd()2384 procState.dumpAggregatedProtoForStatsd(protoStreams[shardIndex], in dumpAggregatedProtoForStatsd()2392 protoStreams[i].flush(); in dumpAggregatedProtoForStatsd()
3043 ProtoOutputStream[] protoStreams = new ProtoOutputStream[MAX_PROCSTATS_SHARDS];3044 for (int i = 0; i < protoStreams.length; i++) {3045 protoStreams[i] = new ProtoOutputStream();3047 procStats.dumpAggregatedProtoForStatsd(protoStreams, MAX_PROCSTATS_RAW_SHARD_SIZE);3048 for (int i = 0; i < protoStreams.length; i++) {3049 byte[] bytes = protoStreams[i].getBytes(); // cache the value