Home
last modified time | relevance | path

Searched refs:trainInfo (Results 1 – 7 of 7) sorted by relevance

/packages/modules/StatsD/statsd/tests/storage/
DStorageManager_test.cpp41 InstallTrainInfo trainInfo; in TEST() local
42 trainInfo.trainVersionCode = 12345; in TEST()
43 trainInfo.trainName = "This is a train name #)$(&&$"; in TEST()
44 trainInfo.status = 1; in TEST()
46 trainInfo.experimentIds.assign(expIds, expIds + strlen(expIds)); in TEST()
50 result = StorageManager::writeTrainInfo(trainInfo); in TEST()
55 result = StorageManager::readTrainInfo(trainInfo.trainName, trainInfoResult); in TEST()
58 EXPECT_EQ(trainInfo.trainVersionCode, trainInfoResult.trainVersionCode); in TEST()
59 ASSERT_EQ(trainInfo.trainName.size(), trainInfoResult.trainName.size()); in TEST()
60 EXPECT_EQ(trainInfo.trainName, trainInfoResult.trainName); in TEST()
[all …]
/packages/modules/StatsD/statsd/src/storage/
DStorageManager.cpp158 bool StorageManager::writeTrainInfo(const InstallTrainInfo& trainInfo) { in writeTrainInfo() argument
161 if (trainInfo.trainName.empty()) { in writeTrainInfo()
164 deleteSuffixedFiles(TRAIN_INFO_DIR, trainInfo.trainName.c_str()); in writeTrainInfo()
168 trainInfo.trainName.c_str()); in writeTrainInfo()
186 const size_t trainVersionCodeByteCount = sizeof(trainInfo.trainVersionCode); in writeTrainInfo()
187 result = write(fd, &trainInfo.trainVersionCode, trainVersionCodeByteCount); in writeTrainInfo()
195 const size_t trainNameSize = trainInfo.trainName.size(); in writeTrainInfo()
205 result = write(fd, trainInfo.trainName.c_str(), trainNameSize); in writeTrainInfo()
213 const size_t statusByteCount = sizeof(trainInfo.status); in writeTrainInfo()
214 result = write(fd, (uint8_t*)&trainInfo.status, statusByteCount); in writeTrainInfo()
[all …]
DStorageManager.h68 static bool writeTrainInfo(const InstallTrainInfo& trainInfo);
73 static bool readTrainInfo(const std::string& trainName, InstallTrainInfo& trainInfo);
78 static bool readTrainInfoLocked(const std::string& trainName, InstallTrainInfo& trainInfo);
/packages/modules/StatsD/statsd/src/
DStatsLogProcessor.cpp196 InstallTrainInfo trainInfo; in onBinaryPushStateChangedEventLocked() local
197 trainInfo.trainName = string(event->GetString(1 /*train name field id*/, &err)); in onBinaryPushStateChangedEventLocked()
198 trainInfo.trainVersionCode = event->GetLong(2 /*train version field id*/, &err); in onBinaryPushStateChangedEventLocked()
199 trainInfo.requiresStaging = event->GetBool(3 /*requires staging field id*/, &err); in onBinaryPushStateChangedEventLocked()
200 trainInfo.rollbackEnabled = event->GetBool(4 /*rollback enabled field id*/, &err); in onBinaryPushStateChangedEventLocked()
201 trainInfo.requiresLowLatencyMonitor = in onBinaryPushStateChangedEventLocked()
203 trainInfo.status = int32_t(event->GetLong(6 /*state field id*/, &err)); in onBinaryPushStateChangedEventLocked()
218 trainInfo.experimentIds = {trainExperimentIds.experiment_id().begin(), in onBinaryPushStateChangedEventLocked()
222 getAndUpdateTrainInfoOnDisk(is_rollback, &trainInfo); in onBinaryPushStateChangedEventLocked()
225 writeExperimentIdsToProto(trainInfo.experimentIds, &trainExperimentIdProto); in onBinaryPushStateChangedEventLocked()
[all …]
DStatsService.cpp1426 for (InstallTrainInfo& trainInfo : trainInfoList) { in getRegisteredExperimentIds()
1428 trainInfo.experimentIds.begin(), in getRegisteredExperimentIds()
1429 trainInfo.experimentIds.end()); in getRegisteredExperimentIds()
/packages/modules/StatsD/statsd/src/external/
DTrainInfoPuller.cpp46 for (InstallTrainInfo& trainInfo : trainInfoList) { in PullInternal()
47 auto event = make_shared<LogEvent>(getWallClockNs(), getElapsedRealtimeNs(), trainInfo); in PullInternal()
/packages/modules/StatsD/statsd/src/logd/
DLogEvent.cpp81 const InstallTrainInfo& trainInfo) { in LogEvent() argument
87 FieldValue(Field(mTagId, getSimpleField(1)), Value(trainInfo.trainVersionCode))); in LogEvent()
89 writeExperimentIdsToProto(trainInfo.experimentIds, &experimentIdsProto); in LogEvent()
91 mValues.push_back(FieldValue(Field(mTagId, getSimpleField(3)), Value(trainInfo.trainName))); in LogEvent()
92 mValues.push_back(FieldValue(Field(mTagId, getSimpleField(4)), Value(trainInfo.status))); in LogEvent()