Searched defs:reconContext (Results 1 - 7 of 7) sorted by relevance

/forgerock/openidm-v4/openidm-core/src/main/java/org/forgerock/openidm/sync/impl/
H A DReconTypeById.java52 * @param reconContext a {@link ReconciliationContext} object.
55 public ReconTypeById(ReconciliationContext reconContext) throws BadRequestException { argument
56 super(reconContext, DEFAULT_RUN_TARGET_PHASE);
58 targetQuery = calcEffectiveQuery("targetQuery", reconContext.getObjectMapping().getTargetObjectSet());
60 JsonValue idsValue = reconContext.getReconParams().get("ids");
87 reconContext,
89 reconContext.getObjectMapping().getLinkType().isTargetCaseSensitive(),
H A DReconTypeByQuery.java52 * @param reconContext a {@link RconciliationContext} object.
55 public ReconTypeByQuery(ReconciliationContext reconContext) { argument
56 super(reconContext, DEFAULT_RUN_TARGET_PHASE);
58 sourceQuery = calcEffectiveQuery("sourceQuery", reconContext.getObjectMapping().getSourceObjectSet());
59 targetQuery = calcEffectiveQuery("targetQuery", reconContext.getObjectMapping().getTargetObjectSet());
69 reconContext,
82 return query(targetQuery.get("resourceName").asString(), targetQuery, reconContext,
84 reconContext.getObjectMapping().getLinkType().isTargetCaseSensitive(), QuerySide.TARGET,
H A DReconFeeder.java55 ReconciliationContext reconContext; field in class:ReconFeeder
57 protected ReconFeeder(Iterator<ResultEntry> entriesIter, ReconciliationContext reconContext) { argument
59 this.reconContext = reconContext;
67 Executor executor = reconContext.getExcecutor();
104 reconContext.checkCanceled();
H A DReconTypeBase.java58 ReconciliationContext reconContext; field in class:ReconTypeBase
87 * @param reconContext a {@link RconciliationContext} object.
90 public ReconTypeBase(ReconciliationContext reconContext, boolean defaultRunTargetPhase) { argument
91 this.reconContext = reconContext;
127 JsonValue overridingConfig = reconContext.getOverridingConfig();
133 JsonValue cfg = reconContext.getObjectMapping().getConfig().get(configPropertyName);
205 * @param reconContext the {@link RconciliationContext} object associated with this recon
210 protected ReconQueryResult query(final String objectSet, final JsonValue query, final ReconciliationContext reconContext, argument
220 QueryResponse queryResponse = reconContext
[all...]
H A DReconciliationService.java396 * @param reconContext a new reconciliation context. Do not re-use these contexts for more than one call to reconcile.
399 private void reconcile(ReconciliationContext reconContext) throws SynchronizationException { argument
401 reconContext.getObjectMapping().recon(reconContext); // throws SynchronizationException
403 if (reconContext.isCanceled()) {
404 reconContext.setStage(ReconStage.COMPLETED_CANCELED);
406 reconContext.setStage(ReconStage.COMPLETED_FAILED);
410 reconContext.setStage(ReconStage.COMPLETED_FAILED);
418 * @param reconContext the reconciliation run specific context
420 private void addReconRun(ReconciliationContext reconContext) { argument
[all...]
H A DReconciliationStatistic.java47 private ReconciliationContext reconContext; field in class:ReconciliationStatistic
66 public ReconciliationStatistic(ReconciliationContext reconContext) { argument
67 this.reconContext = reconContext;
68 sourceStat = new PhaseStatistic(this, PhaseStatistic.Phase.SOURCE, reconContext.getObjectMapping().getSourceObjectSet());
69 targetStat = new PhaseStatistic(this, PhaseStatistic.Phase.TARGET, reconContext.getObjectMapping().getTargetObjectSet());
269 results.put("reconId", reconContext.getReconId());
270 results.put("mappingName", reconContext.getMapping());
H A DObjectMapping.java895 private void doResults(ReconciliationContext reconContext) throws SynchronizationException { argument
898 scope.put("source", reconContext.getStatistics().getSourceStat().asMap());
899 scope.put("target", reconContext.getStatistics().getTargetStat().asMap());
900 scope.put("global", reconContext.getStatistics().asMap());
915 * @param reconContext the context specific to the reconciliation run
918 public void recon(ReconciliationContext reconContext) throws SynchronizationException { argument
919 EventEntry measure = Publisher.start(EVENT_RECON, reconContext.getReconId(), null);
920 doRecon(reconContext);
926 * @param reconContext
929 private void doRecon(ReconciliationContext reconContext) throw argument
1137 recon(String id, JsonValue entry, ReconciliationContext reconContext, Context rootContext, Map<String, Map<String, Link>> allLinks, Collection<String> remainingIds) argument
1278 ReconciliationContext reconContext; field in class:ObjectMapping.ReconTask
1284 ReconTask(ResultEntry resultEntry, ReconciliationContext reconContext, Context parentContext, Map<String, Map<String, Link>> allLinks, Collection<String> remainingIds, Recon reconById) argument
1319 ReconPhase(Iterator<ResultEntry> resultIter, ReconciliationContext reconContext, Context parentContext, Map<String, Map<String, Link>> allLinks, Collection<String> remainingIds, Recon reconById) argument
1363 logReconStart(ReconciliationContext reconContext, Context context) argument
1382 logReconEndSuccess(ReconciliationContext reconContext, Context context) argument
1394 logReconEndFailure(ReconciliationContext reconContext, Context context) argument
1408 logReconEnd(ReconciliationContext reconContext, Context rootContext, Status status, String loggerMessage) argument
1472 public ReconciliationContext reconContext; field in class:ObjectMapping.SyncOperation
[all...]

Completed in 71 milliseconds