com.evolveum.midpoint.task.api.Task.getLastRunFinishTimestamp()方法的使用及代码示例

x33g5p2x  于2022-01-30 转载在 其他  
字(9.2k)|赞(0)|评价(0)|浏览(68)

本文整理了Java中com.evolveum.midpoint.task.api.Task.getLastRunFinishTimestamp()方法的一些代码示例,展示了Task.getLastRunFinishTimestamp()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Task.getLastRunFinishTimestamp()方法的具体详情如下:
包路径:com.evolveum.midpoint.task.api.Task
类名称:Task
方法名:getLastRunFinishTimestamp

Task.getLastRunFinishTimestamp介绍

[英]Returns the time when the task last run was finished (or null if the task was not finished yet).
[中]返回任务上次运行完成的时间(如果任务尚未完成,则返回null)。

代码示例

代码示例来源:origin: Evolveum/midpoint

@Override
      public boolean check() throws CommonException {
        Task freshTask = taskManager.getTaskWithResult(origTask.getOid(), waitResult);
        OperationResult taskResult = freshTask.getResult();
//                display("Times", longTimeToString(origLastRunStartTimestamp) + "-" + longTimeToString(origLastRunStartTimestamp)
//                        + " : " + longTimeToString(freshTask.getLastRunStartTimestamp()) + "-" + longTimeToString(freshTask.getLastRunFinishTimestamp()));
        if (verbose) display("Check result", taskResult);
        taskResultHolder.setValue(taskResult);
        if (isError(taskResult, checkSubresult)) {
          return true;
        }
        if (isUnknown(taskResult, checkSubresult)) {
          return false;
        }
        if (freshTask.getLastRunFinishTimestamp() == null) {
          return false;
        }
        if (freshTask.getLastRunStartTimestamp() == null) {
          return false;
        }
        return !freshTask.getLastRunStartTimestamp().equals(origLastRunStartTimestamp)
            && !freshTask.getLastRunFinishTimestamp().equals(origLastRunFinishTimestamp)
            && freshTask.getLastRunStartTimestamp() < freshTask.getLastRunFinishTimestamp();
      }
      @Override

代码示例来源:origin: Evolveum/midpoint

public boolean check() throws ObjectNotFoundException, SchemaException {
  Task task = taskManager.getTask(TASK_OPENDJ_RECON_OID, result);
  display("Task while waiting for task manager to pick up the task", task);
  // wait until the task is finished
  return task.getLastRunFinishTimestamp() != null;
}

代码示例来源:origin: Evolveum/midpoint

public boolean check() throws ObjectNotFoundException, SchemaException {
        Task task = taskManager.getTask(TASK_OPENDJ_SYNC_OID, result);
        display("Task while waiting for task manager to pick up the task", task);
        // wait until the task is picked up
        return task.getLastRunFinishTimestamp() != null;
//                if (TaskExclusivityStatus.CLAIMED == task.getExclusivityStatus()) {
//                    // wait until the first run is finished
//                    if (task.getLastRunFinishTimestamp() == null) {
//                        return false;
//                    }
//                    return true;
//                }
//                return false;
      }

代码示例来源:origin: Evolveum/midpoint

@Override
  public void timeout() {
    try {
      Task freshTask = taskManager.getTaskWithResult(origTask.getOid(), waitResult);
      OperationResult result = freshTask.getResult();
      LOGGER.debug("Timed-out task:\n{}", freshTask.debugDump());
      display("Times", "origLastRunStartTimestamp="+longTimeToString(origLastRunStartTimestamp)
      + ", origLastRunFinishTimestamp=" + longTimeToString(origLastRunFinishTimestamp)
      + ", freshTask.getLastRunStartTimestamp()=" + longTimeToString(freshTask.getLastRunStartTimestamp())
      + ", freshTask.getLastRunFinishTimestamp()=" + longTimeToString(freshTask.getLastRunFinishTimestamp()));
      assert false : "Timeout ("+timeout+") while waiting for "+freshTask+" next run. Last result "+result;
    } catch (ObjectNotFoundException | SchemaException e) {
      LOGGER.error("Exception during task refresh: {}", e, e);
    }
  }
};

代码示例来源:origin: Evolveum/midpoint

protected OperationResult waitForTaskTreeNextFinishedRun(Task origRootTask, int timeout, OperationResult waitResult) throws Exception {
  Long origLastRunStartTimestamp = origRootTask.getLastRunStartTimestamp();
  Long origLastRunFinishTimestamp = origRootTask.getLastRunFinishTimestamp();
  long start = System.currentTimeMillis();
  Holder<Boolean> triggered = new Holder<>(false);    // to avoid repeated checking for start-finish timestamps
        || freshRootTask.getLastRunFinishTimestamp() == null
        || freshRootTask.getLastRunFinishTimestamp().equals(origLastRunFinishTimestamp)
        || freshRootTask.getLastRunStartTimestamp() >= freshRootTask.getLastRunFinishTimestamp())) {
      display("Root (triggering) task next run has not been completed yet: " + description);
      return false;

代码示例来源:origin: Evolveum/midpoint

protected OperationResult waitForTaskNextRun(final Task origTask, final boolean checkSubresult, final int timeout, final OperationResult waitResult, boolean kickTheTask) throws Exception {
  final Long origLastRunStartTimestamp = origTask.getLastRunStartTimestamp();
  final Long origLastRunFinishTimestamp = origTask.getLastRunFinishTimestamp();
  if (kickTheTask) {
    taskManager.scheduleTaskNow(origTask, waitResult);
  + ", origLastRunFinishTimestamp=" + longTimeToString(origLastRunFinishTimestamp)
  + ", freshTask.getLastRunStartTimestamp()=" + longTimeToString(freshTask.getLastRunStartTimestamp())
  + ", freshTask.getLastRunFinishTimestamp()=" + longTimeToString(freshTask.getLastRunFinishTimestamp()));

代码示例来源:origin: Evolveum/midpoint

@Test
public void test010CycleCronLoose() throws Exception {
  final String TEST_NAME = "test010CycleCronLoose";
  final OperationResult result = createResult(TEST_NAME, LOGGER);
  addObjectFromFile(taskFilename(TEST_NAME));
  waitForTaskProgress(taskOid(TEST_NAME), result, 15000, 2000, 2);
  // Check task status
  Task task = getTask(taskOid(TEST_NAME), result);
  AssertJUnit.assertNotNull(task);
  System.out.println(task.debugDump());
  TaskType t = repositoryService.getObject(TaskType.class, taskOid(TEST_NAME), null, result).getValue().getValue();
  System.out.println(ObjectTypeUtil.dump(t));
  AssertJUnit.assertEquals(TaskExecutionStatus.RUNNABLE, task.getExecutionStatus());
  // .. and last run should not be zero
  AssertJUnit.assertNotNull(task.getLastRunStartTimestamp());
  assertFalse(task.getLastRunStartTimestamp() == 0);
  AssertJUnit.assertNotNull(task.getLastRunFinishTimestamp());
  assertFalse(task.getLastRunFinishTimestamp() == 0);
  // The progress should be at least 2 as the task has run at least twice
  AssertJUnit.assertTrue("Task has not been executed at least twice", task.getProgress() >= 2);
  // Test for presence of a result. It should be there and it should
  // indicate success
  assertSuccessOrInProgress(task);
  // Suspend the task (in order to keep logs clean), without much waiting
  taskManager.suspendTaskQuietly(task, 100, result);
}

代码示例来源:origin: Evolveum/midpoint

AssertJUnit.assertNotNull(task.getLastRunFinishTimestamp());
assertFalse(task.getLastRunFinishTimestamp() == 0);
AssertJUnit.assertTrue(task.getProgress() > 0);
AssertJUnit.assertNotNull(task.getLastRunFinishTimestamp());
assertFalse(task.getLastRunFinishTimestamp() == 0);
AssertJUnit.assertTrue(task.getProgress() > 0);

代码示例来源:origin: Evolveum/midpoint

AssertJUnit.assertNotNull("LastRunStartTimestamp is null", task.getLastRunStartTimestamp());
assertFalse("LastRunStartTimestamp is 0", task.getLastRunStartTimestamp() == 0);
AssertJUnit.assertNotNull(task.getLastRunFinishTimestamp());
assertFalse(task.getLastRunFinishTimestamp() == 0);
AssertJUnit.assertTrue("no progress", task.getProgress() > 0);

代码示例来源:origin: Evolveum/midpoint

AssertJUnit.assertNotNull(task.getLastRunFinishTimestamp());
assertFalse(task.getLastRunFinishTimestamp() == 0);

代码示例来源:origin: Evolveum/midpoint

AssertJUnit.assertNotNull("LastRunFinishTimestamp is null", task1.getLastRunFinishTimestamp());
assertFalse("LastRunFinishTimestamp is 0", task1.getLastRunFinishTimestamp() == 0);

代码示例来源:origin: Evolveum/midpoint

AssertJUnit.assertNotNull("Last run finish timestamp not set", task.getLastRunFinishTimestamp());
assertFalse("Last run finish timestamp is 0", task.getLastRunFinishTimestamp() == 0);

代码示例来源:origin: Evolveum/midpoint

AssertJUnit.assertNotNull("LastRunFinishTimestamp is null", task.getLastRunFinishTimestamp());
assertFalse("LastRunFinishTimestamp is 0", task.getLastRunFinishTimestamp() == 0);

代码示例来源:origin: Evolveum/midpoint

AssertJUnit.assertNotNull("Last run finish timestamp not set", task.getLastRunFinishTimestamp());
assertFalse("Last run finish timestamp is 0", task.getLastRunFinishTimestamp() == 0);

代码示例来源:origin: Evolveum/midpoint

assertNotNull("No lastRunFinishedTimestamp", task.getLastRunFinishTimestamp());
assertFalse("Zero lastRunFinishedTimestamp", task.getLastRunFinishTimestamp().longValue() == 0);

代码示例来源:origin: Evolveum/midpoint

AssertJUnit.assertNotNull("Last run finish timestamp not set", task.getLastRunFinishTimestamp());
assertFalse("Last run finish timestamp is 0", task.getLastRunFinishTimestamp() == 0);

代码示例来源:origin: Evolveum/midpoint

assertNotNull(task.getLastRunFinishTimestamp());
AssertJUnit.assertFalse(task.getLastRunFinishTimestamp().longValue() == 0);

代码示例来源:origin: Evolveum/midpoint

assertNotNull("Null last run finish in recon task", task.getLastRunFinishTimestamp());
AssertJUnit.assertFalse("Zero last run finish in recon task", task.getLastRunFinishTimestamp().longValue() == 0);

代码示例来源:origin: Evolveum/midpoint

AssertJUnit.assertNull(task.getLastRunFinishTimestamp());
AssertJUnit.assertEquals("There should be no progress reported", 0, task.getProgress());

代码示例来源:origin: Evolveum/midpoint

AssertJUnit.assertNotNull(task001.getLastRunStartTimestamp());
AssertJUnit.assertEquals("Start time is not correct", (Long) (currentTime / 1000L), (Long) (task001.getLastRunStartTimestamp() / 1000L));   // e.g. MySQL cuts off millisecond information
AssertJUnit.assertNotNull(task001.getLastRunFinishTimestamp());
AssertJUnit.assertEquals("Finish time is not correct", (Long) (currentTime1 / 1000L), (Long) (task001.getLastRunFinishTimestamp() / 1000L));

相关文章