/forgerock/openam-v13/openam-radius/openam-radius-server/src/main/java/org/forgerock/openam/radius/server/ |
H A D | DroppedRequestHandler.java | 39 * @param executor 40 * the executor 43 public void rejectedExecution(Runnable r, ThreadPoolExecutor executor) { argument
|
/forgerock/openam/openam-radius/openam-radius-server/src/main/java/org/forgerock/openam/radius/server/ |
H A D | DroppedRequestHandler.java | 39 * @param executor 40 * the executor 43 public void rejectedExecution(Runnable r, ThreadPoolExecutor executor) { argument
|
/forgerock/openam-v13/openam-core/src/test/java/org/forgerock/openam/sm/datalayer/impl/ |
H A D | SimpleTaskExecutorTest.java | 37 private SimpleTaskExecutor<Closeable> executor; field in class:SimpleTaskExecutorTest 45 executor = new SimpleTaskExecutor<Closeable>(connectionFactory, mock(Debug.class), adapter); 55 executor.start(); 58 executor.execute(null, task); 69 executor.start(); 72 executor.finalize(); 84 executor.start(); 87 executor.execute(null, mock(Task.class)); 88 executor.execute(null, mock(Task.class));
|
H A D | SeriesTaskExecutorTest.java | 43 private SeriesTaskExecutor executor; field in class:SeriesTaskExecutorTest 56 executor = new SeriesTaskExecutor(executorService, processorFactory, monitor, configuration, mock(Debug.class)); 72 executor.start(); 88 executor.start(); 91 executor.execute("123", mock(Task.class)); 107 executor.start(); 108 executor.execute("123", task); // First create fills the queue 113 executor.execute("123", task); // Second create causes timeout.
|
H A D | PooledTaskExecutorTest.java | 72 final TaskExecutor executor = new PooledTaskExecutor(simpleTaskExecutorProvider, debug, 75 TaskThread task1 = new TaskThread(1, executor, longTask1); 77 TaskThread task2 = new TaskThread(2, executor, longTask2); 78 TaskThread task3 = new TaskThread(3, executor, mock(Task.class)); 128 private TaskExecutor executor; field in class:PooledTaskExecutorTest.TaskThread 131 TaskThread(int taskId, TaskExecutor executor, Task task) { argument 132 this.executor = executor; 140 executor.execute(null, task);
|
/forgerock/openam/openam-core/src/test/java/org/forgerock/openam/sm/datalayer/impl/ |
H A D | SimpleTaskExecutorTest.java | 30 private SimpleTaskExecutor executor; field in class:SimpleTaskExecutorTest 36 executor = new SimpleTaskExecutor(mock(Debug.class), adapter); 43 executor.start(); 46 executor.execute(null, task);
|
H A D | SeriesTaskExecutorTest.java | 43 private SeriesTaskExecutor executor; field in class:SeriesTaskExecutorTest 56 executor = new SeriesTaskExecutor(executorService, processorFactory, monitor, configuration, mock(Debug.class)); 72 executor.start(); 88 executor.start(); 91 executor.execute("123", mock(Task.class)); 107 executor.start(); 108 executor.execute("123", task); // First create fills the queue 113 executor.execute("123", task); // Second create causes timeout.
|
H A D | PooledTaskExecutorTest.java | 73 final TaskExecutor executor = new PooledTaskExecutor(simpleTaskExecutorProvider, debug, 76 TaskThread task1 = new TaskThread(1, executor, longTask1); 78 TaskThread task2 = new TaskThread(2, executor, longTask2); 79 TaskThread task3 = new TaskThread(3, executor, mock(Task.class)); 129 private TaskExecutor executor; field in class:PooledTaskExecutorTest.TaskThread 132 TaskThread(int taskId, TaskExecutor executor, Task task) { argument 133 this.executor = executor; 141 executor.execute(null, task);
|
/forgerock/openidm-v4/openidm-smartevent/src/main/java/org/forgerock/openidm/smartevent/core/ |
H A D | DisruptorReferringPublisher.java | 55 static Executor executor = Executors.newCachedThreadPool(); field in class:DisruptorReferringPublisher 58 RING_SIZE, executor, ProducerType.MULTI, new SleepingWaitStrategy());
|
H A D | DisruptorShortPublisher.java | 55 static Executor executor = Executors.newCachedThreadPool(); field in class:DisruptorShortPublisher 57 DisruptorShortEventEntry.EVENT_FACTORY,RING_SIZE, executor, ProducerType.SINGLE, new SleepingWaitStrategy());
|
/forgerock/opendj-v3/opendj-maven-plugin/src/main/java/org/forgerock/opendj/maven/ |
H A D | GenerateConfigMojo.java | 226 final Templates stylesheet, final ExecutorService executor, final String... parameters) 228 final Future<Void> future = executor.submit(new Callable<Void>() { 245 final ExecutorService executor, final String... parameters) throws Exception { 249 createTransformTask(inputFactory, output, stylesheet, executor, parameters); 265 * serialized by using a single threaded executor. 225 createTransformTask(final StreamSourceFactory inputFactory, final StreamResult output, final Templates stylesheet, final ExecutorService executor, final String... parameters) argument 243 createTransformTask(final StreamSourceFactory inputFactory, final String outputFileName, final Templates stylesheet, final ExecutorService executor, final String... parameters) argument
|
/forgerock/openidm-v4/openidm-scheduler/src/main/java/org/forgerock/openidm/scheduler/impl/ |
H A D | TaskScannerJob.java | 74 final ExecutorService executor = Executors.newFixedThreadPool(numberOfThreads); 78 performTask(executor); 82 executor.shutdown(); 91 performTask(executor); 95 executor.shutdown(); 109 * @param executor ExecutorService in which to invoke this task. 112 private void performTask(ExecutorService executor) argument 155 executor.invokeAll(todo);
|
/forgerock/openidm-v4/openidm-core/src/main/java/org/forgerock/openidm/sync/impl/ |
H A D | ReconciliationContext.java | 56 private ExecutorService executor; field in class:ReconciliationContext 99 // Initialize the executor for this recon, or null if no executor should be used 102 executor = Executors.newFixedThreadPool(noOfThreads); 104 executor = null; 262 * @return the executor for this recon, or null if no executor should be used 265 return executor; 392 if (executor != null) { 393 executor [all...] |
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/backends/pluggable/ |
H A D | OnDiskMergeImporter.java | 548 private final ExecutorService executor; field in class:OnDiskMergeImporter.LDIFReaderSource 562 this.executor = Executors.newFixedThreadPool(nbThreads, newThreadFactory(null, threadNameTemplate, true)); 571 final CompletionService<Void> completion = new ExecutorCompletionService<>(executor); 619 executor.shutdown(); 689 private final ExecutorService executor; field in class:OnDiskMergeImporter.ID2EntrySource 702 this.executor = 709 public void rejectedExecution(Runnable r, ThreadPoolExecutor executor) 714 executor.getQueue().put(r); 737 executor.submit(new Runnable() 759 executor [all...] |
/forgerock/authenticator-android-v2/app/libs/ |
H A D | picasso-2.4.0.jar | META-INF/ META-INF/MANIFEST.MF com/ com/squareup/ com/squareup/picasso/ com/squareup/picasso/Action ... |
/forgerock/openam-v13/openam-oauth/samples/StockClient/lib/ |
H A D | javaee.jar | META-INF/ META-INF/MANIFEST.MF javax/ javax/servlet/ javax/servlet/jsp/ javax/servlet/jsp/jstl/ ... |
/forgerock/openam-v13/openam-oauth/samples/StockService/lib/ |
H A D | javaee.jar | META-INF/ META-INF/MANIFEST.MF javax/ javax/servlet/ javax/servlet/jsp/ javax/servlet/jsp/jstl/ ... |