public class ObjectStorePoolImpl extends Object implements ObjectStorePool
ObjectStoreRequest
s that involve communicating wih Object Store.Constructor and Description |
---|
ObjectStorePoolImpl(AsyncServiceSchedulerResultsReceiver resultsReceiver,
int poolSize,
TierObjectStore tierObjectStore)
Constructs a new ObjectStorePool using the given parameters.
|
ObjectStorePoolImpl(AsyncServiceSchedulerResultsReceiver resultsReceiver,
TierObjectStore tierObjectStore,
int numCores)
Constructs a new ObjectStorePool using the given parameters.
|
Modifier and Type | Method and Description |
---|---|
void |
setObjectStoreRetryWaitInMs(long objectStoreRetryWaitInMs) |
void |
shutdown()
Shuts down the ObjectStorePool.
|
void |
startUp()
Starts up the ObjectStorePool.
|
void |
submitObjectStoreRequest(ObjectStoreRequest objectStoreRequest)
Submits objectStoreRequest to be processed.
|
protected void |
submitRestoreObjectsInStoreRequest(RestoreObjectsInStoreRequest request)
Submits
RestoreObjectsInStoreRequest to be processed. |
protected void |
submitUploadFtpsToStoreRequest(UploadFtpsToStoreRequest request)
Submits
UploadFtpsToStoreRequest to be processed. |
ThreadPoolExecutor |
threadPool() |
public ObjectStorePoolImpl(AsyncServiceSchedulerResultsReceiver resultsReceiver, TierObjectStore tierObjectStore, int numCores)
resultsReceiver
- results receiver to send results totierObjectStore
- object store to write tonumCores
- number of cores available to the ObjectStorePool. Fractional cores are allowed - for example, if the
system has one core total, but caller only wants ObjectStorePool to use half of the core's capacity,
then caller could pass 0.5 available cores.public ObjectStorePoolImpl(AsyncServiceSchedulerResultsReceiver resultsReceiver, int poolSize, TierObjectStore tierObjectStore)
resultsReceiver
- results receiver to send results totierObjectStore
- object store to write topoolSize
- pool size for the thread poolpublic void setObjectStoreRetryWaitInMs(long objectStoreRetryWaitInMs)
public void startUp()
startUp
in interface ObjectStorePool
public void shutdown()
shutdown
in interface ObjectStorePool
public void submitObjectStoreRequest(ObjectStoreRequest objectStoreRequest)
submitObjectStoreRequest
in interface ObjectStorePool
objectStoreRequest
- request to be processed.protected void submitRestoreObjectsInStoreRequest(RestoreObjectsInStoreRequest request)
RestoreObjectsInStoreRequest
to be processed.request
- request to be processedprotected void submitUploadFtpsToStoreRequest(UploadFtpsToStoreRequest request)
UploadFtpsToStoreRequest
to be processed.request
- request to be processedpublic ThreadPoolExecutor threadPool()