Lines Matching refs:protoOutput
122 ProtoOutputStream* protoOutput) { in writeDimensionToProtoHelper() argument
137 uint64_t token = protoOutput->start(FIELD_TYPE_MESSAGE | FIELD_COUNT_REPEATED | in writeDimensionToProtoHelper()
139 protoOutput->write(FIELD_TYPE_INT32 | DIMENSIONS_VALUE_FIELD, fieldNum); in writeDimensionToProtoHelper()
145 protoOutput->write(FIELD_TYPE_INT32 | DIMENSIONS_VALUE_VALUE_INT, in writeDimensionToProtoHelper()
149 protoOutput->write(FIELD_TYPE_INT64 | DIMENSIONS_VALUE_VALUE_LONG, in writeDimensionToProtoHelper()
153 protoOutput->write(FIELD_TYPE_FLOAT | DIMENSIONS_VALUE_VALUE_FLOAT, in writeDimensionToProtoHelper()
158 protoOutput->write(FIELD_TYPE_STRING | DIMENSIONS_VALUE_VALUE_STR, in writeDimensionToProtoHelper()
162 protoOutput->write(FIELD_TYPE_UINT64 | DIMENSIONS_VALUE_VALUE_STR_HASH, in writeDimensionToProtoHelper()
170 protoOutput->end(token); in writeDimensionToProtoHelper()
175 uint64_t dimensionToken = protoOutput->start(FIELD_TYPE_MESSAGE | FIELD_COUNT_REPEATED | in writeDimensionToProtoHelper()
177 protoOutput->write(FIELD_TYPE_INT32 | DIMENSIONS_VALUE_FIELD, fieldNum); in writeDimensionToProtoHelper()
179 protoOutput->start(FIELD_TYPE_MESSAGE | DIMENSIONS_VALUE_VALUE_TUPLE); in writeDimensionToProtoHelper()
182 protoOutput); in writeDimensionToProtoHelper()
183 protoOutput->end(tupleToken); in writeDimensionToProtoHelper()
184 protoOutput->end(dimensionToken); in writeDimensionToProtoHelper()
196 ProtoOutputStream* protoOutput) { in writeDimensionLeafToProtoHelper() argument
209 uint64_t token = protoOutput->start(FIELD_TYPE_MESSAGE | FIELD_COUNT_REPEATED | in writeDimensionLeafToProtoHelper()
216 protoOutput->write(FIELD_TYPE_INT32 | DIMENSIONS_VALUE_VALUE_INT, in writeDimensionLeafToProtoHelper()
220 protoOutput->write(FIELD_TYPE_INT64 | DIMENSIONS_VALUE_VALUE_LONG, in writeDimensionLeafToProtoHelper()
224 protoOutput->write(FIELD_TYPE_FLOAT | DIMENSIONS_VALUE_VALUE_FLOAT, in writeDimensionLeafToProtoHelper()
229 protoOutput->write(FIELD_TYPE_STRING | DIMENSIONS_VALUE_VALUE_STR, in writeDimensionLeafToProtoHelper()
233 protoOutput->write(FIELD_TYPE_UINT64 | DIMENSIONS_VALUE_VALUE_STR_HASH, in writeDimensionLeafToProtoHelper()
241 protoOutput->end(token); in writeDimensionLeafToProtoHelper()
247 protoOutput); in writeDimensionLeafToProtoHelper()
257 ProtoOutputStream* protoOutput) { in writeDimensionPathToProtoHelper() argument
270 uint64_t token = protoOutput->start(FIELD_TYPE_MESSAGE | FIELD_COUNT_REPEATED | in writeDimensionPathToProtoHelper()
272 protoOutput->write(FIELD_TYPE_INT32 | DIMENSIONS_VALUE_FIELD, fieldNum); in writeDimensionPathToProtoHelper()
274 protoOutput->end(token); in writeDimensionPathToProtoHelper()
279 uint64_t dimensionToken = protoOutput->start( in writeDimensionPathToProtoHelper()
281 protoOutput->write(FIELD_TYPE_INT32 | DIMENSIONS_VALUE_FIELD, fieldNum); in writeDimensionPathToProtoHelper()
283 protoOutput->start(FIELD_TYPE_MESSAGE | DIMENSIONS_VALUE_VALUE_TUPLE); in writeDimensionPathToProtoHelper()
285 field.getPrefix(valueDepth), protoOutput); in writeDimensionPathToProtoHelper()
286 protoOutput->end(tupleToken); in writeDimensionPathToProtoHelper()
287 protoOutput->end(dimensionToken); in writeDimensionPathToProtoHelper()
299 ProtoOutputStream* protoOutput) { in writeDimensionToProto() argument
303 protoOutput->write(FIELD_TYPE_INT32 | DIMENSIONS_VALUE_FIELD, in writeDimensionToProto()
305 uint64_t topToken = protoOutput->start(FIELD_TYPE_MESSAGE | DIMENSIONS_VALUE_VALUE_TUPLE); in writeDimensionToProto()
308 protoOutput); in writeDimensionToProto()
309 protoOutput->end(topToken); in writeDimensionToProto()
315 std::set<int32_t>& usedUids, ProtoOutputStream* protoOutput) { in writeDimensionLeafNodesToProto() argument
321 0, 0, str_set, usedUids, protoOutput); in writeDimensionLeafNodesToProto()
325 ProtoOutputStream* protoOutput) { in writeDimensionPathToProto() argument
329 protoOutput->write(FIELD_TYPE_INT32 | DIMENSIONS_VALUE_FIELD, in writeDimensionPathToProto()
331 uint64_t topToken = protoOutput->start(FIELD_TYPE_MESSAGE | DIMENSIONS_VALUE_VALUE_TUPLE); in writeDimensionPathToProto()
333 writeDimensionPathToProtoHelper(fieldMatchers, &index, 0, 0, protoOutput); in writeDimensionPathToProto()
334 protoOutput->end(topToken); in writeDimensionPathToProto()
366 ProtoOutputStream* protoOutput) { in writeFieldValueTreeToStreamHelper() argument
387 protoOutput->write(FIELD_TYPE_INT32 | repeatedFieldMask | fieldNum, in writeFieldValueTreeToStreamHelper()
391 protoOutput->write(FIELD_TYPE_INT64 | repeatedFieldMask | fieldNum, in writeFieldValueTreeToStreamHelper()
395 protoOutput->write(FIELD_TYPE_FLOAT | repeatedFieldMask | fieldNum, in writeFieldValueTreeToStreamHelper()
399 protoOutput->write(FIELD_TYPE_STRING | repeatedFieldMask | fieldNum, in writeFieldValueTreeToStreamHelper()
404 protoOutput->write(FIELD_TYPE_MESSAGE | fieldNum, in writeFieldValueTreeToStreamHelper()
415 msg_token = protoOutput->start(FIELD_TYPE_MESSAGE | FIELD_COUNT_REPEATED | fieldNum); in writeFieldValueTreeToStreamHelper()
420 protoOutput); in writeFieldValueTreeToStreamHelper()
422 protoOutput->end(msg_token); in writeFieldValueTreeToStreamHelper()
433 util::ProtoOutputStream* protoOutput) { in writeFieldValueTreeToStream() argument
434 uint64_t atomToken = protoOutput->start(FIELD_TYPE_MESSAGE | tagId); in writeFieldValueTreeToStream()
438 protoOutput); in writeFieldValueTreeToStream()
439 protoOutput->end(atomToken); in writeFieldValueTreeToStream()
442 void writeStateToProto(const FieldValue& state, util::ProtoOutputStream* protoOutput) { in writeStateToProto() argument
443 protoOutput->write(FIELD_TYPE_INT32 | STATE_VALUE_ATOM_ID, state.mField.getTag()); in writeStateToProto()
447 protoOutput->write(FIELD_TYPE_INT32 | STATE_VALUE_CONTENTS_VALUE, in writeStateToProto()
451 protoOutput->write(FIELD_TYPE_INT64 | STATE_VALUE_CONTENTS_GROUP_ID, in writeStateToProto()
499 util::ProtoOutputStream* protoOutput) { in writeNonZeroStatToStream() argument
501 protoOutput->write(fieldId, value); in writeNonZeroStatToStream()
506 util::ProtoOutputStream* protoOutput) { in writePullerStatsToStream() argument
507 uint64_t token = protoOutput->start(FIELD_TYPE_MESSAGE | FIELD_ID_PULLED_ATOM_STATS | in writePullerStatsToStream()
509 protoOutput->write(FIELD_TYPE_INT32 | FIELD_ID_PULL_ATOM_ID, (int32_t)pair.first); in writePullerStatsToStream()
510 protoOutput->write(FIELD_TYPE_INT64 | FIELD_ID_TOTAL_PULL, (long long)pair.second.totalPull); in writePullerStatsToStream()
511 protoOutput->write(FIELD_TYPE_INT64 | FIELD_ID_TOTAL_PULL_FROM_CACHE, in writePullerStatsToStream()
513 protoOutput->write(FIELD_TYPE_INT64 | FIELD_ID_MIN_PULL_INTERVAL_SEC, in writePullerStatsToStream()
515 protoOutput->write(FIELD_TYPE_INT64 | FIELD_ID_AVERAGE_PULL_TIME_NANOS, in writePullerStatsToStream()
517 protoOutput->write(FIELD_TYPE_INT64 | FIELD_ID_MAX_PULL_TIME_NANOS, in writePullerStatsToStream()
519 protoOutput->write(FIELD_TYPE_INT64 | FIELD_ID_AVERAGE_PULL_DELAY_NANOS, in writePullerStatsToStream()
521 protoOutput->write(FIELD_TYPE_INT64 | FIELD_ID_MAX_PULL_DELAY_NANOS, in writePullerStatsToStream()
523 protoOutput->write(FIELD_TYPE_INT64 | FIELD_ID_DATA_ERROR, (long long)pair.second.dataError); in writePullerStatsToStream()
524 protoOutput->write(FIELD_TYPE_INT64 | FIELD_ID_PULL_TIMEOUT, in writePullerStatsToStream()
526 protoOutput->write(FIELD_TYPE_INT64 | FIELD_ID_PULL_EXCEED_MAX_DELAY, in writePullerStatsToStream()
528 protoOutput->write(FIELD_TYPE_INT64 | FIELD_ID_PULL_FAILED, (long long)pair.second.pullFailed); in writePullerStatsToStream()
529 protoOutput->write(FIELD_TYPE_INT64 | FIELD_ID_EMPTY_DATA, (long long)pair.second.emptyData); in writePullerStatsToStream()
530 protoOutput->write(FIELD_TYPE_INT64 | FIELD_ID_PULL_REGISTERED_COUNT, in writePullerStatsToStream()
532 protoOutput->write(FIELD_TYPE_INT64 | FIELD_ID_PULL_UNREGISTERED_COUNT, in writePullerStatsToStream()
534 protoOutput->write(FIELD_TYPE_INT32 | FIELD_ID_ATOM_ERROR_COUNT, pair.second.atomErrorCount); in writePullerStatsToStream()
535 protoOutput->write(FIELD_TYPE_INT64 | FIELD_ID_BINDER_CALL_FAIL_COUNT, in writePullerStatsToStream()
537 protoOutput->write(FIELD_TYPE_INT64 | FIELD_ID_PULL_UID_PROVIDER_NOT_FOUND, in writePullerStatsToStream()
539 protoOutput->write(FIELD_TYPE_INT64 | FIELD_ID_PULLER_NOT_FOUND, in writePullerStatsToStream()
542 uint64_t timeoutMetadataToken = protoOutput->start(FIELD_TYPE_MESSAGE | in writePullerStatsToStream()
545 protoOutput->write(FIELD_TYPE_INT64 | FIELD_ID_PULL_TIMEOUT_METADATA_UPTIME_MILLIS, in writePullerStatsToStream()
547 protoOutput->write(FIELD_TYPE_INT64 | FIELD_ID_PULL_TIMEOUT_METADATA_ELAPSED_MILLIS, in writePullerStatsToStream()
549 protoOutput->end(timeoutMetadataToken); in writePullerStatsToStream()
552 pair.second.subscriptionPullCount, protoOutput); in writePullerStatsToStream()
553 protoOutput->end(token); in writePullerStatsToStream()
557 util::ProtoOutputStream *protoOutput) { in writeAtomMetricStatsToStream() argument
558 uint64_t token = protoOutput->start(FIELD_TYPE_MESSAGE | FIELD_ID_ATOM_METRIC_STATS | in writeAtomMetricStatsToStream()
562 protoOutput); in writeAtomMetricStatsToStream()
564 (long long)pair.second.hardDimensionLimitReached, protoOutput); in writeAtomMetricStatsToStream()
566 (long long)pair.second.lateLogEventSkipped, protoOutput); in writeAtomMetricStatsToStream()
568 (long long)pair.second.skippedForwardBuckets, protoOutput); in writeAtomMetricStatsToStream()
570 (long long)pair.second.badValueType, protoOutput); in writeAtomMetricStatsToStream()
572 (long long)pair.second.conditionChangeInNextBucket, protoOutput); in writeAtomMetricStatsToStream()
574 (long long)pair.second.invalidatedBucket, protoOutput); in writeAtomMetricStatsToStream()
576 (long long)pair.second.bucketDropped, protoOutput); in writeAtomMetricStatsToStream()
578 (long long)pair.second.minBucketBoundaryDelayNs, protoOutput); in writeAtomMetricStatsToStream()
580 (long long)pair.second.maxBucketBoundaryDelayNs, protoOutput); in writeAtomMetricStatsToStream()
582 (long long)pair.second.bucketUnknownCondition, protoOutput); in writeAtomMetricStatsToStream()
584 (long long)pair.second.bucketCount, protoOutput); in writeAtomMetricStatsToStream()
585 protoOutput->end(token); in writeAtomMetricStatsToStream()