本文整理了Java中com.evolveum.midpoint.task.api.Task.incrementProgressAndStoreStatsIfNeeded()
方法的一些代码示例,展示了Task.incrementProgressAndStoreStatsIfNeeded()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Task.incrementProgressAndStoreStatsIfNeeded()
方法的具体详情如下:
包路径:com.evolveum.midpoint.task.api.Task
类名称: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();
内容来源于网络,如有侵权,请联系作者删除!