Examples of truncateLog()


Examples of org.apache.zookeeper.server.ZKDatabase.truncateLog()

        for (int i = 1; i <= 100; i++) {
            append(zkdb, i);
        }

        zkdb.truncateLog(1);

        append(zkdb, 200);

        zkdb.close();
View Full Code Here

Examples of org.apache.zookeeper.server.ZKDatabase.truncateLog()

        for (int i = 1; i <= 100; i++) {
            append(zkdb, i);
        }

        zkdb.truncateLog(1);

        append(zkdb, 200);

        zkdb.close();
View Full Code Here

Examples of org.apache.zookeeper.server.ZKDatabase.truncateLog()

        File[] logs = snaplog.getDataDir().listFiles();
        for(int i = 0; i < logs.length; i++) {
            logs[i].delete();
        }
        try {
            zkdb.truncateLog(1);
            Assert.assertTrue("Should not get here", false);
        }
        catch(IOException e) {
            Assert.assertTrue("Should have received an IOException", true);
        }
View Full Code Here

Examples of org.apache.zookeeper.server.ZKDatabase.truncateLog()

        for (int i = 1; i <= 100; i++) {
            append(zkdb, i);
        }

        zkdb.truncateLog(1);

        append(zkdb, 200);

        zkdb.close();
View Full Code Here

Examples of org.apache.zookeeper.server.ZKDatabase.truncateLog()

        for (int i = 1; i <= 100; i++) {
            append(zkdb, i);
        }

        zkdb.truncateLog(1);

        append(zkdb, 200);

        zkdb.close();
View Full Code Here

Examples of org.apache.zookeeper.server.ZKDatabase.truncateLog()

        for (int i = 1; i <= 100; i++) {
            append(zkdb, i);
        }

        zkdb.truncateLog(1);

        append(zkdb, 200);

        zkdb.close();
View Full Code Here

Examples of org.apache.zookeeper.server.ZKDatabase.truncateLog()

        for(int i = 0; i < logs.length; i++) {
            LOG.debug("Deleting: {}", logs[i].getName());
            Assert.assertTrue("Failed to delete log file: " + logs[i].getName(), logs[i].delete());
        }
        try {
            zkdb.truncateLog(1);
            Assert.assertTrue("Should not get here", false);
        }
        catch(IOException e) {
            Assert.assertTrue("Should have received an IOException", true);
        }
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.