public class ManualMemberNodeReplicaAuditor extends AbstractReplicationAuditor
replicationDao| Constructor and Description |
|---|
ManualMemberNodeReplicaAuditor(Date auditDate) |
| Modifier and Type | Method and Description |
|---|---|
protected Date |
calculateAuditDate() |
protected long |
getFutureExecutionWaitTimeSeconds() |
protected String |
getLockName() |
protected int |
getMaxPages() |
protected int |
getPageSize() |
protected int |
getPidsPerTaskSize() |
protected List<org.dataone.service.types.v1.Identifier> |
getPidsToAudit(Date auditDate,
int pageNumber,
int pageSize) |
protected Lock |
getProcessingLock() |
protected int |
getTaskPoolSize() |
protected Callable<String> |
newAuditTask(List<org.dataone.service.types.v1.Identifier> pids,
Date auditDate) |
protected void |
releaseLock(Lock lock) |
protected boolean |
shouldRunAudit() |
protected boolean |
tryLock(Lock lock) |
auditReplication, runpublic ManualMemberNodeReplicaAuditor(Date auditDate)
protected Date calculateAuditDate()
calculateAuditDate in class AbstractReplicationAuditorprotected List<org.dataone.service.types.v1.Identifier> getPidsToAudit(Date auditDate, int pageNumber, int pageSize) throws org.dataone.cn.dao.exceptions.DataAccessException
getPidsToAudit in class AbstractReplicationAuditororg.dataone.cn.dao.exceptions.DataAccessExceptionprotected Callable<String> newAuditTask(List<org.dataone.service.types.v1.Identifier> pids, Date auditDate)
newAuditTask in class AbstractReplicationAuditorprotected boolean tryLock(Lock lock)
tryLock in class AbstractReplicationAuditorprotected void releaseLock(Lock lock)
releaseLock in class AbstractReplicationAuditorprotected Lock getProcessingLock()
getProcessingLock in class AbstractReplicationAuditorprotected String getLockName()
getLockName in class AbstractReplicationAuditorprotected int getMaxPages()
getMaxPages in class AbstractReplicationAuditorprotected int getTaskPoolSize()
getTaskPoolSize in class AbstractReplicationAuditorprotected int getPageSize()
getPageSize in class AbstractReplicationAuditorprotected int getPidsPerTaskSize()
getPidsPerTaskSize in class AbstractReplicationAuditorprotected boolean shouldRunAudit()
shouldRunAudit in class AbstractReplicationAuditorprotected long getFutureExecutionWaitTimeSeconds()
getFutureExecutionWaitTimeSeconds in class AbstractReplicationAuditorCopyright © 2018. All rights reserved.