/forgerock/openam/openam-notifications-integration/src/main/java/org/forgerock/openam/notifications/integration/ |
H A D | NotificationsGuiceModule.java | 55 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 D | ThreadPoolConfig.java | 32 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 D | ResizableLinkedBlockingQueue.java | 34 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 D | ThreadPoolConfig.java | 32 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 D | ResizableLinkedBlockingQueue.java | 34 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 D | ReplicationServerHandler.java | 132 * @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 D | DataServerHandler.java | 86 * @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 D | DbHandler.java | 131 * @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 D | ReplServerFakeConfiguration.java | 47 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 D | EclReadAndPlay.java | 72 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 D | DataServerHandler.java | 73 * @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 D | ReplicationServerHandler.java | 129 * @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 D | EclReadAndPlay.java | 71 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 D | DataServerHandler.java | 85 * @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 D | ReplicationServerHandler.java | 132 * @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 D | ReplServerFakeConfiguration.java | 49 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 D | EclReadAndPlay.java | 72 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 D | EclReadAndPlay.java | 72 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 D | EclReadAndPlay.java | 71 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 D | ReplServerFakeConfiguration.java | 47 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 D | ReplicationServerHandler.java | 132 * @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 D | DataServerHandler.java | 73 * @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 D | ReplicationServerHandler.java | 129 * @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 D | InMemoryNotificationBroker.java | 75 * @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 D | CTSNotificationBroker.java | 101 * @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
|