diff options
Diffstat (limited to 'java/com/google/android/libraries/mobiledatadownload/internal/logging/MddEventLogger.java')
| -rw-r--r-- | java/com/google/android/libraries/mobiledatadownload/internal/logging/MddEventLogger.java | 668 |
1 files changed, 350 insertions, 318 deletions
diff --git a/java/com/google/android/libraries/mobiledatadownload/internal/logging/MddEventLogger.java b/java/com/google/android/libraries/mobiledatadownload/internal/logging/MddEventLogger.java index 620421c..9be820d 100644 --- a/java/com/google/android/libraries/mobiledatadownload/internal/logging/MddEventLogger.java +++ b/java/com/google/android/libraries/mobiledatadownload/internal/logging/MddEventLogger.java @@ -21,6 +21,7 @@ import static com.google.common.util.concurrent.MoreExecutors.directExecutor; import android.content.Context; import android.content.Intent; import android.content.IntentFilter; + import com.google.android.libraries.mobiledatadownload.Flags; import com.google.android.libraries.mobiledatadownload.Logger; import com.google.android.libraries.mobiledatadownload.tracing.PropagatedFluentFuture; @@ -34,10 +35,14 @@ import com.google.mobiledatadownload.LogEnumsProto.MddDownloadResult; import com.google.mobiledatadownload.LogProto.AndroidClientInfo; import com.google.mobiledatadownload.LogProto.DataDownloadFileGroupStats; import com.google.mobiledatadownload.LogProto.MddDeviceInfo; +import com.google.mobiledatadownload.LogProto.MddDownloadLatency; import com.google.mobiledatadownload.LogProto.MddDownloadResultLog; +import com.google.mobiledatadownload.LogProto.MddLibApiResultLog; import com.google.mobiledatadownload.LogProto.MddLogData; +import com.google.mobiledatadownload.LogProto.MddNetworkStats; import com.google.mobiledatadownload.LogProto.MddStorageStats; import com.google.mobiledatadownload.LogProto.StableSamplingInfo; + import java.util.ArrayList; import java.util.Arrays; import java.util.List; @@ -45,327 +50,354 @@ import java.util.List; /** Assembles data and logs them with underlying {@link Logger}. */ public final class MddEventLogger implements EventLogger { - private static final String TAG = "MddEventLogger"; - - private final Context context; - private final Logger logger; - // A process that has mdi download module loaded will get restarted if a new module version is - // installed. - private final int moduleVersion; - private final String hostPackageName; - private final Flags flags; - private final LogSampler logSampler; - - private Optional<LoggingStateStore> loggingStateStore = Optional.absent(); - - public MddEventLogger( - Context context, Logger logger, int moduleVersion, LogSampler logSampler, Flags flags) { - this.context = context; - this.logger = logger; - this.moduleVersion = moduleVersion; - this.hostPackageName = context.getPackageName(); - this.logSampler = logSampler; - this.flags = flags; - } - - /** - * This should be called before MddEventLogger is used. If it is not called before MddEventLogger - * is used, stable sampling will not be used. - * - * <p>Note(rohitsat): this is required because LoggingStateStore is constructed with a PDS in the - * MainMddLibModule. MddEventLogger is required to construct the MainMddLibModule. - * - * @param loggingStateStore the LoggingStateStore that contains the persisted random number for - * stable sampling. - */ - public void setLoggingStateStore(LoggingStateStore loggingStateStore) { - this.loggingStateStore = Optional.of(loggingStateStore); - } - - @Override - public void logEventSampled(MddClientEvent.Code eventCode) { - sampleAndSendLogEvent(eventCode, MddLogData.newBuilder(), flags.mddDefaultSampleInterval()); - } - - @Override - public void logEventSampled( - MddClientEvent.Code eventCode, - String fileGroupName, - int fileGroupVersionNumber, - long buildId, - String variantId) { - - DataDownloadFileGroupStats dataDownloadFileGroupStats = - DataDownloadFileGroupStats.newBuilder() - .setFileGroupName(fileGroupName) - .setFileGroupVersionNumber(fileGroupVersionNumber) - .setBuildId(buildId) - .setVariantId(variantId) - .build(); - - sampleAndSendLogEvent( - eventCode, - MddLogData.newBuilder().setDataDownloadFileGroupStats(dataDownloadFileGroupStats), - flags.mddDefaultSampleInterval()); - } - - @Override - public void logEventAfterSample(MddClientEvent.Code eventCode, int sampleInterval) { - // TODO(b/138392640): delete this method once the pds migration is complete. If it's necessary - // for other use cases, we can establish a pattern where this class is still responsible for - // sampling. - MddLogData.Builder logData = MddLogData.newBuilder(); - processAndSendEventWithoutStableSampling(eventCode, logData, sampleInterval); - } - - @Override - public void logMddApiCallStats(DataDownloadFileGroupStats fileGroupDetails, Void apiCallStats) { - // TODO(b/144684763): update this to use stable sampling. Leaving it as is for now since it is - // fairly high volume. - long sampleInterval = flags.apiLoggingSampleInterval(); - if (!LogUtil.shouldSampleInterval(sampleInterval)) { - return; + private static final String TAG = "MddEventLogger"; + + private final Context context; + private final Logger logger; + // A process that has mdi download module loaded will get restarted if a new module version is + // installed. + private final int moduleVersion; + private final String hostPackageName; + private final Flags flags; + private final LogSampler logSampler; + + private Optional<LoggingStateStore> loggingStateStore = Optional.absent(); + + public MddEventLogger( + Context context, Logger logger, int moduleVersion, LogSampler logSampler, Flags flags) { + this.context = context; + this.logger = logger; + this.moduleVersion = moduleVersion; + this.hostPackageName = context.getPackageName(); + this.logSampler = logSampler; + this.flags = flags; + } + + /** + * This should be called before MddEventLogger is used. If it is not called before + * MddEventLogger + * is used, stable sampling will not be used. + * + * <p>Note(rohitsat): this is required because LoggingStateStore is constructed with a PDS in + * the + * MainMddLibModule. MddEventLogger is required to construct the MainMddLibModule. + * + * @param loggingStateStore the LoggingStateStore that contains the persisted random number for + * stable sampling. + */ + public void setLoggingStateStore(LoggingStateStore loggingStateStore) { + this.loggingStateStore = Optional.of(loggingStateStore); + } + + @Override + public void logEventSampled(MddClientEvent.Code eventCode) { + sampleAndSendLogEvent(eventCode, MddLogData.newBuilder(), flags.mddDefaultSampleInterval()); + } + + @Override + public void logEventSampled( + MddClientEvent.Code eventCode, + String fileGroupName, + int fileGroupVersionNumber, + long buildId, + String variantId) { + + DataDownloadFileGroupStats dataDownloadFileGroupStats = + DataDownloadFileGroupStats.newBuilder() + .setFileGroupName(fileGroupName) + .setFileGroupVersionNumber(fileGroupVersionNumber) + .setBuildId(buildId) + .setVariantId(variantId) + .build(); + + sampleAndSendLogEvent( + eventCode, + MddLogData.newBuilder().setDataDownloadFileGroupStats(dataDownloadFileGroupStats), + flags.mddDefaultSampleInterval()); + } + + @Override + public void logEventAfterSample(MddClientEvent.Code eventCode, int sampleInterval) { + // TODO(b/138392640): delete this method once the pds migration is complete. If it's + // necessary + // for other use cases, we can establish a pattern where this class is still responsible for + // sampling. + MddLogData.Builder logData = MddLogData.newBuilder(); + processAndSendEventWithoutStableSampling(eventCode, logData, sampleInterval); + } + + @Override + public void logMddApiCallStats(DataDownloadFileGroupStats fileGroupDetails, Void apiCallStats) { + // TODO(b/144684763): update this to use stable sampling. Leaving it as is for now since + // it is + // fairly high volume. + long sampleInterval = flags.apiLoggingSampleInterval(); + if (!LogUtil.shouldSampleInterval(sampleInterval)) { + return; + } + MddLogData.Builder logData = + MddLogData.newBuilder().setDataDownloadFileGroupStats(fileGroupDetails); + processAndSendEventWithoutStableSampling( + MddClientEvent.Code.EVENT_CODE_UNSPECIFIED, logData, sampleInterval); + } + + @Override + public void logMddLibApiResultLog(MddLibApiResultLog mddLibApiResultLog) { + MddLogData.Builder logData = MddLogData.newBuilder().setMddLibApiResultLog( + mddLibApiResultLog); + + sampleAndSendLogEvent( + MddClientEvent.Code.DATA_DOWNLOAD_LIB_API_RESULT, + logData, + flags.apiLoggingSampleInterval()); + } + + @Override + public ListenableFuture<Void> logMddFileGroupStats( + AsyncCallable<List<EventLogger.FileGroupStatusWithDetails>> buildFileGroupStats) { + return lazySampleAndSendLogEvent( + MddClientEvent.Code.DATA_DOWNLOAD_FILE_GROUP_STATUS, + () -> + PropagatedFutures.transform( + buildFileGroupStats.call(), + fileGroupStatusAndDetailsList -> { + List<MddLogData> allMddLogData = new ArrayList<>(); + + for (FileGroupStatusWithDetails fileGroupStatusAndDetails : + fileGroupStatusAndDetailsList) { + allMddLogData.add( + MddLogData.newBuilder() + .setMddFileGroupStatus( + fileGroupStatusAndDetails.fileGroupStatus()) + .setDataDownloadFileGroupStats( + fileGroupStatusAndDetails.fileGroupDetails()) + .build()); + } + return allMddLogData; + }, + directExecutor()), + flags.groupStatsLoggingSampleInterval()); + } + + @Override + public ListenableFuture<Void> logMddStorageStats( + AsyncCallable<MddStorageStats> buildStorageStats) { + return lazySampleAndSendLogEvent( + MddClientEvent.Code.DATA_DOWNLOAD_STORAGE_STATS, + () -> + PropagatedFutures.transform( + buildStorageStats.call(), + storageStats -> + Arrays.asList(MddLogData.newBuilder().setMddStorageStats( + storageStats).build()), + directExecutor()), + flags.storageStatsLoggingSampleInterval()); + } + + @Override + public ListenableFuture<Void> logMddNetworkStats( + AsyncCallable<MddNetworkStats> buildNetworkStats) { + return lazySampleAndSendLogEvent( + MddClientEvent.Code.DATA_DOWNLOAD_NETWORK_STATS, + () -> + PropagatedFutures.transform( + buildNetworkStats.call(), + networkStats -> + Arrays.asList(MddLogData.newBuilder().setMddNetworkStats( + networkStats).build()), + directExecutor()), + flags.networkStatsLoggingSampleInterval()); + } + + @Override + public void logMddDataDownloadFileExpirationEvent(int eventCode, int count) { + MddLogData.Builder logData = MddLogData.newBuilder(); + sampleAndSendLogEvent( + MddClientEvent.Code.EVENT_CODE_UNSPECIFIED, logData, + flags.mddDefaultSampleInterval()); + } + + @Override + public void logMddNetworkSavings( + DataDownloadFileGroupStats fileGroupDetails, + int code, + long fullFileSize, + long downloadedFileSize, + String fileId, + int deltaIndex) { + MddLogData.Builder logData = MddLogData.newBuilder(); + + sampleAndSendLogEvent( + MddClientEvent.Code.EVENT_CODE_UNSPECIFIED, logData, + flags.mddDefaultSampleInterval()); + } + + @Override + public void logMddQueryStats(DataDownloadFileGroupStats fileGroupDetails) { + MddLogData.Builder logData = MddLogData.newBuilder(); + + sampleAndSendLogEvent( + MddClientEvent.Code.EVENT_CODE_UNSPECIFIED, logData, + flags.mddDefaultSampleInterval()); + } + + @Override + public void logMddDownloadLatency( + DataDownloadFileGroupStats fileGroupDetails, MddDownloadLatency downloadLatency) { + MddLogData.Builder logData = + MddLogData.newBuilder() + .setMddDownloadLatency(downloadLatency) + .setDataDownloadFileGroupStats(fileGroupDetails); + + sampleAndSendLogEvent( + MddClientEvent.Code.DATA_DOWNLOAD_LATENCY_LOG, logData, + flags.mddDefaultSampleInterval()); + } + + @Override + public void logMddDownloadResult( + MddDownloadResult.Code code, DataDownloadFileGroupStats fileGroupDetails) { + MddLogData.Builder logData = + MddLogData.newBuilder() + .setMddDownloadResultLog( + MddDownloadResultLog.newBuilder() + .setResult(code) + .setDataDownloadFileGroupStats(fileGroupDetails)); + + sampleAndSendLogEvent( + MddClientEvent.Code.DATA_DOWNLOAD_RESULT_LOG, logData, + flags.mddDefaultSampleInterval()); + } + + @Override + public void logMddAndroidSharingLog(Void event) { + // TODO(b/144684763): consider moving this to stable sampling depending on frequency of + // events. + long sampleInterval = flags.mddAndroidSharingSampleInterval(); + if (!LogUtil.shouldSampleInterval(sampleInterval)) { + return; + } + MddLogData.Builder logData = MddLogData.newBuilder(); + processAndSendEventWithoutStableSampling( + MddClientEvent.Code.EVENT_CODE_UNSPECIFIED, logData, sampleInterval); + } + + @Override + public void logMddUsageEvent(DataDownloadFileGroupStats fileGroupDetails, Void usageEventLog) { + MddLogData.Builder logData = + MddLogData.newBuilder().setDataDownloadFileGroupStats(fileGroupDetails); + + sampleAndSendLogEvent( + MddClientEvent.Code.EVENT_CODE_UNSPECIFIED, logData, + flags.mddDefaultSampleInterval()); + } + + @Override + public void logNewConfigReceived( + DataDownloadFileGroupStats fileGroupDetails, Void newConfigReceivedInfo) { + MddLogData.Builder logData = + MddLogData.newBuilder().setDataDownloadFileGroupStats(fileGroupDetails); + sampleAndSendLogEvent( + MddClientEvent.Code.EVENT_CODE_UNSPECIFIED, logData, + flags.mddDefaultSampleInterval()); } - MddLogData.Builder logData = - MddLogData.newBuilder().setDataDownloadFileGroupStats(fileGroupDetails); - processAndSendEventWithoutStableSampling( - MddClientEvent.Code.EVENT_CODE_UNSPECIFIED, logData, sampleInterval); - } - - @Override - public void logMddLibApiResultLog(Void mddLibApiResultLog) { - MddLogData.Builder logData = MddLogData.newBuilder(); - - sampleAndSendLogEvent( - MddClientEvent.Code.EVENT_CODE_UNSPECIFIED, logData, flags.apiLoggingSampleInterval()); - } - - @Override - public ListenableFuture<Void> logMddFileGroupStats( - AsyncCallable<List<EventLogger.FileGroupStatusWithDetails>> buildFileGroupStats) { - return lazySampleAndSendLogEvent( - MddClientEvent.Code.DATA_DOWNLOAD_FILE_GROUP_STATUS, - () -> - PropagatedFutures.transform( - buildFileGroupStats.call(), - fileGroupStatusAndDetailsList -> { - List<MddLogData> allMddLogData = new ArrayList<>(); - - for (FileGroupStatusWithDetails fileGroupStatusAndDetails : - fileGroupStatusAndDetailsList) { - allMddLogData.add( - MddLogData.newBuilder() - .setMddFileGroupStatus(fileGroupStatusAndDetails.fileGroupStatus()) - .setDataDownloadFileGroupStats( - fileGroupStatusAndDetails.fileGroupDetails()) - .build()); - } - return allMddLogData; + + /** + * Determines whether the log event will be a part of the sample, and if so calls {@code + * buildStats} to construct the log event. This is like {@link sampleAndSendLogEvent} but + * constructs the log event lazy. This is useful if constructing the log event is expensive. + */ + private ListenableFuture<Void> lazySampleAndSendLogEvent( + MddClientEvent.Code eventCode, + AsyncCallable<List<MddLogData>> buildStats, + int sampleInterval) { + return PropagatedFutures.transformAsync( + logSampler.shouldLog(sampleInterval, loggingStateStore), + samplingInfoOptional -> { + if (!samplingInfoOptional.isPresent()) { + return immediateVoidFuture(); + } + + return PropagatedFluentFuture.from(buildStats.call()) + .transform( + icingLogDataList -> { + if (icingLogDataList != null) { + for (MddLogData icingLogData : icingLogDataList) { + processAndSendEvent( + eventCode, + icingLogData.toBuilder(), + sampleInterval, + samplingInfoOptional.get()); + } + } + return null; + }, + directExecutor()); }, - directExecutor()), - flags.groupStatsLoggingSampleInterval()); - } - - @Override - public ListenableFuture<Void> logMddStorageStats( - AsyncCallable<MddStorageStats> buildStorageStats) { - return lazySampleAndSendLogEvent( - MddClientEvent.Code.DATA_DOWNLOAD_STORAGE_STATS, - () -> - PropagatedFutures.transform( - buildStorageStats.call(), - storageStats -> - Arrays.asList(MddLogData.newBuilder().setMddStorageStats(storageStats).build()), - directExecutor()), - flags.storageStatsLoggingSampleInterval()); - } - - @Override - public ListenableFuture<Void> logMddNetworkStats(AsyncCallable<Void> buildNetworkStats) { - return lazySampleAndSendLogEvent( - MddClientEvent.Code.EVENT_CODE_UNSPECIFIED, - () -> - PropagatedFutures.transform( - buildNetworkStats.call(), networkStats -> Arrays.asList(), directExecutor()), - flags.networkStatsLoggingSampleInterval()); - } - - @Override - public void logMddDataDownloadFileExpirationEvent(int eventCode, int count) { - MddLogData.Builder logData = MddLogData.newBuilder(); - sampleAndSendLogEvent( - MddClientEvent.Code.EVENT_CODE_UNSPECIFIED, logData, flags.mddDefaultSampleInterval()); - } - - @Override - public void logMddNetworkSavings( - DataDownloadFileGroupStats fileGroupDetails, - int code, - long fullFileSize, - long downloadedFileSize, - String fileId, - int deltaIndex) { - MddLogData.Builder logData = MddLogData.newBuilder(); - - sampleAndSendLogEvent( - MddClientEvent.Code.EVENT_CODE_UNSPECIFIED, logData, flags.mddDefaultSampleInterval()); - } - - @Override - public void logMddQueryStats(DataDownloadFileGroupStats fileGroupDetails) { - MddLogData.Builder logData = MddLogData.newBuilder(); - - sampleAndSendLogEvent( - MddClientEvent.Code.EVENT_CODE_UNSPECIFIED, logData, flags.mddDefaultSampleInterval()); - } - - @Override - public void logMddDownloadLatency( - DataDownloadFileGroupStats fileGroupDetails, Void downloadLatency) { - MddLogData.Builder logData = - MddLogData.newBuilder().setDataDownloadFileGroupStats(fileGroupDetails); - - sampleAndSendLogEvent( - MddClientEvent.Code.EVENT_CODE_UNSPECIFIED, logData, flags.mddDefaultSampleInterval()); - } - - @Override - public void logMddDownloadResult( - MddDownloadResult.Code code, DataDownloadFileGroupStats fileGroupDetails) { - MddLogData.Builder logData = - MddLogData.newBuilder() - .setMddDownloadResultLog( - MddDownloadResultLog.newBuilder() - .setResult(code) - .setDataDownloadFileGroupStats(fileGroupDetails)); - - sampleAndSendLogEvent( - MddClientEvent.Code.DATA_DOWNLOAD_RESULT_LOG, logData, flags.mddDefaultSampleInterval()); - } - - @Override - public void logMddAndroidSharingLog(Void event) { - // TODO(b/144684763): consider moving this to stable sampling depending on frequency of events. - long sampleInterval = flags.mddAndroidSharingSampleInterval(); - if (!LogUtil.shouldSampleInterval(sampleInterval)) { - return; + directExecutor()); } - MddLogData.Builder logData = MddLogData.newBuilder(); - processAndSendEventWithoutStableSampling( - MddClientEvent.Code.EVENT_CODE_UNSPECIFIED, logData, sampleInterval); - } - - @Override - public void logMddUsageEvent(DataDownloadFileGroupStats fileGroupDetails, Void usageEventLog) { - MddLogData.Builder logData = - MddLogData.newBuilder().setDataDownloadFileGroupStats(fileGroupDetails); - - sampleAndSendLogEvent( - MddClientEvent.Code.EVENT_CODE_UNSPECIFIED, logData, flags.mddDefaultSampleInterval()); - } - - @Override - public void logNewConfigReceived( - DataDownloadFileGroupStats fileGroupDetails, Void newConfigReceivedInfo) { - MddLogData.Builder logData = - MddLogData.newBuilder().setDataDownloadFileGroupStats(fileGroupDetails); - sampleAndSendLogEvent( - MddClientEvent.Code.EVENT_CODE_UNSPECIFIED, logData, flags.mddDefaultSampleInterval()); - } - - /** - * Determines whether the log event will be a part of the sample, and if so calls {@code - * buildStats} to construct the log event. This is like {@link sampleAndSendLogEvent} but - * constructs the log event lazy. This is useful if constructing the log event is expensive. - */ - private ListenableFuture<Void> lazySampleAndSendLogEvent( - MddClientEvent.Code eventCode, - AsyncCallable<List<MddLogData>> buildStats, - int sampleInterval) { - return PropagatedFutures.transformAsync( - logSampler.shouldLog(sampleInterval, loggingStateStore), - samplingInfoOptional -> { - if (!samplingInfoOptional.isPresent()) { - return immediateVoidFuture(); - } - - return PropagatedFluentFuture.from(buildStats.call()) - .transform( - icingLogDataList -> { - if (icingLogDataList != null) { - for (MddLogData icingLogData : icingLogDataList) { - processAndSendEvent( - eventCode, - icingLogData.toBuilder(), - sampleInterval, - samplingInfoOptional.get()); - } + + private void sampleAndSendLogEvent( + MddClientEvent.Code eventCode, MddLogData.Builder logData, long sampleInterval) { + // NOTE: When using a single-threaded executor, logging may be delayed since other + // work will come before the log sampler check. + PropagatedFutures.addCallback( + logSampler.shouldLog(sampleInterval, loggingStateStore), + new FutureCallback<Optional<StableSamplingInfo>>() { + @Override + public void onSuccess(Optional<StableSamplingInfo> stableSamplingInfo) { + if (stableSamplingInfo.isPresent()) { + processAndSendEvent(eventCode, logData, sampleInterval, + stableSamplingInfo.get()); + } } - return null; - }, - directExecutor()); - }, - directExecutor()); - } - - private void sampleAndSendLogEvent( - MddClientEvent.Code eventCode, MddLogData.Builder logData, long sampleInterval) { - // NOTE: When using a single-threaded executor, logging may be delayed since other - // work will come before the log sampler check. - PropagatedFutures.addCallback( - logSampler.shouldLog(sampleInterval, loggingStateStore), - new FutureCallback<Optional<StableSamplingInfo>>() { - @Override - public void onSuccess(Optional<StableSamplingInfo> stableSamplingInfo) { - if (stableSamplingInfo.isPresent()) { - processAndSendEvent(eventCode, logData, sampleInterval, stableSamplingInfo.get()); - } - } - - @Override - public void onFailure(Throwable t) { - LogUtil.e(t, "%s: failure when sampling log!", TAG); - } - }, - directExecutor()); - } - - /** Adds all transforms common to all logs and sends the event to Logger. */ - private void processAndSendEventWithoutStableSampling( - MddClientEvent.Code eventCode, MddLogData.Builder logData, long sampleInterval) { - processAndSendEvent( - eventCode, - logData, - sampleInterval, - StableSamplingInfo.newBuilder().setStableSamplingUsed(false).build()); - } - - /** Adds all transforms common to all logs and sends the event to Logger. */ - private void processAndSendEvent( - MddClientEvent.Code eventCode, - MddLogData.Builder logData, - long sampleInterval, - StableSamplingInfo stableSamplingInfo) { - if (eventCode.equals(MddClientEvent.Code.EVENT_CODE_UNSPECIFIED)) { - LogUtil.e("%s: unspecified code used, skipping event log", TAG); - // return early for unspecified codes. - return; + + @Override + public void onFailure(Throwable t) { + LogUtil.e(t, "%s: failure when sampling log!", TAG); + } + }, + directExecutor()); + } + + /** Adds all transforms common to all logs and sends the event to Logger. */ + private void processAndSendEventWithoutStableSampling( + MddClientEvent.Code eventCode, MddLogData.Builder logData, long sampleInterval) { + processAndSendEvent( + eventCode, + logData, + sampleInterval, + StableSamplingInfo.newBuilder().setStableSamplingUsed(false).build()); + } + + /** Adds all transforms common to all logs and sends the event to Logger. */ + private void processAndSendEvent( + MddClientEvent.Code eventCode, + MddLogData.Builder logData, + long sampleInterval, + StableSamplingInfo stableSamplingInfo) { + if (eventCode.equals(MddClientEvent.Code.EVENT_CODE_UNSPECIFIED)) { + LogUtil.e("%s: unspecified code used, skipping event log", TAG); + // return early for unspecified codes. + return; + } + + logData + .setSamplingInterval(sampleInterval) + .setDeviceInfo( + MddDeviceInfo.newBuilder().setDeviceStorageLow(isDeviceStorageLow(context))) + .setAndroidClientInfo( + AndroidClientInfo.newBuilder() + .setHostPackageName(hostPackageName) + .setModuleVersion(moduleVersion)) + .setStableSamplingInfo(stableSamplingInfo); + logger.log(logData.build(), eventCode.getNumber()); + } + + /** Returns whether the device is in low storage state. */ + private static boolean isDeviceStorageLow(Context context) { + // Check if the system says storage is low, by reading the sticky intent. + return context.registerReceiver(null, new IntentFilter(Intent.ACTION_DEVICE_STORAGE_LOW)) + != null; } - logData - .setSamplingInterval(sampleInterval) - .setDeviceInfo(MddDeviceInfo.newBuilder().setDeviceStorageLow(isDeviceStorageLow(context))) - .setAndroidClientInfo( - AndroidClientInfo.newBuilder() - .setHostPackageName(hostPackageName) - .setModuleVersion(moduleVersion)) - .setStableSamplingInfo(stableSamplingInfo); - logger.log(logData.build(), eventCode.getNumber()); - } - - /** Returns whether the device is in low storage state. */ - private static boolean isDeviceStorageLow(Context context) { - // Check if the system says storage is low, by reading the sticky intent. - return context.registerReceiver(null, new IntentFilter(Intent.ACTION_DEVICE_STORAGE_LOW)) - != null; - } } |