boolean |
ThrottleBin.beginRead(int byteCount,
IBreakCheck breakCheck) |
Note the start of an individual byte read of a specified size.
|
boolean |
Throttler.FetchThrottler.obtainFetchDocumentPermission(IBreakCheck breakCheck) |
Get permission to fetch a document.
|
boolean |
Throttler.ThrottlingGroup.obtainFetchDocumentPermission(java.lang.String[] binNames,
IBreakCheck breakCheck) |
Get permission to fetch a document.
|
boolean |
Throttler.StreamThrottler.obtainReadPermission(int byteCount,
IBreakCheck breakCheck) |
Obtain permission to read a block of bytes.
|
boolean |
Throttler.ThrottlingGroup.obtainReadPermission(java.lang.String[] binNames,
int byteCount,
IBreakCheck breakCheck) |
Obtain permission to read a block of bytes.
|
boolean |
FetchBin.reserveFetchRequest(IBreakCheck breakCheck) |
Reserve a request to fetch a document from this bin.
|
int |
ConnectionBin.waitConnectionAvailable(java.util.concurrent.atomic.AtomicInteger poolCount,
IBreakCheck breakCheck) |
Wait for a connection to become available, in the context of an existing connection pool.
|
int |
Throttler.ConnectionThrottler.waitConnectionAvailable(IBreakCheck breakCheck) |
Get permission to grab a connection for use.
|
int |
Throttler.ThrottlingGroup.waitConnectionAvailable(java.lang.String[] binNames,
java.util.concurrent.atomic.AtomicInteger[] poolCounts,
IBreakCheck breakCheck) |
Wait for a connection to become available.
|
boolean |
FetchBin.waitNextFetch(IBreakCheck breakCheck) |
Wait the necessary time to do the fetch.
|