org.tikv.txn

Interface AbstractLockResolverClient

All Known Implementing Classes:

LockResolverClientV2, LockResolverClientV3, LockResolverClientV4

public interface AbstractLockResolverClient

Field Summary

Fields

Modifier and Type	Field and Description
static long	BIG_TXN_THRESHOLD transaction involves keys exceed this threshold can be treated as `big transaction`.
static long	RESOLVED_TXN_CACHE_SIZE ResolvedCacheSize is max number of cached txn status.

Method Summary

Modifier and Type	Method and Description
static Lock	extractLockFromKeyErr(Kvrpcpb.KeyError keyError, RequestKeyCodec codec)
static AbstractLockResolverClient	getInstance(TiConfiguration conf, TiRegion region, TiStore store, TikvGrpc.TikvBlockingStub blockingStub, TikvGrpc.TikvFutureStub asyncStub, ChannelFactory channelFactory, RegionManager regionManager, PDClient pdClient, RegionStoreClient.RegionStoreClientBuilder clientBuilder)
String	getVersion()
ResolveLockResult	resolveLocks(BackOffer bo, long callerStartTS, List<Lock> locks, boolean forWrite) ResolveLocks tries to resolve Locks.

Field Detail

RESOLVED_TXN_CACHE_SIZE

static final long RESOLVED_TXN_CACHE_SIZE

ResolvedCacheSize is max number of cached txn status.

See Also:

Constant Field Values

BIG_TXN_THRESHOLD

static final long BIG_TXN_THRESHOLD

transaction involves keys exceed this threshold can be treated as `big transaction`.

See Also:

Constant Field Values

Method Detail

extractLockFromKeyErr

static Lock extractLockFromKeyErr(Kvrpcpb.KeyError keyError,
                                  RequestKeyCodec codec)

getInstance

static AbstractLockResolverClient getInstance(TiConfiguration conf,
                                              TiRegion region,
                                              TiStore store,
                                              TikvGrpc.TikvBlockingStub blockingStub,
                                              TikvGrpc.TikvFutureStub asyncStub,
                                              ChannelFactory channelFactory,
                                              RegionManager regionManager,
                                              PDClient pdClient,
                                              RegionStoreClient.RegionStoreClientBuilder clientBuilder)

getVersion

String getVersion()

resolveLocks

ResolveLockResult resolveLocks(BackOffer bo,
                               long callerStartTS,
                               List<Lock> locks,
                               boolean forWrite)

ResolveLocks tries to resolve Locks. The resolving process is in 3 steps: 1) Use the `lockTTL` to pick up all expired locks. Only locks that are old enough are considered orphan locks and will be handled later. If all locks are expired then all locks will be resolved so true will be returned, otherwise caller should sleep a while before retry. 2) For each lock, query the primary key to get txn(which left the lock)'s commit status. 3) Send `ResolveLock` cmd to the lock's region to resolve all locks belong to the same transaction.

Parameters:

bo -

callerStartTS -

locks -

forWrite -

Returns:

msBeforeTxnExpired: 0 means all locks are resolved