org.tikv.txn

Class LockResolverClientV4

java.lang.Object

org.tikv.common.AbstractGRPCClient<TikvGrpc.TikvBlockingStub,TikvGrpc.TikvFutureStub>

org.tikv.common.region.AbstractRegionStoreClient

org.tikv.txn.LockResolverClientV4

All Implemented Interfaces:

AutoCloseable, RegionErrorReceiver, AbstractLockResolverClient

public class LockResolverClientV4
extends AbstractRegionStoreClient
implements AbstractLockResolverClient

Since v4.0.0 TiDB write will not block read (update MinCommitTS).

Field Summary

Fields inherited from class org.tikv.common.region.AbstractRegionStoreClient

codec, region, regionManager, SEEK_LEADER_STORE_DURATION, SEEK_PROXY_STORE_DURATION, store

Fields inherited from class org.tikv.common.AbstractGRPCClient

asyncStub, blockingStub, channelFactory, conf, timeout

Fields inherited from interface org.tikv.txn.AbstractLockResolverClient

BIG_TXN_THRESHOLD, RESOLVED_TXN_CACHE_SIZE

Constructor Summary

Constructors

Constructor and Description
LockResolverClientV4(TiConfiguration conf, TiRegion region, TiStore store, TikvGrpc.TikvBlockingStub blockingStub, TikvGrpc.TikvFutureStub asyncStub, ChannelFactory channelFactory, RegionManager regionManager, PDClient pdClient, RegionStoreClient.RegionStoreClientBuilder clientBuilder)

Method Summary

Modifier and Type	Method and Description
String	getVersion()
ResolveLockResult	resolveLocks(BackOffer bo, long callerStartTS, List<Lock> locks, boolean forWrite) ResolveLocks tries to resolve Locks.

Methods inherited from class org.tikv.common.region.AbstractRegionStoreClient

close, getAsyncStub, getBlockingStub, getRegion, makeContext, makeContext, makeContext, makeContext, onNotLeader, onStoreUnreachable

Methods inherited from class org.tikv.common.AbstractGRPCClient

callAsyncWithRetry, callServerStreamingWithRetry, callWithRetry, checkHealth, getConf, getTimeout, setTimeout

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.tikv.txn.AbstractLockResolverClient

extractLockFromKeyErr, getInstance

Constructor Detail

LockResolverClientV4

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

Method Detail

getVersion

public String getVersion()

Specified by:

getVersion in interface AbstractLockResolverClient

resolveLocks

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

Description copied from interface: AbstractLockResolverClient

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.

Specified by:

resolveLocks in interface AbstractLockResolverClient

Returns:

msBeforeTxnExpired: 0 means all locks are resolved