Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Fixed typo in variable name DEFUALT_MAX_CONCURRENT_PLANS #235

Closed
wants to merge 1 commit into from
Closed

Fixed typo in variable name DEFUALT_MAX_CONCURRENT_PLANS #235

Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
20 changes: 10 additions & 10 deletions subprojects/parseq/src/main/java/com/linkedin/parseq/Engine.java
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -58,7 +58,7 @@ public class Engine {
private static final int DEFUALT_MAX_RELATIONSHIPS_PER_TRACE = 65536;

public static final String MAX_CONCURRENT_PLANS = "_MaxConcurrentPlans_";
private static final int DEFUALT_MAX_CONCURRENT_PLANS = Integer.MAX_VALUE;
private static final int DEFAULT_MAX_CONCURRENT_PLANS = Integer.MAX_VALUE;

public static final String DRAIN_SERIAL_EXECUTOR_QUEUE = "_DrainSerialExecutorQueue_";
private static final boolean DEFAULT_DRAIN_SERIAL_EXECUTOR_QUEUE = true;
Expand Down Expand Up @@ -158,7 +158,7 @@ private static enum StateName {
if (_properties.containsKey(MAX_CONCURRENT_PLANS)) {
_maxConcurrentPlans = (Integer) getProperty(MAX_CONCURRENT_PLANS);
} else {
_maxConcurrentPlans = DEFUALT_MAX_CONCURRENT_PLANS;
_maxConcurrentPlans = DEFAULT_MAX_CONCURRENT_PLANS;
}
_concurrentPlans = new Semaphore(_maxConcurrentPlans);

Expand Down Expand Up @@ -290,7 +290,7 @@ private final String defaultPlanClass(final Task<?> task) {
* Engine's capacity is specified by a {@value #MAX_CONCURRENT_PLANS} configuration property. Use
* {@link EngineBuilder#setEngineProperty(String, Object)} to set this property.
* For the sake of backwards compatibility default value for a {@value #MAX_CONCURRENT_PLANS} is
* {@value #DEFUALT_MAX_CONCURRENT_PLANS} which essentially means "unbounded capacity".
* {@value #DEFAULT_MAX_CONCURRENT_PLANS} which essentially means "unbounded capacity".
*
* @param task the task to run
* @throws IllegalStateException
Expand All @@ -307,7 +307,7 @@ public void run(final Task<?> task) {
* Engine's capacity is specified by a {@value #MAX_CONCURRENT_PLANS} configuration property. Use
* {@link EngineBuilder#setEngineProperty(String, Object)} to set this property.
* For the sake of backwards compatibility default value for a {@value #MAX_CONCURRENT_PLANS} is
* {@value #DEFUALT_MAX_CONCURRENT_PLANS} which essentially means "unbounded capacity".
* {@value #DEFAULT_MAX_CONCURRENT_PLANS} which essentially means "unbounded capacity".
*
* @param task the task to run
* @param planClass string that identifies a "class" of the Plan. Plan class ends up in a ParSeq
Expand All @@ -328,7 +328,7 @@ public void run(final Task<?> task, final String planClass) {
* specified by a {@value #MAX_CONCURRENT_PLANS} configuration property. Use
* {@link EngineBuilder#setEngineProperty(String, Object)} to set this property.
* For the sake of backwards compatibility default value for a {@value #MAX_CONCURRENT_PLANS} is
* {@value #DEFUALT_MAX_CONCURRENT_PLANS} which essentially means "unbounded capacity".
* {@value #DEFAULT_MAX_CONCURRENT_PLANS} which essentially means "unbounded capacity".
*
* @param task the task to run
*/
Expand All @@ -344,7 +344,7 @@ public void blockingRun(final Task<?> task) {
* specified by a {@value #MAX_CONCURRENT_PLANS} configuration property. Use
* {@link EngineBuilder#setEngineProperty(String, Object)} to set this property.
* For the sake of backwards compatibility default value for a {@value #MAX_CONCURRENT_PLANS} is
* {@value #DEFUALT_MAX_CONCURRENT_PLANS} which essentially means "unbounded capacity".
* {@value #DEFAULT_MAX_CONCURRENT_PLANS} which essentially means "unbounded capacity".
*
* @param task the task to run
* @param planClass string that identifies a "class" of the Plan. Plan class ends up in a ParSeq
Expand All @@ -363,7 +363,7 @@ public void blockingRun(final Task<?> task, final String planClass) {
* Runs the given task if Engine has a capacity to start new plan as specified by
* {@value #MAX_CONCURRENT_PLANS} configuration parameter.
* For the sake of backwards compatibility default value for a {@value #MAX_CONCURRENT_PLANS} is
* {@value #DEFUALT_MAX_CONCURRENT_PLANS} which essentially means "unbounded capacity".
* {@value #DEFAULT_MAX_CONCURRENT_PLANS} which essentially means "unbounded capacity".
* Task passed in as a parameter becomes a root on a new Plan.
* All tasks created and started as a consequence of a root task will belong to that plan and will share a Trace.
* This method returns immediately and does not block. It returns {@code true} if Plan was successfully started.
Expand All @@ -378,7 +378,7 @@ public boolean tryRun(final Task<?> task) {
* Runs the given task if Engine has a capacity to start new plan as specified by
* {@value #MAX_CONCURRENT_PLANS} configuration parameter.
* For the sake of backwards compatibility default value for a {@value #MAX_CONCURRENT_PLANS} is
* {@value #DEFUALT_MAX_CONCURRENT_PLANS} which essentially means "unbounded capacity".
* {@value #DEFAULT_MAX_CONCURRENT_PLANS} which essentially means "unbounded capacity".
* Task passed in as a parameter becomes a root on a new Plan.
* All tasks created and started as a consequence of a root task will belong to that plan and will share a Trace.
* This method returns immediately and does not block. It returns {@code true} if Plan was successfully started.
Expand All @@ -399,7 +399,7 @@ public boolean tryRun(final Task<?> task, final String planClass) {
* Runs the given task if Engine has a capacity to start new plan as specified by
* {@value #MAX_CONCURRENT_PLANS} configuration parameter within specified amount of time.
* For the sake of backwards compatibility default value for a {@value #MAX_CONCURRENT_PLANS} is
* {@value #DEFUALT_MAX_CONCURRENT_PLANS} which essentially means "unbounded capacity".
* {@value #DEFAULT_MAX_CONCURRENT_PLANS} which essentially means "unbounded capacity".
* Task passed in as a parameter becomes a root on a new Plan.
* All tasks created and started as a consequence of a root task will belong to that plan and will share a Trace.
* If Engine does not have capacity to start the task, this method will block up to specified amount of
Expand All @@ -419,7 +419,7 @@ public boolean tryRun(final Task<?> task, final long timeout, final TimeUnit uni
* Runs the given task if Engine has a capacity to start new plan as specified by
* {@value #MAX_CONCURRENT_PLANS} configuration parameter within specified amount of time.
* For the sake of backwards compatibility default value for a {@value #MAX_CONCURRENT_PLANS} is
* {@value #DEFUALT_MAX_CONCURRENT_PLANS} which essentially means "unbounded capacity".
* {@value #DEFAULT_MAX_CONCURRENT_PLANS} which essentially means "unbounded capacity".
* Task passed in as a parameter becomes a root on a new Plan.
* All tasks created and started as a consequence of a root task will belong to that plan and will share a Trace.
* If Engine does not have capacity to start the task, this method will block up to specified amount of
Expand Down