Lines Matching refs:protoOutput
107 ProtoOutputStream* protoOutput) { in writeDimensionToProtoHelper() argument
120 uint64_t token = protoOutput->start(FIELD_TYPE_MESSAGE | FIELD_COUNT_REPEATED | in writeDimensionToProtoHelper()
122 protoOutput->write(FIELD_TYPE_INT32 | DIMENSIONS_VALUE_FIELD, fieldNum); in writeDimensionToProtoHelper()
125 protoOutput->write(FIELD_TYPE_INT32 | DIMENSIONS_VALUE_VALUE_INT, in writeDimensionToProtoHelper()
129 protoOutput->write(FIELD_TYPE_INT64 | DIMENSIONS_VALUE_VALUE_LONG, in writeDimensionToProtoHelper()
133 protoOutput->write(FIELD_TYPE_FLOAT | DIMENSIONS_VALUE_VALUE_FLOAT, in writeDimensionToProtoHelper()
138 protoOutput->write(FIELD_TYPE_STRING | DIMENSIONS_VALUE_VALUE_STR, in writeDimensionToProtoHelper()
142 protoOutput->write( in writeDimensionToProtoHelper()
151 protoOutput->end(token); in writeDimensionToProtoHelper()
156 uint64_t dimensionToken = protoOutput->start( in writeDimensionToProtoHelper()
158 protoOutput->write(FIELD_TYPE_INT32 | DIMENSIONS_VALUE_FIELD, fieldNum); in writeDimensionToProtoHelper()
160 protoOutput->start(FIELD_TYPE_MESSAGE | DIMENSIONS_VALUE_VALUE_TUPLE); in writeDimensionToProtoHelper()
162 str_set, protoOutput); in writeDimensionToProtoHelper()
163 protoOutput->end(tupleToken); in writeDimensionToProtoHelper()
164 protoOutput->end(dimensionToken); in writeDimensionToProtoHelper()
176 ProtoOutputStream* protoOutput) { in writeDimensionLeafToProtoHelper() argument
188 uint64_t token = protoOutput->start(FIELD_TYPE_MESSAGE | FIELD_COUNT_REPEATED | in writeDimensionLeafToProtoHelper()
192 protoOutput->write(FIELD_TYPE_INT32 | DIMENSIONS_VALUE_VALUE_INT, in writeDimensionLeafToProtoHelper()
196 protoOutput->write(FIELD_TYPE_INT64 | DIMENSIONS_VALUE_VALUE_LONG, in writeDimensionLeafToProtoHelper()
200 protoOutput->write(FIELD_TYPE_FLOAT | DIMENSIONS_VALUE_VALUE_FLOAT, in writeDimensionLeafToProtoHelper()
205 protoOutput->write(FIELD_TYPE_STRING | DIMENSIONS_VALUE_VALUE_STR, in writeDimensionLeafToProtoHelper()
209 protoOutput->write( in writeDimensionLeafToProtoHelper()
218 protoOutput->end(token); in writeDimensionLeafToProtoHelper()
224 str_set, protoOutput); in writeDimensionLeafToProtoHelper()
234 ProtoOutputStream* protoOutput) { in writeDimensionPathToProtoHelper() argument
247 uint64_t token = protoOutput->start(FIELD_TYPE_MESSAGE | FIELD_COUNT_REPEATED | in writeDimensionPathToProtoHelper()
249 protoOutput->write(FIELD_TYPE_INT32 | DIMENSIONS_VALUE_FIELD, fieldNum); in writeDimensionPathToProtoHelper()
251 protoOutput->end(token); in writeDimensionPathToProtoHelper()
256 uint64_t dimensionToken = protoOutput->start( in writeDimensionPathToProtoHelper()
258 protoOutput->write(FIELD_TYPE_INT32 | DIMENSIONS_VALUE_FIELD, fieldNum); in writeDimensionPathToProtoHelper()
260 protoOutput->start(FIELD_TYPE_MESSAGE | DIMENSIONS_VALUE_VALUE_TUPLE); in writeDimensionPathToProtoHelper()
262 field.getPrefix(valueDepth), protoOutput); in writeDimensionPathToProtoHelper()
263 protoOutput->end(tupleToken); in writeDimensionPathToProtoHelper()
264 protoOutput->end(dimensionToken); in writeDimensionPathToProtoHelper()
275 ProtoOutputStream* protoOutput) { in writeDimensionToProto() argument
279 protoOutput->write(FIELD_TYPE_INT32 | DIMENSIONS_VALUE_FIELD, in writeDimensionToProto()
281 uint64_t topToken = protoOutput->start(FIELD_TYPE_MESSAGE | DIMENSIONS_VALUE_VALUE_TUPLE); in writeDimensionToProto()
283 writeDimensionToProtoHelper(dimension.getValues(), &index, 0, 0, str_set, protoOutput); in writeDimensionToProto()
284 protoOutput->end(topToken); in writeDimensionToProto()
290 ProtoOutputStream* protoOutput) { in writeDimensionLeafNodesToProto() argument
296 &index, 0, 0, str_set, protoOutput); in writeDimensionLeafNodesToProto()
300 ProtoOutputStream* protoOutput) { in writeDimensionPathToProto() argument
304 protoOutput->write(FIELD_TYPE_INT32 | DIMENSIONS_VALUE_FIELD, in writeDimensionPathToProto()
306 uint64_t topToken = protoOutput->start(FIELD_TYPE_MESSAGE | DIMENSIONS_VALUE_VALUE_TUPLE); in writeDimensionPathToProto()
308 writeDimensionPathToProtoHelper(fieldMatchers, &index, 0, 0, protoOutput); in writeDimensionPathToProto()
309 protoOutput->end(topToken); in writeDimensionPathToProto()
340 ProtoOutputStream* protoOutput) { in writeFieldValueTreeToStreamHelper() argument
355 protoOutput->write(FIELD_TYPE_INT32 | fieldNum, dim.mValue.int_value); in writeFieldValueTreeToStreamHelper()
358 protoOutput->write(FIELD_TYPE_INT64 | fieldNum, in writeFieldValueTreeToStreamHelper()
362 protoOutput->write(FIELD_TYPE_FLOAT | fieldNum, dim.mValue.float_value); in writeFieldValueTreeToStreamHelper()
365 protoOutput->write(FIELD_TYPE_STRING | fieldNum, dim.mValue.str_value); in writeFieldValueTreeToStreamHelper()
369 protoOutput->write(FIELD_TYPE_MESSAGE | fieldNum, in writeFieldValueTreeToStreamHelper()
382 protoOutput->start(FIELD_TYPE_MESSAGE | FIELD_COUNT_REPEATED | fieldNum); in writeFieldValueTreeToStreamHelper()
384 msg_token = protoOutput->start(FIELD_TYPE_MESSAGE | fieldNum); in writeFieldValueTreeToStreamHelper()
389 dim.mField.getPrefix(valueDepth), protoOutput); in writeFieldValueTreeToStreamHelper()
391 protoOutput->end(msg_token); in writeFieldValueTreeToStreamHelper()
401 util::ProtoOutputStream* protoOutput) { in writeFieldValueTreeToStream() argument
402 uint64_t atomToken = protoOutput->start(FIELD_TYPE_MESSAGE | tagId); in writeFieldValueTreeToStream()
405 writeFieldValueTreeToStreamHelper(tagId, values, &index, 0, 0, protoOutput); in writeFieldValueTreeToStream()
406 protoOutput->end(atomToken); in writeFieldValueTreeToStream()
409 void writeStateToProto(const FieldValue& state, util::ProtoOutputStream* protoOutput) { in writeStateToProto() argument
410 protoOutput->write(FIELD_TYPE_INT32 | STATE_VALUE_ATOM_ID, state.mField.getTag()); in writeStateToProto()
414 protoOutput->write(FIELD_TYPE_INT32 | STATE_VALUE_CONTENTS_VALUE, in writeStateToProto()
418 protoOutput->write(FIELD_TYPE_INT64 | STATE_VALUE_CONTENTS_GROUP_ID, in writeStateToProto()
466 util::ProtoOutputStream* protoOutput) { in writeNonZeroStatToStream() argument
468 protoOutput->write(fieldId, value); in writeNonZeroStatToStream()
473 util::ProtoOutputStream* protoOutput) { in writePullerStatsToStream() argument
474 uint64_t token = protoOutput->start(FIELD_TYPE_MESSAGE | FIELD_ID_PULLED_ATOM_STATS | in writePullerStatsToStream()
476 protoOutput->write(FIELD_TYPE_INT32 | FIELD_ID_PULL_ATOM_ID, (int32_t)pair.first); in writePullerStatsToStream()
477 protoOutput->write(FIELD_TYPE_INT64 | FIELD_ID_TOTAL_PULL, (long long)pair.second.totalPull); in writePullerStatsToStream()
478 protoOutput->write(FIELD_TYPE_INT64 | FIELD_ID_TOTAL_PULL_FROM_CACHE, in writePullerStatsToStream()
480 protoOutput->write(FIELD_TYPE_INT64 | FIELD_ID_MIN_PULL_INTERVAL_SEC, in writePullerStatsToStream()
482 protoOutput->write(FIELD_TYPE_INT64 | FIELD_ID_AVERAGE_PULL_TIME_NANOS, in writePullerStatsToStream()
484 protoOutput->write(FIELD_TYPE_INT64 | FIELD_ID_MAX_PULL_TIME_NANOS, in writePullerStatsToStream()
486 protoOutput->write(FIELD_TYPE_INT64 | FIELD_ID_AVERAGE_PULL_DELAY_NANOS, in writePullerStatsToStream()
488 protoOutput->write(FIELD_TYPE_INT64 | FIELD_ID_MAX_PULL_DELAY_NANOS, in writePullerStatsToStream()
490 protoOutput->write(FIELD_TYPE_INT64 | FIELD_ID_DATA_ERROR, (long long)pair.second.dataError); in writePullerStatsToStream()
491 protoOutput->write(FIELD_TYPE_INT64 | FIELD_ID_PULL_TIMEOUT, in writePullerStatsToStream()
493 protoOutput->write(FIELD_TYPE_INT64 | FIELD_ID_PULL_EXCEED_MAX_DELAY, in writePullerStatsToStream()
495 protoOutput->write(FIELD_TYPE_INT64 | FIELD_ID_PULL_FAILED, (long long)pair.second.pullFailed); in writePullerStatsToStream()
496 protoOutput->write(FIELD_TYPE_INT64 | FIELD_ID_EMPTY_DATA, (long long)pair.second.emptyData); in writePullerStatsToStream()
497 protoOutput->write(FIELD_TYPE_INT64 | FIELD_ID_PULL_REGISTERED_COUNT, in writePullerStatsToStream()
499 protoOutput->write(FIELD_TYPE_INT64 | FIELD_ID_PULL_UNREGISTERED_COUNT, in writePullerStatsToStream()
501 protoOutput->write(FIELD_TYPE_INT32 | FIELD_ID_ATOM_ERROR_COUNT, pair.second.atomErrorCount); in writePullerStatsToStream()
502 protoOutput->write(FIELD_TYPE_INT64 | FIELD_ID_BINDER_CALL_FAIL_COUNT, in writePullerStatsToStream()
504 protoOutput->write(FIELD_TYPE_INT64 | FIELD_ID_PULL_UID_PROVIDER_NOT_FOUND, in writePullerStatsToStream()
506 protoOutput->write(FIELD_TYPE_INT64 | FIELD_ID_PULLER_NOT_FOUND, in writePullerStatsToStream()
509 uint64_t timeoutMetadataToken = protoOutput->start(FIELD_TYPE_MESSAGE | in writePullerStatsToStream()
512 protoOutput->write(FIELD_TYPE_INT64 | FIELD_ID_PULL_TIMEOUT_METADATA_UPTIME_MILLIS, in writePullerStatsToStream()
514 protoOutput->write(FIELD_TYPE_INT64 | FIELD_ID_PULL_TIMEOUT_METADATA_ELAPSED_MILLIS, in writePullerStatsToStream()
516 protoOutput->end(timeoutMetadataToken); in writePullerStatsToStream()
518 protoOutput->end(token); in writePullerStatsToStream()
522 util::ProtoOutputStream *protoOutput) { in writeAtomMetricStatsToStream() argument
523 uint64_t token = protoOutput->start(FIELD_TYPE_MESSAGE | FIELD_ID_ATOM_METRIC_STATS | in writeAtomMetricStatsToStream()
527 protoOutput); in writeAtomMetricStatsToStream()
529 (long long)pair.second.hardDimensionLimitReached, protoOutput); in writeAtomMetricStatsToStream()
531 (long long)pair.second.lateLogEventSkipped, protoOutput); in writeAtomMetricStatsToStream()
533 (long long)pair.second.skippedForwardBuckets, protoOutput); in writeAtomMetricStatsToStream()
535 (long long)pair.second.badValueType, protoOutput); in writeAtomMetricStatsToStream()
537 (long long)pair.second.conditionChangeInNextBucket, protoOutput); in writeAtomMetricStatsToStream()
539 (long long)pair.second.invalidatedBucket, protoOutput); in writeAtomMetricStatsToStream()
541 (long long)pair.second.bucketDropped, protoOutput); in writeAtomMetricStatsToStream()
543 (long long)pair.second.minBucketBoundaryDelayNs, protoOutput); in writeAtomMetricStatsToStream()
545 (long long)pair.second.maxBucketBoundaryDelayNs, protoOutput); in writeAtomMetricStatsToStream()
547 (long long)pair.second.bucketUnknownCondition, protoOutput); in writeAtomMetricStatsToStream()
549 (long long)pair.second.bucketCount, protoOutput); in writeAtomMetricStatsToStream()
550 protoOutput->end(token); in writeAtomMetricStatsToStream()