X-Git-Url: https://git.argeo.org/?a=blobdiff_plain;f=org.argeo.api.uuid%2Fsrc%2Forg%2Fargeo%2Fapi%2Fuuid%2FAbstractAsyncUuidFactory.java;h=52becc85ac0946a018e692b1065e3b20c999c83a;hb=0f8bddc982e2ea4f260e1eb639777b74e7893ea3;hp=1948eafbd8e82de76afe00e21d4d7620b9259d83;hpb=f97685aba73c01d93689fca1a67338fb4d23919c;p=lgpl%2Fargeo-commons.git

diff --git a/org.argeo.api.uuid/src/org/argeo/api/uuid/AbstractAsyncUuidFactory.java b/org.argeo.api.uuid/src/org/argeo/api/uuid/AbstractAsyncUuidFactory.java
index 1948eafbd..52becc85a 100644
--- a/org.argeo.api.uuid/src/org/argeo/api/uuid/AbstractAsyncUuidFactory.java
+++ b/org.argeo.api.uuid/src/org/argeo/api/uuid/AbstractAsyncUuidFactory.java
@@ -26,16 +26,17 @@ public abstract class AbstractAsyncUuidFactory extends AbstractUuidFactory imple
 	protected ConcurrentTimeUuidState timeUuidState;
 
 	private NodeIdSupplier nodeIdSupplier;
+	private long currentClockSequenceRange = 0;
 
 	public AbstractAsyncUuidFactory() {
-		secureRandom = newSecureRandom();
+		secureRandom = createSecureRandom();
 		timeUuidState = new ConcurrentTimeUuidState(secureRandom, null);
 	}
 	/*
 	 * ABSTRACT METHODS
 	 */
 
-	protected abstract SecureRandom newSecureRandom();
+	protected abstract SecureRandom createSecureRandom();
 
 	/*
 	 * STATE
@@ -44,7 +45,7 @@ public abstract class AbstractAsyncUuidFactory extends AbstractUuidFactory imple
 		if (nodeIdSupplier == null)
 			throw new IllegalStateException("No node id supplier available");
 		long nodeIdBase = nodeIdSupplier.get();
-		timeUuidState.reset(nodeIdBase);
+		timeUuidState.reset(nodeIdBase, currentClockSequenceRange);
 	}
 
 	public void setNodeIdSupplier(NodeIdSupplier nodeIdSupplier) {
@@ -52,10 +53,28 @@ public abstract class AbstractAsyncUuidFactory extends AbstractUuidFactory imple
 		reset();
 	}
 
+	public void setNodeIdSupplier(NodeIdSupplier nodeIdSupplier, long range) {
+		this.currentClockSequenceRange = range >= 0 ? range & 0x3F00 : range;
+		setNodeIdSupplier(nodeIdSupplier);
+	}
+
+	protected NodeIdSupplier getNodeIdSupplier() {
+		return nodeIdSupplier;
+	}
+
+	/**
+	 * If positive, only clock_hi is taken from the argument (range & 0x3F00), if
+	 * negative, the full range of possible values is used.
+	 */
+	public void setCurrentClockSequenceRange(long range) {
+		this.currentClockSequenceRange = range >= 0 ? range & 0x3F00 : range;
+		reset();
+	}
+
 	/*
 	 * SYNC OPERATIONS
 	 */
-	protected UUID newRandomUUIDStrong() {
+	protected UUID createRandomUUIDStrong() {
 		SecureRandomParameters parameters = secureRandom.getParameters();
 		if (parameters != null) {
 			if (parameters instanceof DrbgParameters.Instantiation) {
@@ -66,14 +85,14 @@ public abstract class AbstractAsyncUuidFactory extends AbstractUuidFactory imple
 				}
 			}
 		}
-		return newRandomUUID(secureRandom);
+		return createRandomUUID(secureRandom);
 	}
 
 	public UUID randomUUIDWeak() {
-		return newRandomUUID(ThreadLocalRandom.current());
+		return createRandomUUID(ThreadLocalRandom.current());
 	}
 
-	protected UUID newTimeUUID() {
+	protected UUID createTimeUUID() {
 		if (nodeIdSupplier == null)
 			throw new IllegalStateException("No node id supplier available");
 		UUID uuid = new UUID(timeUuidState.getMostSignificantBits(), timeUuidState.getLeastSignificantBits());
@@ -122,21 +141,21 @@ public abstract class AbstractAsyncUuidFactory extends AbstractUuidFactory imple
 
 	@Override
 	public ForkJoinTask<UUID> futureNameUUIDv5(UUID namespace, byte[] data) {
-		return submit(() -> newNameUUIDv5(namespace, data));
+		return submit(() -> createNameUUIDv5(namespace, data));
 	}
 
 	@Override
 	public ForkJoinTask<UUID> futureNameUUIDv3(UUID namespace, byte[] data) {
-		return submit(() -> newNameUUIDv3(namespace, data));
+		return submit(() -> createNameUUIDv3(namespace, data));
 	}
 
 	@Override
 	public ForkJoinTask<UUID> futureRandomUUIDStrong() {
-		return submit(this::newRandomUUIDStrong);
+		return submit(this::createRandomUUIDStrong);
 	}
 
 	@Override
 	public ForkJoinTask<UUID> futureTimeUUID() {
-		return submit(this::newTimeUUID);
+		return submit(this::createTimeUUID);
 	}
 }