tikv
/
client-java
mirror of https://github.com/tikv/client-java.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

fix #21 (#23)

This commit is contained in:
birdstorm 2019-01-07 15:30:41 +08:00 committed by GitHub
parent 2f0d9997d1
commit 491efa9fbb
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 2 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
src/main/java/org/tikv/common/region/RegionStoreClient.java
View File

@ -22,6 +22,7 @@ import static com.google.common.base.Preconditions.checkNotNull;
import static org.tikv.common.util.BackOffFunction.BackOffFuncType.BoRegionMiss; import static org.tikv.common.util.BackOffFunction.BackOffFuncType.BoRegionMiss;
import static org.tikv.common.util.BackOffFunction.BackOffFuncType.BoTxnLockFast; import static org.tikv.common.util.BackOffFunction.BackOffFuncType.BoTxnLockFast;
import com.google.common.annotations.VisibleForTesting;
import com.google.protobuf.ByteString; import com.google.protobuf.ByteString;
import io.grpc.ManagedChannel; import io.grpc.ManagedChannel;
import java.util.ArrayList; import java.util.ArrayList;
@ -70,13 +71,7 @@ public class RegionStoreClient extends AbstractGRPCClient<TikvBlockingStub, Tikv
private static final Logger logger = Logger.getLogger(RegionStoreClient.class); private static final Logger logger = Logger.getLogger(RegionStoreClient.class);
private TiRegion region; private TiRegion region;
private final RegionManager regionManager; private final RegionManager regionManager;
// TODO: change from public to private @VisibleForTesting private final LockResolverClient lockResolverClient;
// because our test needs to implement the
// preWrite and commit which needs to use
// lockResolverClient, after implements the
// write implementation of tispark, we can change
// it to private
public final LockResolverClient lockResolverClient;
private TikvBlockingStub blockingStub; private TikvBlockingStub blockingStub;
private TikvStub asyncStub; private TikvStub asyncStub;