modified loader

microstream-one · Oct 31, 2023 · 8d5b963 · 8d5b963
1 parent 5c60356
commit 8d5b963
Show file tree

Hide file tree

Showing 2 changed files with 17 additions and 1 deletion.
diff --git a/persistence/binary/src/main/java/one/microstream/persistence/binary/types/BinaryLoader.java b/persistence/binary/src/main/java/one/microstream/persistence/binary/types/BinaryLoader.java
@@ -34,6 +34,7 @@
 import one.microstream.persistence.binary.exceptions.BinaryPersistenceException;
 import one.microstream.persistence.binary.one.microstream.collections.BinaryHandlerSingleton;
 import one.microstream.persistence.exceptions.PersistenceExceptionTypeHandlerConsistencyUnhandledTypeId;
+import one.microstream.persistence.types.PersistenceAcceptor;
 import one.microstream.persistence.types.PersistenceLoadHandler;
 import one.microstream.persistence.types.PersistenceLoader;
 import one.microstream.persistence.types.PersistenceObjectRegistry;
@@ -65,7 +66,7 @@ public static BinaryLoader.Creator CreatorSimple(final boolean switchByteOrder)
 		return new BinaryLoader.CreatorSimple(switchByteOrder);
 	}
 
-	public static BinaryLoader.Default New(
+	public static BinaryLoader New(
 		final PersistenceTypeHandlerLookup<Binary> typeLookup     ,
 		final PersistenceObjectRegistry            registry       ,
 		final Persister                            persister      ,
@@ -919,6 +920,15 @@ private final void requireReference(final long objectId)
 			this.loadItems.addLoadItem(objectId);
 		}
 
+		@Override
+		public void iterateEntries(final PersistenceAcceptor iterator)
+		{
+			synchronized(this.objectRegistry)
+			{
+				this.objectRegistry.iterateEntries(iterator);
+			}
+		}
+
 	}
 
 

diff --git a/...stence/persistence/src/main/java/one/microstream/persistence/types/PersistenceLoader.java b/...stence/persistence/src/main/java/one/microstream/persistence/types/PersistenceLoader.java
@@ -26,6 +26,12 @@ public interface PersistenceLoader extends PersistenceRetrieving
 
 	public void registerSkip(long objectId);
 
+	/**
+	 * Iterate over all known objects of the current Loader
+	 * 
+	 * @param iterator PersistenceAcceptor
+	 */
+	void iterateEntries(final PersistenceAcceptor iterator);
 
 
 	public interface Creator<D>