@Test public void dumpPageHistoryToDefaultDir() throws Exception { diagnosticProcessor.dumpPageHistory(new PageHistoryDiagnoster.DiagnosticPageBuilder() .pageIds(expectedPageId) .addAction(PRINT_TO_LOG) .addAction(PRINT_TO_FILE) ); Path path = Paths.get(U.defaultWorkDirectory(), DEFAULT_TARGET_FOLDER); File dumpFile = path.toFile().listFiles((dir, name) -> name.endsWith(FILE_FORMAT))[0]; List<String> records = Files.readAllLines(dumpFile.toPath()); assertTrue(!records.isEmpty()); assertTrue(records.stream().anyMatch(line -> line.contains("CheckpointRecord"))); }
public void dumpPageHistory( @NotNull PageHistoryDiagnoster.DiagnosticPageBuilder builder ) throws IgniteCheckedException { logTime(log, "DiagnosticPageHistory", () -> pageHistoryDiagnoster.dumpPageHistory(builder)); }
DiagnosticProcessor extends GridProcessorAdapter { public void dumpPageHistory( @NotNull PageHistoryDiagnoster.DiagnosticPageBuilder builder ) throws IgniteCheckedException { logTime(log, "DiagnosticPageHistory", () -> pageHistoryDiagnoster.dumpPageHistory(builder)); } }
DiagnosticProcessor extends GridProcessorAdapter { public void dumpPageHistory( @NotNull PageHistoryDiagnoster.DiagnosticPageBuilder builder ) throws IgniteCheckedException { logTime(log, "DiagnosticPageHistory", () -> pageHistoryDiagnoster.dumpPageHistory(builder)); } DiagnosticProcessor(GridKernalContext ctx); }
DiagnosticProcessor extends GridProcessorAdapter { public void dumpPageHistory( @NotNull PageHistoryDiagnoster.DiagnosticPageBuilder builder ) throws IgniteCheckedException { logTime(log, "DiagnosticPageHistory", () -> pageHistoryDiagnoster.dumpPageHistory(builder)); } DiagnosticProcessor(GridKernalContext ctx); @Override void onKernalStart(boolean active); void dumpPageHistory(
        @NotNull PageHistoryDiagnoster.DiagnosticPageBuilder builder
    ); void onFailure(Ignite ignite, FailureContext failureCtx); ReconciliationExecutionContext reconciliationExecutionContext(); }
DiagnosticProcessor extends GridProcessorAdapter { public void dumpPageHistory( @NotNull PageHistoryDiagnoster.DiagnosticPageBuilder builder ) throws IgniteCheckedException { logTime(log, "DiagnosticPageHistory", () -> pageHistoryDiagnoster.dumpPageHistory(builder)); } DiagnosticProcessor(GridKernalContext ctx); @Override void onKernalStart(boolean active); void dumpPageHistory(
        @NotNull PageHistoryDiagnoster.DiagnosticPageBuilder builder
    ); void onFailure(Ignite ignite, FailureContext failureCtx); ReconciliationExecutionContext reconciliationExecutionContext(); static final String DEFAULT_TARGET_FOLDER; }