public static interface DistributionSchedule.AckSet
Modifier and Type | Method and Description |
---|---|
boolean |
completeBookieAndCheck(int bookieIndexHeardFrom)
Add a bookie response and check if quorum has been met.
|
boolean |
failBookieAndCheck(int bookieIndexHeardFrom,
org.apache.bookkeeper.net.BookieSocketAddress address)
Received failure response from a bookie and check if ack quorum
will be broken.
|
java.util.Map<java.lang.Integer,org.apache.bookkeeper.net.BookieSocketAddress> |
getFailedBookies()
Return the list of bookies that already failed.
|
void |
recycle()
Recycle this ack set when not used anymore.
|
boolean |
removeBookieAndCheck(int bookie)
Invalidate a previous bookie response.
|
boolean completeBookieAndCheck(int bookieIndexHeardFrom)
boolean failBookieAndCheck(int bookieIndexHeardFrom, org.apache.bookkeeper.net.BookieSocketAddress address)
bookieIndexHeardFrom
- bookie index that failed.address
- bookie addressjava.util.Map<java.lang.Integer,org.apache.bookkeeper.net.BookieSocketAddress> getFailedBookies()
boolean removeBookieAndCheck(int bookie)
void recycle()
Copyright © 2011–2020 The Apache Software Foundation. All rights reserved.