Method logDump

ZezeJava/ZezeJava/src/main/java/Zeze/Raft/Test.java:51–69

(String db)

	private boolean running = true;

	private static void logDump(String db) throws IOException, RocksDBException {
		RocksDB.loadLibrary();
		try (var r1 = RocksDB.openReadOnly(RocksDatabase.getCommonOptions(), Paths.get(db, "logs").toString())) {
			try (var it1 = r1.newIterator(RocksDatabase.getDefaultReadOptions())) {
				var StateMachine = new TestStateMachine();
				var snapshot = Paths.get(db, LogSequence.snapshotFileName).toString();
				if (new File(snapshot).isFile())
					StateMachine._loadSnapshot(snapshot);
				try (var dumpFile = new FileOutputStream(db + ".txt")) {
					dumpFile.write(String.format("SnapshotCount = %d\n", StateMachine.getCount()).getBytes(StandardCharsets.UTF_8));
					for (it1.seekToFirst(); it1.isValid(); it1.next()) {
						var l1 = RaftLog.decode(new Binary(it1.value()), StateMachine::logFactory);
						dumpFile.write(l1.toString().getBytes(StandardCharsets.UTF_8));
						dumpFile.write('\n');
					}
				}
			}
		}
	}

	public void run(String command, String[] args) throws InterruptedException {
		System.out.println(command);