org.apache.hadoop.hbase.regionserver

Class ServerNonceManager

java.lang.Object

org.apache.hadoop.hbase.regionserver.ServerNonceManager

@InterfaceAudience.Private
public class ServerNonceManager
extends Object

Implementation of nonce manager that stores nonces in a hash map and cleans them up after some time; if nonce group/client ID is supplied, nonces are stored by client ID.

Field Summary

Fields

Modifier and Type	Field and Description
static String	HASH_NONCE_GRACE_PERIOD_KEY

Constructor Summary

Constructors

Constructor and Description
ServerNonceManager(org.apache.hadoop.conf.Configuration conf)

Method Summary

Modifier and Type	Method and Description
void	addMvccToOperationContext(long group, long nonce, long mvcc) Store the write point in OperationContext when the operation succeed.
ScheduledChore	createCleanupScheduledChore(Stoppable stoppable) Creates a scheduled chore that is used to clean up old nonces.
void	endOperation(long group, long nonce, boolean success) Ends the operation started by startOperation.
long	getMvccFromOperationContext(long group, long nonce) Return the write point of the previous succeed operation.
void	reportOperationFromWal(long group, long nonce, long writeTime) Reports the operation from WAL during replay.
void	setConflictWaitIterationMs(int conflictWaitIterationMs)
boolean	startOperation(long group, long nonce, Stoppable stoppable) Starts the operation if operation with such nonce has not already succeeded.

Methods inherited from class java.lang.Object

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

Field Detail

HASH_NONCE_GRACE_PERIOD_KEY

public static final String HASH_NONCE_GRACE_PERIOD_KEY

See Also:

Constant Field Values

Constructor Detail

ServerNonceManager

public ServerNonceManager(org.apache.hadoop.conf.Configuration conf)

Method Detail

setConflictWaitIterationMs

public void setConflictWaitIterationMs(int conflictWaitIterationMs)

startOperation

public boolean startOperation(long group,
                              long nonce,
                              Stoppable stoppable)
                       throws InterruptedException

Starts the operation if operation with such nonce has not already succeeded. If the operation is in progress, waits for it to end and checks whether it has succeeded.

Parameters:

group - Nonce group.

nonce - Nonce.

stoppable - Stoppable that terminates waiting (if any) when the server is stopped.

Returns:

true if the operation has not already succeeded and can proceed; false otherwise.

Throws:

InterruptedException

endOperation

public void endOperation(long group,
                         long nonce,
                         boolean success)

Ends the operation started by startOperation.

Parameters:

group - Nonce group.

nonce - Nonce.

success - Whether the operation has succeeded.

addMvccToOperationContext

public void addMvccToOperationContext(long group,
                                      long nonce,
                                      long mvcc)

Store the write point in OperationContext when the operation succeed.

Parameters:

group - Nonce group.

nonce - Nonce.

mvcc - Write point of the succeed operation.

getMvccFromOperationContext

public long getMvccFromOperationContext(long group,
                                        long nonce)

Return the write point of the previous succeed operation.

Parameters:

group - Nonce group.

nonce - Nonce.

Returns:

write point of the previous succeed operation.

reportOperationFromWal

public void reportOperationFromWal(long group,
                                   long nonce,
                                   long writeTime)

Reports the operation from WAL during replay.

Parameters:

group - Nonce group.

nonce - Nonce.

writeTime - Entry write time, used to ignore entries that are too old.

createCleanupScheduledChore

public ScheduledChore createCleanupScheduledChore(Stoppable stoppable)

Creates a scheduled chore that is used to clean up old nonces.

Parameters:

stoppable - Stoppable for the chore.

Returns:

ScheduledChore; the scheduled chore is not started.