Test

src/BackupMasterRecovery.cc

 /* Copyright (c) 2009-2012 Stanford University
  *
  * Permission to use, copy, modify, and distribute this software for any
  * purpose with or without fee is hereby granted, provided that the above
  * copyright notice and this permission notice appear in all copies.
  *
  * THE SOFTWARE IS PROVIDED "AS IS" AND THE AUTHOR(S) DISCLAIM ALL WARRANTIES
  * WITH REGARD TO THIS SOFTWARE INCLUDING ALL IMPLIED WARRANTIES OF
  * MERCHANTABILITY AND FITNESS. IN NO EVENT SHALL AUTHORS BE LIABLE FOR
  * ANY SPECIAL, DIRECT, INDIRECT, OR CONSEQUENTIAL DAMAGES OR ANY DAMAGES
@@ skipping 295 matching lines @@
             "starting build of recovery segments now",
             crashedMasterId.toString().c_str(), segmentId);
         replica->frame->load();
         buildRecoverySegments(*replica);
     }
 
     Fence::lfence();
     if (!replica->built) {
         LOG(DEBUG, "Deferring because <%s,%lu> not yet filtered",
             crashedMasterId.toString().c_str(), segmentId);
-        return STATUS_RETRY;
+        throw RetryException(HERE, 5000, 10000,
+                "desired segment not yet filtered");
     }
 
     if (replica->metadata->primary)
         ++metrics->backup.primaryLoadCount;
     else
         ++metrics->backup.secondaryLoadCount;
 
     if (replica->recoveryException) {
         auto e = SegmentRecoveryFailedException(*replica->recoveryException);
         replica->recoveryException.reset();
@@ skipping 239 matching lines @@
 BackupMasterRecovery::Replica::Replica(const BackupStorage::FrameRef& frame)
     : frame(frame)
     , metadata(static_cast<const BackupReplicaMetadata*>(frame->getMetadata()))
     , recoverySegments()
     , recoveryException()
     , built()
 {
 }
 
 } // namespace RAMCloud