Skip to content
Permalink
Browse files

use DistributedExecutor libs from ISPN to get FixityResults

  • Loading branch information...
barmintor committed Jun 4, 2013
1 parent 9b63f43 commit c628fde56174bc28363e72de250df7498f61a021
Showing with 891 additions and 377 deletions.
  1. +1 −1 fcrepo-kernel/src/main/java/org/fcrepo/services/DatastreamService.java
  2. +233 −121 fcrepo-kernel/src/main/java/org/fcrepo/services/LowLevelStorageService.java
  3. +14 −0 fcrepo-kernel/src/main/java/org/fcrepo/services/ServiceHelpers.java
  4. +56 −0 fcrepo-kernel/src/main/java/org/fcrepo/services/functions/CacheLocalTransform.java
  5. +30 −11 fcrepo-kernel/src/main/java/org/fcrepo/services/functions/CheckCacheEntryFixity.java
  6. +4 −2 fcrepo-kernel/src/main/java/org/fcrepo/services/functions/GetCacheStore.java
  7. +20 −160 fcrepo-kernel/src/main/java/org/fcrepo/utils/LowLevelCacheEntry.java
  8. +166 −0 fcrepo-kernel/src/main/java/org/fcrepo/utils/impl/CacheStoreEntry.java
  9. +66 −0 fcrepo-kernel/src/main/java/org/fcrepo/utils/impl/ChainingCacheStoreEntry.java
  10. +117 −0 fcrepo-kernel/src/main/java/org/fcrepo/utils/impl/LocalBinaryStoreEntry.java
  11. +18 −28 fcrepo-kernel/src/test/java/org/fcrepo/integration/utils/LowLevelCacheEntryIT.java
  12. +17 −1 fcrepo-kernel/src/test/java/org/fcrepo/integration/utils/SelfHealingIT.java
  13. +7 −5 fcrepo-kernel/src/test/java/org/fcrepo/services/DatastreamServiceTest.java
  14. +60 −14 fcrepo-kernel/src/test/java/org/fcrepo/services/LowLevelStorageServiceTest.java
  15. +54 −0 fcrepo-kernel/src/test/java/org/fcrepo/services/functions/CacheLocalTransformTest.java
  16. +6 −4 fcrepo-kernel/src/test/java/org/fcrepo/services/functions/CheckCacheEntryFixityTest.java
  17. +22 −30 fcrepo-kernel/src/test/java/org/fcrepo/utils/LowLevelCacheEntryTest.java
@@ -246,7 +246,7 @@ public boolean apply(org.fcrepo.utils.FixityResult input) {
result.getEntry()
.storeValue(anyGoodCacheEntry.getInputStream());
final FixityResult newResult =
result.getEntry().checkFixity(digestUri, size, digest);
result.getEntry().checkFixity(digestUri, size, digest.getAlgorithm());
if (newResult.isSuccess()) {
result.setRepaired();
fixityRepairedCounter.inc();
Oops, something went wrong.

0 comments on commit c628fde

Please sign in to comment.
You can’t perform that action at this time.