Package | Description |
---|---|
org.apache.manifoldcf.connectorcommon.interfaces | |
org.apache.manifoldcf.connectorcommon.throttler |
Modifier and Type | Method and Description |
---|---|
boolean |
IFetchThrottler.obtainFetchDocumentPermission(IBreakCheck breakCheck)
Get permission to fetch a document.
|
boolean |
IStreamThrottler.obtainReadPermission(int byteCount,
IBreakCheck breakCheck)
Obtain permission to read a block of bytes.
|
int |
IConnectionThrottler.waitConnectionAvailable(IBreakCheck breakCheck)
Get permission to grab a connection for use.
|
Modifier and Type | Method and Description |
---|---|
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.
|