voldemort.server.scheduler.slop
Class BlockingSlopPusherJob

java.lang.Object
  voldemort.server.scheduler.slop.BlockingSlopPusherJob

All Implemented Interfaces:

java.lang.Runnable

public class BlockingSlopPusherJob
extends java.lang.Object
implements java.lang.Runnable

A task which goes through the slop table and attempts to push out all the slop to its rightful owner node

Field Summary

static java.lang.String

TYPE_NAME

Constructor Summary

BlockingSlopPusherJob(StoreRepository storeRepo, MetadataStore metadataStore, FailureDetector failureDetector, VoldemortConfig voldemortConfig, java.util.concurrent.Semaphore repairPermits)

Method Summary

void	run() Loop over entries in the slop table and attempt to push them to the deserving server

Methods inherited from class java.lang.Object

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

Field Detail

TYPE_NAME

public static final java.lang.String TYPE_NAME

See Also:

Constant Field Values

Constructor Detail

BlockingSlopPusherJob

public BlockingSlopPusherJob(StoreRepository storeRepo,
                             MetadataStore metadataStore,
                             FailureDetector failureDetector,
                             VoldemortConfig voldemortConfig,
                             java.util.concurrent.Semaphore repairPermits)

Method Detail

run

public void run()

Loop over entries in the slop table and attempt to push them to the deserving server

Specified by:

run in interface java.lang.Runnable