Merge 79e8ce1 into b5b093e

Author: romtsn

sentry/src/main/java/io/sentry/ExperimentalOptions.java

@@ -9,7 +9,11 @@
  * <p>Beware that experimental options can change at any time.
  */
 public final class ExperimentalOptions {
-  private @NotNull SentryReplayOptions sessionReplay = new SentryReplayOptions();
+  private @NotNull SentryReplayOptions sessionReplay;
+
+  public ExperimentalOptions(final boolean empty) {
+    this.sessionReplay = new SentryReplayOptions(empty);
+  }
 
   @NotNull
   public SentryReplayOptions getSessionReplay() {

sentry/src/main/java/io/sentry/SentryOptions.java

@@ -19,13 +19,13 @@
 import io.sentry.transport.ITransportGate;
 import io.sentry.transport.NoOpEnvelopeCache;
 import io.sentry.transport.NoOpTransportGate;
+import io.sentry.util.Objects;
 import io.sentry.util.Platform;
 import io.sentry.util.SampleRateUtils;
 import io.sentry.util.StringUtils;
 import io.sentry.util.thread.IMainThreadChecker;
 import io.sentry.util.thread.NoOpMainThreadChecker;
 import java.io.File;
-import java.net.Proxy;
 import java.util.ArrayList;
 import java.util.Collections;
 import java.util.HashMap;
@@ -119,10 +119,14 @@ public class SentryOptions {
   private @NotNull SentryLevel diagnosticLevel = DEFAULT_DIAGNOSTIC_LEVEL;
 
   /** Envelope reader interface */
-  private @NotNull IEnvelopeReader envelopeReader = new EnvelopeReader(new JsonSerializer(this));
+  private volatile @Nullable IEnvelopeReader envelopeReader;
+
+  private final @NotNull Object envelopeReaderLock = new Object();
 
   /** Serializer interface to serialize/deserialize json events */
-  private @NotNull ISerializer serializer = new JsonSerializer(this);
+  private volatile @Nullable ISerializer serializer;
+
+  private final @NotNull Object serializerLock = new Object();
 
   /** Max depth when serializing object graphs with reflection. * */
   private int maxDepth = 100;
@@ -416,7 +420,9 @@ public class SentryOptions {
 
   /** Date provider to retrieve the current date from. */
   @ApiStatus.Internal
-  private @NotNull SentryDateProvider dateProvider = new SentryAutoDateProvider();
+  private volatile @Nullable SentryDateProvider dateProvider;
+
+  private final @NotNull Object dateProviderLock = new Object();
 
   private final @NotNull List<IPerformanceCollector> performanceCollectors = new ArrayList<>();
 
@@ -479,7 +485,7 @@ public class SentryOptions {
 
   @ApiStatus.Experimental private @Nullable Cron cron = null;
 
-  private final @NotNull ExperimentalOptions experimental = new ExperimentalOptions();
+  private final @NotNull ExperimentalOptions experimental;
 
   private @NotNull ReplayController replayController = NoOpReplayController.getInstance();
 
@@ -605,7 +611,14 @@ public void setDiagnosticLevel(@Nullable final SentryLevel diagnosticLevel) {
    * @return the serializer
    */
   public @NotNull ISerializer getSerializer() {
-    return serializer;
+    if (serializer == null) {
+      synchronized (serializerLock) {
+        if (serializer == null) {
+          serializer = new JsonSerializer(this);
+        }
+      }
+    }
+    return Objects.requireNonNull(serializer, "Serializer was null");
   }
 
   /**
@@ -636,7 +649,14 @@ public void setMaxDepth(int maxDepth) {
   }
 
   public @NotNull IEnvelopeReader getEnvelopeReader() {
-    return envelopeReader;
+    if (envelopeReader == null) {
+      synchronized (envelopeReaderLock) {
+        if (envelopeReader == null) {
+          envelopeReader = new EnvelopeReader(getSerializer());
+        }
+      }
+    }
+    return Objects.requireNonNull(envelopeReader, "EnvelopeReader was null");
   }
 
   public void setEnvelopeReader(final @Nullable IEnvelopeReader envelopeReader) {
@@ -2212,7 +2232,14 @@ public void setIgnoredCheckIns(final @Nullable List<String> ignoredCheckIns) {
   /** Returns the current {@link SentryDateProvider} that is used to retrieve the current date. */
   @ApiStatus.Internal
   public @NotNull SentryDateProvider getDateProvider() {
-    return dateProvider;
+    if (dateProvider == null) {
+      synchronized (dateProviderLock) {
+        if (dateProvider == null) {
+          dateProvider = new SentryAutoDateProvider();
+        }
+      }
+    }
+    return Objects.requireNonNull(dateProvider, "DateProvider is not set");
   }
 
   /**
@@ -2540,6 +2567,7 @@ public SentryOptions() {
    * @param empty if options should be empty.
    */
   private SentryOptions(final boolean empty) {
+    experimental = new ExperimentalOptions(empty);
     if (!empty) {
       // SentryExecutorService should be initialized before any
       // SendCachedEventFireAndForgetIntegration

sentry/src/main/java/io/sentry/SentryReplayOptions.java

@@ -96,14 +96,16 @@ public enum SentryReplayQuality {
   /** The maximum duration of a full session replay, defaults to 1h. */
   private long sessionDuration = 60 * 60 * 1000L;
 
-  public SentryReplayOptions() {
-    setRedactAllText(true);
-    setRedactAllImages(true);
+  public SentryReplayOptions(final boolean empty) {
+    if (!empty) {
+      setRedactAllText(true);
+      setRedactAllImages(true);
+    }
   }
 
   public SentryReplayOptions(
       final @Nullable Double sessionSampleRate, final @Nullable Double onErrorSampleRate) {
-    this();
+    this(false);
     this.sessionSampleRate = sessionSampleRate;
     this.onErrorSampleRate = onErrorSampleRate;
   }

sentry/src/main/java/io/sentry/clientreport/AtomicClientReportStorage.java

@@ -1,10 +1,12 @@
 package io.sentry.clientreport;
 
 import io.sentry.DataCategory;
+import io.sentry.util.LazyEvaluator;
 import java.util.ArrayList;
 import java.util.Collections;
 import java.util.List;
 import java.util.Map;
+import java.util.Set;
 import java.util.concurrent.ConcurrentHashMap;
 import java.util.concurrent.atomic.AtomicLong;
 import org.jetbrains.annotations.ApiStatus;
@@ -14,25 +16,25 @@
 @ApiStatus.Internal
 final class AtomicClientReportStorage implements IClientReportStorage {
 
-  private final @NotNull Map<ClientReportKey, AtomicLong> lostEventCounts;
-
-  public AtomicClientReportStorage() {
+  private final @NotNull LazyEvaluator<Map<ClientReportKey, AtomicLong>> lostEventCounts = new LazyEvaluator<>(() -> {
     final Map<ClientReportKey, AtomicLong> modifyableEventCountsForInit = new ConcurrentHashMap<>();
 
     for (final DiscardReason discardReason : DiscardReason.values()) {
       for (final DataCategory category : DataCategory.values()) {
         modifyableEventCountsForInit.put(
-            new ClientReportKey(discardReason.getReason(), category.getCategory()),
-            new AtomicLong(0));
+          new ClientReportKey(discardReason.getReason(), category.getCategory()),
+          new AtomicLong(0));
       }
     }
 
-    lostEventCounts = Collections.unmodifiableMap(modifyableEventCountsForInit);
-  }
+    return Collections.unmodifiableMap(modifyableEventCountsForInit);
+  });
+
+  public AtomicClientReportStorage() {}
 
   @Override
   public void addCount(ClientReportKey key, Long count) {
-    final @Nullable AtomicLong quantity = lostEventCounts.get(key);
+    final @Nullable AtomicLong quantity = lostEventCounts.getValue().get(key);
 
     if (quantity != null) {
       quantity.addAndGet(count);
@@ -43,7 +45,8 @@ public void addCount(ClientReportKey key, Long count) {
   public List<DiscardedEvent> resetCountsAndGet() {
     final List<DiscardedEvent> discardedEvents = new ArrayList<>();
 
-    for (final Map.Entry<ClientReportKey, AtomicLong> entry : lostEventCounts.entrySet()) {
+    Set<Map.Entry<ClientReportKey, AtomicLong>> entrySet = lostEventCounts.getValue().entrySet();
+    for (final Map.Entry<ClientReportKey, AtomicLong> entry : entrySet) {
       final Long quantity = entry.getValue().getAndSet(0);
       if (quantity > 0) {
         discardedEvents.add(