/forgerock/openam-v13/openam-core/src/main/java/com/iplanet/dpro/session/monitoring/ |
H A D | SessionMonitoringStore.java | 44 private final ExecutorService executorService; field in class:SessionMonitoringStore 52 * @param executorService the service to which to offload out writes 55 public SessionMonitoringStore(@Named(EXECUTOR_BINDING_NAME) ExecutorService executorService, argument 57 this.executorService = executorService; 69 * @param executorService Service to perform writes with 76 SessionMonitoringStore(ExecutorService executorService, argument 82 this.executorService = executorService; 98 executorService [all...] |
/forgerock/openam-v13/openam-scripting/src/main/java/org/forgerock/openam/scripting/ |
H A D | ThreadPoolScriptEvaluator.java | 129 private final ExecutorService executorService; field in class:ThreadPoolScriptEvaluator.ThreadPoolConfigurator 131 ThreadPoolConfigurator(final ExecutorService executorService) { argument 132 this.executorService = executorService; 138 ExecutorServiceConfigurator delegateConfigurator = getDelegateConfigurator(executorService); 152 executorService) 185 private ExecutorServiceConfigurator getDelegateConfigurator(ExecutorService executorService) { argument 187 if (executorService instanceof ThreadPoolExecutor) { 188 return new ExecutorServiceConfigurator((ThreadPoolExecutor) executorService); 190 } else if (executorService instanceo [all...] |
/forgerock/openam/openam-scripting/src/main/java/org/forgerock/openam/scripting/ |
H A D | ThreadPoolScriptEvaluator.java | 129 private final ExecutorService executorService; field in class:ThreadPoolScriptEvaluator.ThreadPoolConfigurator 131 ThreadPoolConfigurator(final ExecutorService executorService) { argument 132 this.executorService = executorService; 138 ExecutorServiceConfigurator delegateConfigurator = getDelegateConfigurator(executorService); 152 executorService) 185 private ExecutorServiceConfigurator getDelegateConfigurator(ExecutorService executorService) { argument 187 if (executorService instanceof ThreadPoolExecutor) { 188 return new ExecutorServiceConfigurator((ThreadPoolExecutor) executorService); 190 } else if (executorService instanceo [all...] |
/forgerock/openam/openam-core/src/main/java/com/iplanet/dpro/session/monitoring/ |
H A D | SessionMonitoringStore.java | 44 private final ExecutorService executorService; field in class:SessionMonitoringStore 52 * @param executorService the service to which to offload out writes 55 public SessionMonitoringStore(@Named(EXECUTOR_BINDING_NAME) ExecutorService executorService, argument 57 this.executorService = executorService; 69 * @param executorService Service to perform writes with 76 SessionMonitoringStore(ExecutorService executorService, argument 82 this.executorService = executorService; 98 executorService [all...] |
/forgerock/openam/openam-core/src/main/java/com/iplanet/dpro/session/service/ |
H A D | SessionTimeoutHandlerExecutor.java | 64 private final ExecutorService executorService; field in class:SessionTimeoutHandlerExecutor 69 final @Named(EXECUTOR_BINDING_NAME) ExecutorService executorService, 73 this.executorService = executorService; 132 futures.add(executorService.submit(timeoutTask)); // This should not throw any exceptions. 67 SessionTimeoutHandlerExecutor( final @Named(SESSION_DEBUG) Debug sessionDebug, final @Named(EXECUTOR_BINDING_NAME) ExecutorService executorService, final SSOTokenManager ssoTokenManager, final SessionServiceConfig serviceConfig) argument
|
/forgerock/openam-v13/openam-core/src/main/java/org/forgerock/openam/entitlement/monitoring/ |
H A D | PolicyMonitorImpl.java | 54 private final ExecutorService executorService; field in class:PolicyMonitorImpl 61 * @param executorService The executor service this module should use when passing off the adding of new data 70 @Named(EXECUTOR_BINDING_NAME) ExecutorService executorService, 77 this.executorService = executorService; 94 executorService.submit(new Runnable() { 107 executorService.submit(new Runnable() { 127 executorService.submit(new Callable<Void>() { 69 PolicyMonitorImpl(@amedPOLICY_MONITOR_DEBUG) Debug debug, @Named(EXECUTOR_BINDING_NAME) ExecutorService executorService, final EvaluationMonitoringStore selfEvaluationMonitoringStore, final EvaluationTimingStore selfEvaluationTimingStore, final EvaluationMonitoringStore subtreeEvaluationMonitoringStore, final EvaluationTimingStore subtreeEvaluationTimingStore, final InternalEvaluationTimingStore internalEvaluationTimingStore) argument
|
/forgerock/openam/openam-core/src/main/java/org/forgerock/openam/entitlement/monitoring/ |
H A D | PolicyMonitorImpl.java | 54 private final ExecutorService executorService; field in class:PolicyMonitorImpl 61 * @param executorService The executor service this module should use when passing off the adding of new data 70 @Named(EXECUTOR_BINDING_NAME) ExecutorService executorService, 77 this.executorService = executorService; 94 executorService.submit(new Runnable() { 107 executorService.submit(new Runnable() { 127 executorService.submit(new Callable<Void>() { 69 PolicyMonitorImpl(@amedPOLICY_MONITOR_DEBUG) Debug debug, @Named(EXECUTOR_BINDING_NAME) ExecutorService executorService, final EvaluationMonitoringStore selfEvaluationMonitoringStore, final EvaluationTimingStore selfEvaluationTimingStore, final EvaluationMonitoringStore subtreeEvaluationMonitoringStore, final EvaluationTimingStore subtreeEvaluationTimingStore, final InternalEvaluationTimingStore internalEvaluationTimingStore) argument
|
/forgerock/openam/openam-notifications/src/test/java/org/forgerock/openam/notifications/ |
H A D | InMemoryNotificationBrokerTest.java | 51 private ExecutorService executorService; field in class:InMemoryNotificationBrokerTest 67 when(executorServiceFactory.createFixedThreadPool(anyInt(), anyString())).thenReturn(executorService); 81 verify(executorService, times(CONSUMERS)).submit(readerCapture.capture()); 106 verify(executorService, times(CONSUMERS)).submit(readerCapture.capture()); 126 verify(executorService, times(CONSUMERS)).submit(readerCapture.capture()); 148 verify(executorService, times(CONSUMERS)).submit(readerCapture.capture()); 209 verify(executorService, times(CONSUMERS)).submit(readerCapture.capture()); 231 verify(executorService, times(CONSUMERS)).submit(readerCapture.capture()); 255 verify(executorService, times(CONSUMERS)).submit(readerCapture.capture()); 278 verify(executorService, time [all...] |
/forgerock/openam-v13/openam-radius/openam-radius-server/src/main/java/org/forgerock/openam/radius/server/ |
H A D | RadiusRequestListener.java | 87 private final ExecutorService executorService; field in class:RadiusRequestListener 104 * @param executorService the thread pool executor to process radius requests. 111 final ExecutorService executorService, 117 this.executorService = executorService; 190 executorService.shutdown(); 201 finished = executorService.awaitTermination(RadiusServerConstants.THREAD_POOL_SHUTDOWN_WAIT_SECONDS, 204 LOG.warning("InterruptedException caught while waiting for executorService to terminate."); 289 executorService.execute(requestHandler); 110 RadiusRequestListener(final RadiusServiceConfig config, final ExecutorService executorService, final EventBus eventBus, final AccessRequestHandlerFactory accessRequestHandlerFactory) argument
|
H A D | RequestListenerFactory.java | 90 final ExecutorService executorService = executorServiceFactory.createThreadPool(coreSize, maxSize, idleTimeout, 92 return new RadiusRequestListener(serviceConfig, executorService, eventBus, accessRequestHandlerFactory);
|
/forgerock/openam/openam-radius/openam-radius-server/src/main/java/org/forgerock/openam/radius/server/ |
H A D | RadiusRequestListener.java | 89 private final ExecutorService executorService; field in class:RadiusRequestListener 106 * @param executorService the thread pool executor to process radius requests. 113 final ExecutorService executorService, 119 this.executorService = executorService; 212 executorService.shutdown(); 223 finished = executorService.awaitTermination(RadiusServerConstants.THREAD_POOL_SHUTDOWN_WAIT_SECONDS, 226 LOG.warning("InterruptedException caught while waiting for executorService to terminate."); 311 executorService.execute(requestHandler); 112 RadiusRequestListener(final RadiusServiceConfig config, final ExecutorService executorService, final EventBus eventBus, final AccessRequestHandlerFactory accessRequestHandlerFactory) argument
|
H A D | RequestListenerFactory.java | 87 final ExecutorService executorService = executorServiceFactory.createThreadPool(coreSize, maxSize, idleTimeout, 89 return new RadiusRequestListener(serviceConfig, executorService, eventBus, accessRequestHandlerFactory);
|
/forgerock/openam-v13/openam-core/src/main/java/org/forgerock/openam/cts/monitoring/impl/ |
H A D | CTSMonitoringStoreImpl.java | 56 private final ExecutorService executorService; field in class:CTSMonitoringStoreImpl 64 * @param executorService An instance of an ExecutorService. 69 public CTSMonitoringStoreImpl(@Named(EXECUTOR_BINDING_NAME) final ExecutorService executorService, argument 75 this.executorService = executorService; 92 executorService.submit(new Callable<Void>() { 109 executorService.submit(new Callable<Void>() {
|
/forgerock/openam/openam-notifications-websocket/src/main/java/org/forgerock/openam/notifications/websocket/ |
H A D | NotificationsWebSocket.java | 79 private final ScheduledExecutorService executorService; field in class:NotificationsWebSocket 91 executorService = null; 101 @Named("webSocketScheduledExecutorService") ScheduledExecutorService executorService) { 105 this.executorService = executorService; 119 pingFuture = executorService.scheduleAtFixedRate(new Runnable() { 100 NotificationsWebSocket(NotificationBroker broker, TimeService timeService, @Named(�) ScheduledExecutorService executorService) argument
|
/forgerock/openam/openam-shared/src/test/java/org/forgerock/openam/shared/concurrency/ |
H A D | ThreadMonitorTest.java | 182 ExecutorService executorService = null; 184 executorService = Executors.newCachedThreadPool(); 186 executorService, 206 monitor.watchThread(executorService, mockRunnable); 215 if (executorService != null) { 216 executorService.shutdown();
|
/forgerock/openam/openam-core/src/main/java/org/forgerock/openam/cts/monitoring/impl/ |
H A D | CTSMonitoringStoreImpl.java | 56 private final ExecutorService executorService; field in class:CTSMonitoringStoreImpl 64 * @param executorService An instance of an ExecutorService. 69 public CTSMonitoringStoreImpl(@Named(EXECUTOR_BINDING_NAME) final ExecutorService executorService, argument 75 this.executorService = executorService; 92 executorService.submit(new Callable<Void>() { 109 executorService.submit(new Callable<Void>() {
|
/forgerock/openam-v13/openam-core/src/test/java/org/forgerock/openam/sm/datalayer/impl/ |
H A D | SeriesTaskExecutorTest.java | 42 private ExecutorService executorService; field in class:SeriesTaskExecutorTest 50 executorService = mock(ExecutorService.class); 56 executor = new SeriesTaskExecutor(executorService, processorFactory, monitor, configuration, mock(Debug.class));
|
/forgerock/openam/openam-core/src/test/java/org/forgerock/openam/sm/datalayer/impl/ |
H A D | SeriesTaskExecutorTest.java | 42 private ExecutorService executorService; field in class:SeriesTaskExecutorTest 50 executorService = mock(ExecutorService.class); 56 executor = new SeriesTaskExecutor(executorService, processorFactory, monitor, configuration, mock(Debug.class));
|
/forgerock/openam/openam-notifications/src/main/java/org/forgerock/openam/notifications/brokers/ |
H A D | InMemoryNotificationBroker.java | 67 private final ExecutorService executorService; field in class:InMemoryNotificationBroker 89 executorService = executorServiceFactory.createFixedThreadPool(consumers, "InMemoryNotificationsBroker"); 91 executorService.submit(new NotificationReader()); 135 executorService.shutdownNow();
|
/forgerock/openam/openam-core-rest/src/main/java/org/forgerock/openam/core/rest/docs/api/ |
H A D | ApiDocsService.java | 215 ExecutorService executorService = new ThreadPoolExecutor(1, 1, 0, SECONDS, new LinkedBlockingQueue<Runnable>()); 216 final Future<ApiDescription> description = executorService.submit(new Callable<ApiDescription>() { 232 final Future<File> asciidoc = executorService.submit(new Callable<File>() { 246 final Future<File> docs = executorService.submit(new Callable<File>() { 260 executorService.shutdown();
|
/forgerock/openam/openam-notifications-integration/src/main/java/org/forgerock/openam/notifications/integration/brokers/ |
H A D | CTSNotificationBroker.java | 93 private final ScheduledExecutorService executorService; field in class:CTSNotificationBroker 122 executorService = executorServiceFactory.createScheduledService(1, "CTSNotificationsBroker"); 127 executorService.scheduleAtFixedRate(new CTSPublisher(), publishFrequencyMilliseconds, 162 executorService.shutdownNow();
|
/forgerock/openam-v13/openam-core/src/test/java/org/forgerock/openam/cts/monitoring/ |
H A D | CTSMonitoringStoreImplTest.java | 54 final ExecutorService executorService = mock(ExecutorService.class); 60 executorService, 67 given(executorService.submit(any(Callable.class))).will(new Answer<Object>() {
|
/forgerock/openam/openam-core/src/test/java/org/forgerock/openam/cts/monitoring/ |
H A D | CTSMonitoringStoreImplTest.java | 54 final ExecutorService executorService = mock(ExecutorService.class); 60 executorService, 67 given(executorService.submit(any(Callable.class))).will(new Answer<Object>() {
|
/forgerock/openam/openam-notifications-websocket/src/test/java/org/forgerock/openam/notifications/websocket/ |
H A D | NotificationsWebSocketTest.java | 74 private ScheduledExecutorService executorService; field in class:NotificationsWebSocketTest 86 notificationsWebSocket = new NotificationsWebSocket(broker, timeService, executorService); 115 verify(executorService).scheduleAtFixedRate(any(Runnable.class), eq(30 * 1000L), eq(30 * 1000L), 124 verify(executorService).scheduleAtFixedRate(runnableCaptor.capture(), anyLong(), anyLong(), 373 when(executorService.scheduleAtFixedRate(any(Runnable.class), anyLong(), anyLong(), any(TimeUnit.class)))
|
/forgerock/openam/openam-notifications-integration/src/test/java/org/forgerock/openam/notifications/brokers/ |
H A D | CTSNotificationBrokerTest.java | 74 private ScheduledExecutorService executorService; field in class:CTSNotificationBrokerTest 90 when(executorServiceFactory.createScheduledService(anyInt(), anyString())).thenReturn(executorService); 101 verify(executorService).scheduleAtFixedRate(any(Runnable.class), eq(100L), eq(100L), eq(TimeUnit.MILLISECONDS)); 295 verify(executorService).scheduleAtFixedRate(publisherTaskCaptor.capture(), anyLong(), anyLong(),
|