Searched defs:poolSize (Results 1 - 25 of 28) sorted by relevance

12

/forgerock/openam-v13/openam-shared/src/main/java/com/sun/identity/common/
H A DSystemTimerPool.java47 private static int poolSize; field in class:SystemTimerPool
50 poolSize = DEFAULT_POOL_SIZE;
55 poolSize = Integer.parseInt(size);
77 poolSize, false, Debug.getInstance("SystemTimerPool"));
H A DTimerPool.java51 private int poolSize; field in class:TimerPool
67 * @param poolSize The size of the TimerPool
73 public TimerPool(String name, int poolSize, boolean daemon, Debug debug) { argument
75 this.poolSize = poolSize;
81 this.threads = new WorkerThread[poolSize];
86 createThreads(poolSize);
97 if (timersToCreate > poolSize) {
98 timersToCreate = poolSize;
118 createThreads(poolSize);
[all...]
/forgerock/openam-v13/openam-core/src/main/java/com/sun/identity/sm/
H A DSMSThreadPool.java50 private static int poolSize; field in class:SMSThreadPool
80 if (newPoolSize == poolSize) {
84 poolSize = newPoolSize;
87 debug.message("SMSThreadPool: poolSize=" + poolSize);
93 poolSize, DEFAULT_TRESHOLD, false, debug);
106 poolSize, DEFAULT_TRESHOLD, false, debug);
/forgerock/openam/openam-shared/src/main/java/com/sun/identity/common/
H A DSystemTimerPool.java47 private static int poolSize; field in class:SystemTimerPool
50 poolSize = DEFAULT_POOL_SIZE;
55 poolSize = Integer.parseInt(size);
76 instance = new TimerPool(TIMER_NAME, poolSize, false, Debug.getInstance(TIMER_NAME));
H A DTimerPool.java51 private int poolSize; field in class:TimerPool
67 * @param poolSize The size of the TimerPool
73 public TimerPool(String name, int poolSize, boolean daemon, Debug debug) { argument
75 this.poolSize = poolSize;
81 this.threads = new WorkerThread[poolSize];
86 createThreads(poolSize);
97 if (timersToCreate > poolSize) {
98 timersToCreate = poolSize;
118 createThreads(poolSize);
[all...]
/forgerock/openam/openam-core/src/main/java/com/sun/identity/sm/
H A DSMSThreadPool.java50 private static int poolSize; field in class:SMSThreadPool
80 if (newPoolSize == poolSize) {
84 poolSize = newPoolSize;
87 debug.message("SMSThreadPool: poolSize=" + poolSize);
93 poolSize, DEFAULT_TRESHOLD, false, debug);
106 poolSize, DEFAULT_TRESHOLD, false, debug);
/forgerock/openam/openam-audit/openam-audit-context/src/main/java/org/forgerock/openam/audit/context/
H A DAMExecutorServiceFactory.java45 * @param poolSize The size of the ScheduledExecutorService thread pool.
49 ScheduledExecutorService createScheduledService(int poolSize, String threadNamePrefix); argument
H A DAuditRequestContextPropagatingExecutorServiceFactory.java48 public ScheduledExecutorService createScheduledService(int poolSize, String threadNamePrefix) { argument
49 return decorate(delegate.createScheduledService(poolSize, threadNamePrefix));
H A DExtendedExecutorServiceFactory.java54 public ScheduledExecutorService createScheduledService(int poolSize, String threadNamePrefix) { argument
56 Executors.newScheduledThreadPool(poolSize, new NamedThreadFactory(threadNamePrefix));
/forgerock/openam-v13/openam-core/src/main/java/com/sun/identity/entitlement/
H A DThreadPool.java57 private int poolSize; field in class:ThreadPool
70 * @param poolSize
74 public ThreadPool(String name, int poolSize) { argument
75 this.poolSize = poolSize;
78 threads = new WorkerThread[poolSize];
86 for (int i = 0; i < poolSize; i++) {
/forgerock/openam-v13/openam-audit/openam-audit-context/src/main/java/org/forgerock/openam/audit/context/
H A DAuditRequestContextPropagatingExecutorServiceFactory.java46 public ScheduledExecutorService createScheduledService(int poolSize) { argument
47 return decorate(super.createScheduledService(poolSize));
/forgerock/openam/openam-core/src/main/java/com/sun/identity/entitlement/
H A DThreadPool.java57 private int poolSize; field in class:ThreadPool
70 * @param poolSize
74 public ThreadPool(String name, int poolSize) { argument
75 this.poolSize = poolSize;
78 threads = new WorkerThread[poolSize];
86 for (int i = 0; i < poolSize; i++) {
/forgerock/openam-v13/openam-core/src/main/java/com/iplanet/am/util/
H A DThreadPool.java55 private int poolSize; field in class:ThreadPool
71 * @param poolSize
81 public ThreadPool(String name, int poolSize, int threshold, boolean daemon, argument
84 this.poolSize = poolSize;
98 this.threads = new WorkerThread[poolSize];
101 + this.poolSize + "\nThreshold = " + threshold);
104 createThreads(poolSize);
114 if (threadsToCreate > poolSize) {
115 threadsToCreate = poolSize;
[all...]
/forgerock/openam-v13/openam-core/src/main/java/com/iplanet/services/comm/https/
H A DJSSThreadPool.java36 private int poolSize; field in class:JSSThreadPool
52 * @param poolSize
60 public JSSThreadPool(String name, int poolSize, boolean daemon, Debug debug) { argument
62 this.poolSize = poolSize;
73 this.threads = new WorkerThread[poolSize];
74 this.readerWriter = new ReaderWriterClear[poolSize];
76 createThreads(poolSize);
86 if (threadsToCreate > poolSize) {
87 threadsToCreate = poolSize;
[all...]
/forgerock/openam/openam-core/src/main/java/com/iplanet/am/util/
H A DThreadPool.java55 private int poolSize; field in class:ThreadPool
71 * @param poolSize
81 public ThreadPool(String name, int poolSize, int threshold, boolean daemon, argument
84 this.poolSize = poolSize;
98 this.threads = new WorkerThread[poolSize];
101 + this.poolSize + "\nThreshold = " + threshold);
104 createThreads(poolSize);
114 if (threadsToCreate > poolSize) {
115 threadsToCreate = poolSize;
[all...]
/forgerock/opendj-b2.6/src/server/org/opends/server/extensions/
H A DLDAPPassThroughAuthenticationPolicyFactory.java753 private final int poolSize = Runtime.getRuntime().availableProcessors() * 2; field in class:LDAPPassThroughAuthenticationPolicyFactory.ConnectionPool
754 private final Semaphore availableConnections = new Semaphore(poolSize);
794 if (availableConnections.availablePermits() != poolSize)
/forgerock/opendj2/src/server/org/opends/server/extensions/
H A DLDAPPassThroughAuthenticationPolicyFactory.java747 private final int poolSize = Runtime.getRuntime().availableProcessors() * 2; field in class:LDAPPassThroughAuthenticationPolicyFactory.ConnectionPool
748 private final Semaphore availableConnections = new Semaphore(poolSize);
788 if (availableConnections.availablePermits() != poolSize)
/forgerock/opendj2.6.2/src/server/org/opends/server/extensions/
H A DLDAPPassThroughAuthenticationPolicyFactory.java753 private final int poolSize = Runtime.getRuntime().availableProcessors() * 2; field in class:LDAPPassThroughAuthenticationPolicyFactory.ConnectionPool
754 private final Semaphore availableConnections = new Semaphore(poolSize);
794 if (availableConnections.availablePermits() != poolSize)
/forgerock/opendj2-jel-hg/src/server/org/opends/server/extensions/
H A DLDAPPassThroughAuthenticationPolicyFactory.java753 private final int poolSize = Runtime.getRuntime().availableProcessors() * 2; field in class:LDAPPassThroughAuthenticationPolicyFactory.ConnectionPool
754 private final Semaphore availableConnections = new Semaphore(poolSize);
794 if (availableConnections.availablePermits() != poolSize)
/forgerock/opendj2-hg/src/server/org/opends/server/extensions/
H A DLDAPPassThroughAuthenticationPolicyFactory.java747 private final int poolSize = Runtime.getRuntime().availableProcessors() * 2; field in class:LDAPPassThroughAuthenticationPolicyFactory.ConnectionPool
748 private final Semaphore availableConnections = new Semaphore(poolSize);
788 if (availableConnections.availablePermits() != poolSize)
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/extensions/
H A DLDAPPassThroughAuthenticationPolicyFactory.java728 private final int poolSize = Runtime.getRuntime().availableProcessors() * 2; field in class:LDAPPassThroughAuthenticationPolicyFactory.ConnectionPool
729 private final Semaphore availableConnections = new Semaphore(poolSize);
768 if (availableConnections.availablePermits() != poolSize)
/forgerock/openam-v13/openam-core/src/main/java/org/forgerock/openam/ldap/
H A DLDAPAuthUtils.java151 private static Set<String> poolSize = null; field in class:LDAPAuthUtils
186 poolSize = (Set<String>) attrs.get(CONNECTION_POOL_SIZE_ATTR);
294 if (poolSize != null && !poolSize.isEmpty()) {
298 for (String val : poolSize) {
/forgerock/openam/openam-core/src/main/java/org/forgerock/openam/ldap/
H A DLDAPAuthUtils.java152 private static Set<String> poolSize = null; field in class:LDAPAuthUtils
187 poolSize = (Set<String>) attrs.get(CONNECTION_POOL_SIZE_ATTR);
295 if (poolSize != null && !poolSize.isEmpty()) {
299 for (String val : poolSize) {
/forgerock/opendj-b2.6/tests/staf-tests/shared/java/ldapjdk/
H A Dldapjdk.jarMETA-INF/ META-INF/MANIFEST.MF com/netscape/sasl/mechanisms/SaslExternal.class SaslExternal.java ...
/forgerock/opendj2/tests/staf-tests/shared/java/ldapjdk/
H A Dldapjdk.jarMETA-INF/ META-INF/MANIFEST.MF com/netscape/sasl/mechanisms/SaslExternal.class SaslExternal.java ...

Completed in 77 milliseconds

12