Searched defs:queueSize (Results 1 - 25 of 59) sorted by relevance

123

/forgerock/openam/openam-notifications-integration/src/main/java/org/forgerock/openam/notifications/integration/
H A DNotificationsGuiceModule.java55 bindConstant().annotatedWith(Names.named("queueSize"))
56 .to(SystemProperties.getAsInt("org.forgerock.openam.notifications.local.queueSize", 10000));
65 .to(SystemProperties.getAsInt("org.forgerock.openam.notifications.cts.queueSize", 10000));
86 @Named("ctsQueueSize") int queueSize,
90 return new CTSNotificationBroker(store, broker, queueSize, tokenExpirySeconds,
84 notificationBroker(CTSPersistentStore store, @LocalOnly NotificationBroker broker, @Named(�) int queueSize, @Named(�) long tokenExpirySeconds, @Named(�) long publishFrequencyMilliseconds, AMExecutorServiceFactory factory) argument
/forgerock/openam-v13/openam-radius/openam-radius-server/src/main/java/org/forgerock/openam/radius/server/config/
H A DThreadPoolConfig.java32 private final int queueSize; field in class:ThreadPoolConfig
43 * @param queueSize
49 public ThreadPoolConfig(int core, int max, int queueSize, int keepAliveSeconds) { argument
66 if (queueSize < 1 || queueSize > 1000) {
67 this.queueSize = DEFAULT_QUEUE_SIZE;
69 + queueSize + "'. Using the default value of '" + DEFAULT_QUEUE_SIZE + "' instead.");
71 this.queueSize = queueSize;
100 * @return the queueSize
[all...]
/forgerock/openam-v13/openam-shared/src/main/java/org/forgerock/openam/shared/concurrency/
H A DResizableLinkedBlockingQueue.java34 private int queueSize; field in class:ResizableLinkedBlockingQueue
43 queueSize = Integer.MAX_VALUE;
44 availablePlaces = new ResizableSemaphore(queueSize, true);
59 queueSize = Integer.MAX_VALUE;
60 availablePlaces = new ResizableSemaphore(queueSize, true);
73 queueSize = initialCapacity;
91 if (newSize < queueSize) {
92 difference = queueSize - newSize;
94 } else if (newSize > queueSize) {
95 difference = newSize - queueSize;
[all...]
/forgerock/openam/openam-radius/openam-radius-server/src/main/java/org/forgerock/openam/radius/server/config/
H A DThreadPoolConfig.java32 private final int queueSize; field in class:ThreadPoolConfig
43 * @param queueSize
49 public ThreadPoolConfig(int core, int max, int queueSize, int keepAliveSeconds) { argument
66 if (queueSize < 1 || queueSize > 1000) {
67 this.queueSize = DEFAULT_QUEUE_SIZE;
69 + queueSize + "'. Using the default value of '" + DEFAULT_QUEUE_SIZE + "' instead.");
71 this.queueSize = queueSize;
100 * @return the queueSize
[all...]
/forgerock/openam/openam-shared/src/main/java/org/forgerock/openam/shared/concurrency/
H A DResizableLinkedBlockingQueue.java34 private int queueSize; field in class:ResizableLinkedBlockingQueue
43 queueSize = Integer.MAX_VALUE;
44 availablePlaces = new ResizableSemaphore(queueSize, true);
59 queueSize = Integer.MAX_VALUE;
60 availablePlaces = new ResizableSemaphore(queueSize, true);
73 queueSize = initialCapacity;
91 if (newSize < queueSize) {
92 difference = queueSize - newSize;
94 } else if (newSize > queueSize) {
95 difference = newSize - queueSize;
[all...]
/forgerock/opendj-b2.6/src/server/org/opends/server/replication/server/
H A DReplicationServerHandler.java132 * @param queueSize The queue size to manage updates to that RS.
140 int queueSize,
146 super(session, queueSize, replicationServerURL, replicationServerId,
138 ReplicationServerHandler( Session session, int queueSize, String replicationServerURL, int replicationServerId, ReplicationServer replicationServer, int rcvWindowSize) argument
H A DDataServerHandler.java86 * @param queueSize The queue size.
94 int queueSize,
100 super(session, queueSize, replicationServerURL, replicationServerId,
92 DataServerHandler( Session session, int queueSize, String replicationServerURL, int replicationServerId, ReplicationServer replicationServer, int rcvWindowSize) argument
H A DDbHandler.java131 * @param queueSize The queueSize to use when creating the dbHandler.
136 ReplicationDbEnv dbenv, int queueSize)
143 queueMaxSize = queueSize;
144 queueLowmark = queueSize / 5;
145 queueHimark = queueSize * 4 / 5;
134 DbHandler( int id, String baseDn, ReplicationServer replicationServer, ReplicationDbEnv dbenv, int queueSize) argument
/forgerock/opendj-b2.6/tests/unit-tests-testng/src/server/org/opends/server/replication/server/
H A DReplServerFakeConfiguration.java47 int queueSize; field in class:ReplServerFakeConfiguration
74 int queueSize, int windowSize, SortedSet<String> servers)
90 if (queueSize == 0)
92 this.queueSize = 10000;
96 this.queueSize = queueSize;
116 int queueSize, int windowSize, SortedSet<String> servers,
119 this(port, dirName, purgeDelay, serverId, queueSize, windowSize, servers);
130 int queueSize, int windowSize, SortedSet<String> servers,
133 this(port, dirName, purgeDelay, serverId, queueSize, windowSiz
72 ReplServerFakeConfiguration( int port, String dirName, int purgeDelay, int serverId, int queueSize, int windowSize, SortedSet<String> servers) argument
114 ReplServerFakeConfiguration( int port, String dirName, int purgeDelay, int serverId, int queueSize, int windowSize, SortedSet<String> servers, int groupId, long assuredTimeout, int degradedStatusThreshold) argument
128 ReplServerFakeConfiguration( int port, String dirName, int purgeDelay, int serverId, int queueSize, int windowSize, SortedSet<String> servers, int groupId, long assuredTimeout, int degradedStatusThreshold, int weight) argument
[all...]
/forgerock/opendj-b2.6/tests/staf-tests/shared/java/ldapjdk/
H A DEclReadAndPlay.java72 static int queueSize = 0; field in class:EclReadAndPlay
135 queueSize = Integer.parseInt(val);
181 if ( eclMode == null || queueSize == 0 || bindDn == null ||
236 BlockingQueue<Change> queue = new ArrayBlockingQueue<Change>(queueSize);
/forgerock/opendj2/src/server/org/opends/server/replication/server/
H A DDataServerHandler.java73 * @param queueSize The queue size.
79 int queueSize,
83 super(session, queueSize, replicationServer, rcvWindowSize);
77 DataServerHandler( Session session, int queueSize, ReplicationServer replicationServer, int rcvWindowSize) argument
H A DReplicationServerHandler.java129 * @param queueSize The queue size to manage updates to that RS.
135 int queueSize,
139 super(session, queueSize, replicationServer, rcvWindowSize);
133 ReplicationServerHandler( Session session, int queueSize, ReplicationServer replicationServer, int rcvWindowSize) argument
/forgerock/opendj2/tests/staf-tests/shared/java/ldapjdk/
H A DEclReadAndPlay.java71 static int queueSize = 0; field in class:EclReadAndPlay
134 queueSize = Integer.parseInt(val);
180 if ( eclMode == null || queueSize == 0 || bindDn == null ||
235 BlockingQueue<Change> queue = new ArrayBlockingQueue<Change>(queueSize);
/forgerock/opendj2.6.2/src/server/org/opends/server/replication/server/
H A DDataServerHandler.java85 * @param queueSize The queue size.
93 int queueSize,
99 super(session, queueSize, replicationServerURL, replicationServerId,
91 DataServerHandler( Session session, int queueSize, String replicationServerURL, int replicationServerId, ReplicationServer replicationServer, int rcvWindowSize) argument
H A DReplicationServerHandler.java132 * @param queueSize The queue size to manage updates to that RS.
140 int queueSize,
146 super(session, queueSize, replicationServerURL, replicationServerId,
138 ReplicationServerHandler( Session session, int queueSize, String replicationServerURL, int replicationServerId, ReplicationServer replicationServer, int rcvWindowSize) argument
/forgerock/opendj2.6.2/tests/unit-tests-testng/src/server/org/opends/server/replication/server/
H A DReplServerFakeConfiguration.java49 int queueSize; field in class:ReplServerFakeConfiguration
76 int queueSize, int windowSize, SortedSet<String> servers)
92 if (queueSize == 0)
94 this.queueSize = 10000;
98 this.queueSize = queueSize;
118 int queueSize, int windowSize, SortedSet<String> servers,
121 this(port, dirName, purgeDelay, serverId, queueSize, windowSize, servers);
132 int queueSize, int windowSize, SortedSet<String> servers,
135 this(port, dirName, purgeDelay, serverId, queueSize, windowSiz
74 ReplServerFakeConfiguration( int port, String dirName, int purgeDelay, int serverId, int queueSize, int windowSize, SortedSet<String> servers) argument
116 ReplServerFakeConfiguration( int port, String dirName, int purgeDelay, int serverId, int queueSize, int windowSize, SortedSet<String> servers, int groupId, long assuredTimeout, int degradedStatusThreshold) argument
130 ReplServerFakeConfiguration( int port, String dirName, int purgeDelay, int serverId, int queueSize, int windowSize, SortedSet<String> servers, int groupId, long assuredTimeout, int degradedStatusThreshold, int weight) argument
[all...]
/forgerock/opendj2.6.2/tests/staf-tests/shared/java/ldapjdk/
H A DEclReadAndPlay.java72 static int queueSize = 0; field in class:EclReadAndPlay
135 queueSize = Integer.parseInt(val);
181 if ( eclMode == null || queueSize == 0 || bindDn == null ||
236 BlockingQueue<Change> queue = new ArrayBlockingQueue<Change>(queueSize);
/forgerock/opendj2-jel-hg/tests/staf-tests/shared/java/ldapjdk/
H A DEclReadAndPlay.java72 static int queueSize = 0; field in class:EclReadAndPlay
135 queueSize = Integer.parseInt(val);
181 if ( eclMode == null || queueSize == 0 || bindDn == null ||
236 BlockingQueue<Change> queue = new ArrayBlockingQueue<Change>(queueSize);
/forgerock/opendj2-hg/tests/staf-tests/shared/java/ldapjdk/
H A DEclReadAndPlay.java71 static int queueSize = 0; field in class:EclReadAndPlay
134 queueSize = Integer.parseInt(val);
180 if ( eclMode == null || queueSize == 0 || bindDn == null ||
235 BlockingQueue<Change> queue = new ArrayBlockingQueue<Change>(queueSize);
/forgerock/opendj2-jel-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/server/
H A DReplServerFakeConfiguration.java47 int queueSize; field in class:ReplServerFakeConfiguration
74 int queueSize, int windowSize, SortedSet<String> servers)
90 if (queueSize == 0)
92 this.queueSize = 10000;
96 this.queueSize = queueSize;
116 int queueSize, int windowSize, SortedSet<String> servers,
119 this(port, dirName, purgeDelay, serverId, queueSize, windowSize, servers);
130 int queueSize, int windowSize, SortedSet<String> servers,
133 this(port, dirName, purgeDelay, serverId, queueSize, windowSiz
72 ReplServerFakeConfiguration( int port, String dirName, int purgeDelay, int serverId, int queueSize, int windowSize, SortedSet<String> servers) argument
114 ReplServerFakeConfiguration( int port, String dirName, int purgeDelay, int serverId, int queueSize, int windowSize, SortedSet<String> servers, int groupId, long assuredTimeout, int degradedStatusThreshold) argument
128 ReplServerFakeConfiguration( int port, String dirName, int purgeDelay, int serverId, int queueSize, int windowSize, SortedSet<String> servers, int groupId, long assuredTimeout, int degradedStatusThreshold, int weight) argument
[all...]
/forgerock/opendj2-jel-hg/src/server/org/opends/server/replication/server/
H A DReplicationServerHandler.java132 * @param queueSize The queue size to manage updates to that RS.
140 int queueSize,
146 super(session, queueSize, replicationServerURL, replicationServerId,
138 ReplicationServerHandler( Session session, int queueSize, String replicationServerURL, int replicationServerId, ReplicationServer replicationServer, int rcvWindowSize) argument
/forgerock/opendj2-hg/src/server/org/opends/server/replication/server/
H A DDataServerHandler.java73 * @param queueSize The queue size.
79 int queueSize,
83 super(session, queueSize, replicationServer, rcvWindowSize);
77 DataServerHandler( Session session, int queueSize, ReplicationServer replicationServer, int rcvWindowSize) argument
H A DReplicationServerHandler.java129 * @param queueSize The queue size to manage updates to that RS.
135 int queueSize,
139 super(session, queueSize, replicationServer, rcvWindowSize);
133 ReplicationServerHandler( Session session, int queueSize, ReplicationServer replicationServer, int rcvWindowSize) argument
/forgerock/openam/openam-notifications/src/main/java/org/forgerock/openam/notifications/brokers/
H A DInMemoryNotificationBroker.java75 * @param queueSize the number of notifications to buffer in memory
79 @Named("queueSize") int queueSize, @Named("consumers") int consumers) {
82 Reject.ifTrue(queueSize <= 0, "Queue size must be a positive integer");
87 queue = new ArrayBlockingQueue<>(queueSize);
78 InMemoryNotificationBroker(AMExecutorServiceFactory executorServiceFactory, TimeService timeService, @Named(�) int queueSize, @Named(�) int consumers) argument
/forgerock/openam/openam-notifications-integration/src/main/java/org/forgerock/openam/notifications/integration/brokers/
H A DCTSNotificationBroker.java101 * @param queueSize the size of the queue of notifications waiting to be written to the CTS
109 @Named("ctsQueueSize") int queueSize,
125 queue = new ArrayBlockingQueue<>(queueSize);
107 CTSNotificationBroker(CTSPersistentStore store, @Named(�) NotificationBroker localBroker, @Named(�) int queueSize, @Named(�) long tokenExpirySeconds, @Named(�) long publishFrequencyMilliseconds, AMExecutorServiceFactory executorServiceFactory) argument

Completed in 165 milliseconds

123