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

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

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

Task.incrementProgressAndStoreStatsIfNeeded介绍

暂无

代码示例

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

private void applyMetadataDeltas(ObjectContext objectCtx, RunContext runContext, OperationResult opResult) {
  ObjectType object = objectCtx.object;
  List<ItemDelta<?, ?>> deltas = objectCtx.modifications;
  try {
    if (LOGGER.isTraceEnabled()) {
      LOGGER.trace("### Updating {} with:\n{}", toShortString(object), DebugUtil.debugDump(deltas));
    }
    if (!deltas.isEmpty()) {
      repositoryService.modifyObject(object.getClass(), object.getOid(), deltas, opResult);
      runContext.task.incrementProgressAndStoreStatsIfNeeded();
    }
  } catch (ObjectNotFoundException | SchemaException | ObjectAlreadyExistsException e) {
    LoggingUtils.logUnexpectedException(LOGGER, "Couldn't update certification metadata for {}", e, toShortString(object));
  }
}

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

@Override
public TaskRunResult run(Task task) {
  LOGGER.info("MockCycle.run starting");
  OperationResult opResult = new OperationResult(MockCycleTaskHandler.class.getName()+".run");
  TaskRunResult runResult = new TaskRunResult();
  runResult.setOperationResult(opResult);
  // TODO
  task.incrementProgressAndStoreStatsIfNeeded();
  opResult.recordSuccess();
  // This "run" is finished. But the task goes on ... (if finishTheHandler == false)
  runResult.setRunResultStatus(finishTheHandler ? TaskRunResultStatus.FINISHED_HANDLER : TaskRunResultStatus.FINISHED);
  LOGGER.info("MockCycle.run stopping");
  return runResult;
}

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

runContext.task.incrementProgressAndStoreStatsIfNeeded();

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

task.incrementProgressAndStoreStatsIfNeeded();

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

task.incrementProgressAndStoreStatsIfNeeded();
try {
  Thread.sleep(1000L * interval);

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

processor.process(task, workBucket, 0);
  task.incrementProgressAndStoreStatsIfNeeded();
} else {
  int from = content.getFrom().intValue();
    task.incrementProgressAndStoreStatsIfNeeded();

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

@Override
public TaskRunResult run(Task task) {
  LOGGER.info("MockLong.run starting (id = {}, progress = {})", id, task.getProgress());
  OperationResult opResult = new OperationResult(MockLongTaskHandler.class.getName()+".run");
  TaskRunResult runResult = new TaskRunResult();
  while (task.canRun()) {
    task.incrementProgressAndStoreStatsIfNeeded();
    try {
      Thread.sleep(100);
    } catch (InterruptedException e) {
      LOGGER.info("Interrupted: exiting", e);
      break;
    }
  }
  opResult.recordSuccess();
  runResult.setOperationResult(opResult);
  runResult.setRunResultStatus(TaskRunResultStatus.FINISHED);
  runResult.setProgress(task.getProgress());
  LOGGER.info("MockLong.run stopping; progress = {}", task.getProgress());
  return runResult;
}

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

throw t;
executionTask.incrementProgressAndStoreStatsIfNeeded();

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

task.incrementProgressAndStoreStatsIfNeeded();

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

task.setExtensionProperty(newToken);
processedChanges++;
task.incrementProgressAndStoreStatsIfNeeded();
LOGGER.debug(
    "Skipping processing change. Can't find appropriate shadow (e.g. the object was deleted on the resource meantime).");
task.incrementProgressAndStoreStatsIfNeeded();

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

caseResult.computeStatus();
  revokedOk++;
  task.incrementProgressAndStoreStatsIfNeeded();
} catch (CommonException | RuntimeException e) {
  String message = "Couldn't revoke case " + caseId + ": " + e.getMessage();

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

task.incrementProgressAndStoreStatsIfNeeded();

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

throw t;		// TODO we don't want to continue processing if an error occurs?
task.incrementProgressAndStoreStatsIfNeeded();

相关文章

微信公众号

最新文章

更多