List of pollLedgerToRereplicate() Examples

Examples of pollLedgerToRereplicate()

org.apache.bookkeeper.meta.LedgerUnderreplicationManager.pollLedgerToRereplicate()
Poll for a underreplicated ledger to rereplicate. @see #getLedgerToRereplicate @return the ledgerId, or -1 if none are available

Examples of org.apache.bookkeeper.meta.LedgerUnderreplicationManager.pollLedgerToRereplicate()

        } while (underReplicatedLedger != -1);


        Thread.sleep(CHECK_INTERVAL * 2); // give a chance to run again (it shouldn't, it's disabled)


        // ensure that nothing is marked as underreplicated
        underReplicatedLedger = underReplicationManager.pollLedgerToRereplicate();
        assertEquals("There should be no underreplicated ledgers", -1, underReplicatedLedger);


        LOG.info("{} of {} ledgers underreplicated", numUnderreplicated, numUnderreplicated);
        assertTrue("All should be underreplicated",
                numUnderreplicated <= numLedgers && numUnderreplicated > 0);

View Full Code Here

Examples of org.apache.bookkeeper.meta.LedgerUnderreplicationManager.pollLedgerToRereplicate()

        out.getChannel().write(junk);
        out.close();


        long underReplicatedLedger = -1;
        for (int i = 0; i < 10; i++) {
            underReplicatedLedger = underReplicationManager.pollLedgerToRereplicate();
            if (underReplicatedLedger != -1) {
                break;
            }
            Thread.sleep(CHECK_INTERVAL);
        }

View Full Code Here

Examples of org.apache.bookkeeper.meta.LedgerUnderreplicationManager.pollLedgerToRereplicate()

        Thread.sleep(CHECK_INTERVAL * 2);


        int numUnderreplicated = 0;
        long underReplicatedLedger = -1;
        do {
            underReplicatedLedger = underReplicationManager.pollLedgerToRereplicate();
            if (underReplicatedLedger == -1) {
                break;
            }
            numUnderreplicated++;

View Full Code Here

Examples of org.apache.bookkeeper.meta.LedgerUnderreplicationManager.pollLedgerToRereplicate()

        } while (underReplicatedLedger != -1);


        Thread.sleep(CHECK_INTERVAL * 2); // give a chance to run again (it shouldn't, it's disabled)


        // ensure that nothing is marked as underreplicated
        underReplicatedLedger = underReplicationManager.pollLedgerToRereplicate();
        assertEquals("There should be no underreplicated ledgers", -1, underReplicatedLedger);


        LOG.info("{} of {} ledgers underreplicated", numUnderreplicated, numUnderreplicated);
        assertTrue("All should be underreplicated",
                numUnderreplicated <= numLedgers && numUnderreplicated > 0);

View Full Code Here

Examples of org.apache.bookkeeper.meta.LedgerUnderreplicationManager.pollLedgerToRereplicate()

        restartBookies(); // restart to clear read buffers


        underReplicationManager.enableLedgerReplication();
        long underReplicatedLedger = -1;
        for (int i = 0; i < 10; i++) {
            underReplicatedLedger = underReplicationManager.pollLedgerToRereplicate();
            if (underReplicatedLedger != -1) {
                break;
            }
            Thread.sleep(CHECK_INTERVAL);
        }

View Full Code Here

0 1

TOP

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.