Fix race condition when making initial connection to a slow database.

1 files changed, 4 insertions, 1 deletions

diff --git a/src/main/java/com/amazon/carbonado/repo/replicated/ReplicatedRepositoryBuilder.java b/src/main/java/com/amazon/carbonado/repo/replicated/ReplicatedRepositoryBuilder.java
index 17beb2e..a24cffe 100644
--- a/src/main/java/com/amazon/carbonado/repo/replicated/ReplicatedRepositoryBuilder.java
+++ b/src/main/java/com/amazon/carbonado/repo/replicated/ReplicatedRepositoryBuilder.java
@@ -82,8 +82,11 @@ public class ReplicatedRepositoryBuilder extends AbstractRepositoryBuilder {
             mMasterRepositoryBuilder.setMaster(mIsMaster);

 

             Log log = LogFactory.getLog(ReplicatedRepositoryBuilder.class);

+            // Pass a dummy root reference, to prevent it from overriding the

+            // true root, which is a ReplicatedRepository.

+            AtomicReference<Repository> dummyRef = new AtomicReference<Repository>();

             BelatedRepositoryCreator creator = new BelatedRepositoryCreator

-                (log, mMasterRepositoryBuilder, rootRef, DEFAULT_RETRY_MILLIS) {

+                (log, mMasterRepositoryBuilder, dummyRef, DEFAULT_RETRY_MILLIS) {

 

                 @Override

                 protected void createdNotification(Repository repo) {