com.orientechnologies.orient.server.distributed.impl

Class OConflictResolverDatabaseRepairer

java.lang.Object

com.orientechnologies.orient.server.distributed.impl.OConflictResolverDatabaseRepairer

All Implemented Interfaces:

ODistributedDatabaseRepairer

public class OConflictResolverDatabaseRepairer
extends Object
implements ODistributedDatabaseRepairer

Distributed database repairer that, based on the reported records to check, executes repair of record in configurable batches. This assure better performance by grouping multiple requests. The repair is based on the chain of conflict resolver.

Author:

Luca Garulli (l.garulli--at--orientdb.com)

Constructor Summary

Constructors

Constructor and Description
OConflictResolverDatabaseRepairer(ODistributedServerManager manager, String databaseName)

Method Summary

Modifier and Type	Method and Description
void	cancelRepairRecord(ORecordId rid) Cancel the repair against a record because the update succeed.
void	enqueueRepairCluster(int clusterId) Enqueues the request to repair a cluster.
void	enqueueRepairRecord(ORecordId rid) Adds the record to repair int the map of records and cluster.
void	enqueueRepairRecords(Collection<ORecordId> rids)
long	getRecordProcessed()
long	getTotalTimeProcessing()
void	repairRecord(ORecordId rid)
void	repairRecords(Collection<ORecordId> rids)
void	shutdown()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

OConflictResolverDatabaseRepairer

public OConflictResolverDatabaseRepairer(ODistributedServerManager manager,
                                         String databaseName)

Method Detail

enqueueRepairRecords

public void enqueueRepairRecords(Collection<ORecordId> rids)

Specified by:

enqueueRepairRecords in interface ODistributedDatabaseRepairer

enqueueRepairRecord

public void enqueueRepairRecord(ORecordId rid)

Adds the record to repair int the map of records and cluster. The decision about repairing is taken by the timer task.

Specified by:

enqueueRepairRecord in interface ODistributedDatabaseRepairer

Parameters:

rid - RecordId to repair

cancelRepairRecord

public void cancelRepairRecord(ORecordId rid)

Cancel the repair against a record because the update succeed.

Specified by:

cancelRepairRecord in interface ODistributedDatabaseRepairer

Parameters:

rid - RecordId to remove from repair

enqueueRepairCluster

public void enqueueRepairCluster(int clusterId)

Enqueues the request to repair a cluster. The decision about repairing is taken by the timer task.

Specified by:

enqueueRepairCluster in interface ODistributedDatabaseRepairer

Parameters:

clusterId - Broken cluster id to start repairing

repairRecords

public void repairRecords(Collection<ORecordId> rids)

Specified by:

repairRecords in interface ODistributedDatabaseRepairer

repairRecord

public void repairRecord(ORecordId rid)

Specified by:

repairRecord in interface ODistributedDatabaseRepairer

getRecordProcessed

public long getRecordProcessed()

Specified by:

getRecordProcessed in interface ODistributedDatabaseRepairer

getTotalTimeProcessing

public long getTotalTimeProcessing()

Specified by:

getTotalTimeProcessing in interface ODistributedDatabaseRepairer

shutdown

public void shutdown()

Specified by:

shutdown in interface ODistributedDatabaseRepairer