public abstract class AbstractReplicationAuditor extends Object implements Runnable
Modifier and Type | Field and Description |
---|---|
protected org.dataone.cn.dao.ReplicationDao |
replicationDao |
Constructor and Description |
---|
AbstractReplicationAuditor() |
Modifier and Type | Method and Description |
---|---|
void |
auditReplication() |
protected abstract Date |
calculateAuditDate() |
protected abstract long |
getFutureExecutionWaitTimeSeconds() |
protected abstract String |
getLockName() |
protected abstract int |
getMaxPages() |
protected abstract int |
getPageSize() |
protected abstract int |
getPidsPerTaskSize() |
protected abstract List<org.dataone.service.types.v1.Identifier> |
getPidsToAudit(Date auditDate,
int pageNumber,
int pageSize) |
protected Lock |
getProcessingLock() |
protected abstract int |
getTaskPoolSize() |
protected abstract Callable<String> |
newAuditTask(List<org.dataone.service.types.v1.Identifier> pids,
Date auditDate) |
protected void |
releaseLock(Lock auditLock) |
void |
run() |
protected abstract boolean |
shouldRunAudit() |
protected boolean |
tryLock(Lock auditLock) |
protected abstract String getLockName()
protected abstract Date calculateAuditDate()
protected abstract List<org.dataone.service.types.v1.Identifier> getPidsToAudit(Date auditDate, int pageNumber, int pageSize) throws org.dataone.cn.dao.exceptions.DataAccessException
org.dataone.cn.dao.exceptions.DataAccessException
protected abstract Callable<String> newAuditTask(List<org.dataone.service.types.v1.Identifier> pids, Date auditDate)
protected abstract int getMaxPages()
protected abstract int getTaskPoolSize()
protected abstract int getPageSize()
protected abstract int getPidsPerTaskSize()
protected abstract boolean shouldRunAudit()
protected abstract long getFutureExecutionWaitTimeSeconds()
public void auditReplication()
protected boolean tryLock(Lock auditLock)
protected void releaseLock(Lock auditLock)
protected Lock getProcessingLock()
Copyright © 2018. All rights reserved.