From c72fdcb306c91155da500d003dc45b75046c95d1 Mon Sep 17 00:00:00 2001 From: Peter Lawrey Date: Thu, 15 Aug 2019 09:45:08 +0100 Subject: [PATCH] Remove

--- .../chronicle/map/ChronicleMapBuilder.java | 2 +- .../map/utility/ProcessInstanceLimiter.java | 18 +++++++++--------- 2 files changed, 10 insertions(+), 10 deletions(-) diff --git a/src/main/java/net/openhft/chronicle/map/ChronicleMapBuilder.java b/src/main/java/net/openhft/chronicle/map/ChronicleMapBuilder.java index 53867e4d2..e7c1789b2 100755 --- a/src/main/java/net/openhft/chronicle/map/ChronicleMapBuilder.java +++ b/src/main/java/net/openhft/chronicle/map/ChronicleMapBuilder.java @@ -167,7 +167,7 @@ public final class ChronicleMapBuilder implements /** * Default timeout is 1 minute. Even loopback tests converge often in the course of seconds, * let alone WAN replication over many nodes might take tens of seconds. - *

+ *

* TODO review */ long cleanupTimeout = 1; diff --git a/src/test/java/net/openhft/chronicle/map/utility/ProcessInstanceLimiter.java b/src/test/java/net/openhft/chronicle/map/utility/ProcessInstanceLimiter.java index 7608d6fa8..4761331a3 100644 --- a/src/test/java/net/openhft/chronicle/map/utility/ProcessInstanceLimiter.java +++ b/src/test/java/net/openhft/chronicle/map/utility/ProcessInstanceLimiter.java @@ -46,13 +46,13 @@ import static net.openhft.chronicle.algo.bytes.Access.checkedBytesStoreAccess; * shared map (using ChronicleMap) to maintain shared data across any processes * which use a ProcessInstanceLimiter, and checking on startup and regularly * after whether it is allowed to run. - *

+ *

*

Typically, you need to specify two things to create an instance of * ProcessInstanceLimiter: a path to a file that will hold the shared map; and a * callback object (an instance implementing ProcessInstanceLimiter.Callback) to * handle the various possible callback messages that the ProcessInstanceLimiter * can generate. - *

+ *

*

Once you have a ProcessInstanceLimiter instance, you specify a type of * process (any string) which will be limited to up to N processes running at * the same time by calling the setMaxNumberOfProcessesOfType() method. Finally @@ -60,18 +60,18 @@ import static net.openhft.chronicle.algo.bytes.Access.checkedBytesStoreAccess; * startingProcessOfType(X). This last is deliberately not done automatically as * you may wish for one type of process to define limitations on other types of * processes. - *

+ *

*

The are some convenience methods which allow you to quickly specify a limit * without consideration of the above. For example, if during your application * startup you call ProcessInstanceLimiter.limitTo(2), then you need not call * anything else and you have limited your application to running at most 2 JVM * instances of your application. Under the covers, this call is identical to * the sequence: - *

+ *

*

ProcessInstanceLimiter limiter = new ProcessInstanceLimiter(); * limiter.setMaxNumberOfProcessesOfType(processType,numProcesses); * limiter.startingProcessOfType(processType); - *

+ *

*

This: * 1. Creates a shared file called ProcessInstanceLimiter_DEFAULT_SHARED_MAP_ in * the temp directory to hold an instance of ChronicleMap @@ -159,7 +159,7 @@ public class ProcessInstanceLimiter implements Runnable { /** * Convenience method. - *

+ *

*

Create a ProcessInstanceLimiter instance which is limited to one OS * process instance of the DEFAULT type. This will enforce that any JVM on * the same box which runs the code @@ -175,7 +175,7 @@ public class ProcessInstanceLimiter implements Runnable { /** * Convenience method. - *

+ *

*

Create a ProcessInstanceLimiter instance which is limited to * "numProcesses" OS process instances of the DEFAULT type. This will * enforce that any JVM on the same box which runs the code @@ -194,7 +194,7 @@ public class ProcessInstanceLimiter implements Runnable { /** * Convenience method. - *

+ *

*

Create a ProcessInstanceLimiter instance which is limited to * "numProcesses" OS process instances of the "processType" type. This will * enforce that any JVM on the same box which runs the code @@ -532,7 +532,7 @@ public class ProcessInstanceLimiter implements Runnable { /** * The Data object holds an array of timestamps and a maximum number of * processes allowed to be running concurrently - *

+ *

*

The Timelock field is just for locking the time field */ public interface Data {