/forgerock/openam/openam-core/src/main/java/org/forgerock/openam/sm/datalayer/api/ |
H A D | Task.java | 19 * Represents a Task which can be performed by a the implementation. 21 * enough state to be processed by the Task Processor. 25 public interface Task { interface
|
H A D | QueueTimeoutException.java | 22 * Task on the queue. 30 public QueueTimeoutException(Task task) { 33 "Task: {0}", 43 public QueueTimeoutException(Task task, InterruptedException error) { 46 "Task: {0}",
|
H A D | TaskExecutor.java | 29 void execute(String tokenId, Task task) throws DataLayerException;
|
/forgerock/openam-v13/openam-core/src/main/java/org/forgerock/openam/sm/datalayer/api/ |
H A D | QueueTimeoutException.java | 22 * Task on the queue. 30 public QueueTimeoutException(Task task) { 33 "Task: {0}", 43 public QueueTimeoutException(Task task, InterruptedException error) { 46 "Task: {0}",
|
H A D | Task.java | 20 * Represents a Task which can be performed by a the implementation. 22 * enough state to be processed by the Task Processor. 26 public interface Task { interface
|
H A D | TaskExecutor.java | 28 void execute(String tokenId, Task task) throws DataLayerException;
|
/forgerock/openam-v13/openam-core/src/main/java/org/forgerock/openam/sm/datalayer/impl/tasks/ |
H A D | TaskFactory.java | 23 import org.forgerock.openam.sm.datalayer.api.Task; 27 * Generates instances of specific Task implementations. 31 * @see org.forgerock.openam.sm.datalayer.api.Task 39 * @return Non null Token creation Task. 41 public Task create(Token token, ResultHandler<Token, ?> handler) { 49 * @return Non null Token read Task. 51 public Task read(String tokenId, ResultHandler<Token, ?> handler) { 58 * @return Non null Token update Task. 60 public Task update(Token token, ResultHandler<Token, ?> handler) { 67 * @return Non null Token delete Task [all...] |
/forgerock/openam-v13/openam-core/src/test/java/org/forgerock/openam/sm/datalayer/impl/ |
H A D | SeriesTaskExecutorThreadTest.java | 22 import org.forgerock.openam.sm.datalayer.api.Task; 57 processor.setQueue(generateTestQueue(mock(Task.class))); 69 Task mockTask = mock(Task.class); 79 private BlockingQueue<Task> generateTestQueue(final Task first) throws InterruptedException { 80 BlockingQueue<Task> queue = mock(BlockingQueue.class);
|
/forgerock/openam/openam-core/src/main/java/org/forgerock/openam/sm/datalayer/impl/tasks/ |
H A D | TaskFactory.java | 23 import org.forgerock.openam.sm.datalayer.api.Task; 28 * Generates instances of specific Task implementations. 32 * @see org.forgerock.openam.sm.datalayer.api.Task 42 * @return Non null. Token creation Task. 44 public Task create(Token token, Options options, ResultHandler<Token, ?> handler) { 54 * @return Non null. Token read Task. 56 public Task read(String tokenId, Options options, ResultHandler<Token, ?> handler) { 65 * @return Non null. Token update Task. 67 public Task update(Token token, Options options, ResultHandler<Token, ?> handler) { 76 * @return Non null. Token delete Task [all...] |
/forgerock/openam/openam-core/src/test/java/org/forgerock/openam/sm/datalayer/impl/ |
H A D | SeriesTaskExecutorThreadTest.java | 22 import org.forgerock.openam.sm.datalayer.api.Task; 57 processor.setQueue(generateTestQueue(mock(Task.class))); 69 Task mockTask = mock(Task.class); 79 private BlockingQueue<Task> generateTestQueue(final Task first) throws InterruptedException { 80 BlockingQueue<Task> queue = mock(BlockingQueue.class);
|
H A D | SimpleTaskExecutorTest.java | 21 import org.forgerock.openam.sm.datalayer.api.Task; 42 Task task = mock(Task.class);
|
/forgerock/openam-v13/openam-core/src/test/java/org/forgerock/openam/cts/impl/queue/ |
H A D | TaskDispatcherTest.java | 26 import org.forgerock.openam.sm.datalayer.api.Task; 95 Task task = mock(Task.class); 110 Task task = mock(Task.class); 123 Task task = mock(Task.class); 136 Task task = mock(Task.class); 150 Task tas [all...] |
/forgerock/openam/openam-core/src/main/java/org/forgerock/openam/sm/datalayer/impl/ |
H A D | SeriesTaskExecutor.java | 38 import org.forgerock.openam.sm.datalayer.api.Task; 53 * {@link Task}s themselves are keyed by the Token ID of the request. 75 private BlockingQueue<Task>[] taskQueues; 107 public void execute(String tokenId, Task task) throws DataLayerException { 108 BlockingQueue<Task> queue = getQueue(tokenId); 139 debug("Created {0} Task Processors", processors); 147 private BlockingQueue<Task> getQueueForQuery() { 160 private BlockingQueue<Task> getQueue(String tokenId) { 172 * @param task Task to add. 173 * @throws org.forgerock.openam.sm.datalayer.api.QueueTimeoutException If the timeout expired before the Task wa [all...] |
/forgerock/openam-v13/openam-core/src/test/java/org/forgerock/openam/sm/datalayer/store/ |
H A D | TokenDataStoreTest.java | 32 import org.forgerock.openam.sm.datalayer.api.Task; 64 final Task task = mock(Task.class); 86 final Task task = mock(Task.class); 106 final Task task = mock(Task.class); 122 final Task task = mock(Task.class); 124 when(taskFactory.read(anyString(), any(ResultHandler.class))).thenAnswer(new Answer<Task>() { [all...] |
/forgerock/openam/openam-core/src/test/java/org/forgerock/openam/sm/datalayer/store/ |
H A D | TokenDataStoreTest.java | 31 import org.forgerock.openam.sm.datalayer.api.Task; 63 Task task = givenCreateTaskCompletesSuccessfully(); 90 final Task task = mock(Task.class); 107 Task task = givenReadTaskCompletesSuccessfully(token); 149 doThrow(DataLayerException.class).when(taskExecutor).execute(anyString(), any(Task.class)); 160 Task readTask = givenReadTaskCompletesSuccessfully("123", token); 161 Task updateTask = givenUpdateTaskCompletesSuccessfully(token); 209 Task updateTask = givenUpdateTaskCompletesSuccessfully(token); 221 Task tas [all...] |
/forgerock/opendj-v3/opendj-server-legacy/src/test/java/org/opends/server/tasks/ |
H A D | TasksTestCase.java | 35 import org.opends.server.backends.task.Task; 125 public static Task getTask(final DN taskEntryDN) throws Exception 133 return timer.repeatUntilSuccess(new Callable<Task>() 136 public Task call() throws Exception 138 Task task = taskBackend.getScheduledTask(taskEntryDN); 156 public static Task getDoneTask(final DN taskEntryDN) throws Exception 158 final Task task = getTask(taskEntryDN); 164 return timer.repeatUntilSuccess(new Callable<Task>() 167 public Task call() throws Exception 170 "Task " [all...] |
/forgerock/openam-v13/openam-core/src/main/java/org/forgerock/openam/sm/datalayer/impl/ |
H A D | SeriesTaskExecutor.java | 38 import org.forgerock.openam.sm.datalayer.api.Task; 53 * {@link Task}s themselves are keyed by the Token ID of the request. 75 private BlockingQueue<Task>[] taskQueues; 107 public void execute(String tokenId, Task task) throws DataLayerException { 108 BlockingQueue<Task> queue = getQueue(tokenId); 132 taskQueues[ii] = new LinkedBlockingQueue<Task>(configuration.getQueueSize()); 139 debug("Created {0} Task Processors", processors); 147 private BlockingQueue<Task> getQueueForQuery() { 160 private BlockingQueue<Task> getQueue(String tokenId) { 172 * @param task Task t [all...] |
/forgerock/opendj2/src/server/org/opends/server/backends/task/ |
H A D | TaskThread.java | 81 super("Task Thread " + threadID); 102 public Task getTask() 115 public void setTask(Task task) 197 Task task = getAssociatedTask(); 217 Task task = getAssociatedTask(); 226 Task completedTask = getAssociatedTask(); 237 Task task = getAssociatedTask();
|
/forgerock/opendj-b2.6/src/server/org/opends/server/backends/task/ |
H A D | TaskThread.java | 85 super("Task Thread " + threadID); 106 public Task getTask() 119 public void setTask(Task task) 201 Task task = getAssociatedTask(); 221 Task task = getAssociatedTask(); 230 Task completedTask = getAssociatedTask(); 241 Task task = getAssociatedTask();
|
/forgerock/opendj2.6.2/src/server/org/opends/server/backends/task/ |
H A D | TaskThread.java | 85 super("Task Thread " + threadID); 106 public Task getTask() 119 public void setTask(Task task) 201 Task task = getAssociatedTask(); 221 Task task = getAssociatedTask(); 230 Task completedTask = getAssociatedTask(); 241 Task task = getAssociatedTask();
|
/forgerock/opendj2-hg/src/server/org/opends/server/backends/task/ |
H A D | TaskThread.java | 81 super("Task Thread " + threadID); 102 public Task getTask() 115 public void setTask(Task task) 197 Task task = getAssociatedTask(); 217 Task task = getAssociatedTask(); 226 Task completedTask = getAssociatedTask(); 237 Task task = getAssociatedTask();
|
/forgerock/opendj2-jel-hg/src/server/org/opends/server/backends/task/ |
H A D | TaskThread.java | 85 super("Task Thread " + threadID); 106 public Task getTask() 119 public void setTask(Task task) 201 Task task = getAssociatedTask(); 221 Task task = getAssociatedTask(); 230 Task completedTask = getAssociatedTask(); 241 Task task = getAssociatedTask();
|
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/backends/task/ |
H A D | TaskThread.java | 75 super("Task Thread " + threadID); 96 public Task getTask() 109 public void setTask(Task task) 185 Task task = getAssociatedTask(); 199 Task task = getAssociatedTask(); 204 Task completedTask = getAssociatedTask(); 215 Task task = getAssociatedTask();
|
/forgerock/openam/openam-core/src/test/java/org/forgerock/openam/cts/impl/queue/ |
H A D | TaskDispatcherTest.java | 27 import org.forgerock.openam.sm.datalayer.api.Task; 142 Task task = mock(Task.class); 157 Task task = mock(Task.class); 170 Task task = mock(Task.class); 183 Task task = mock(Task.class); 197 Task tas [all...] |
/forgerock/opendj2/src/build-tools/org/opends/build/tools/ |
H A D | CreateVersionString.java | 31 import org.apache.tools.ant.Task; 39 public class CreateVersionString extends Task
|