vendor: update kvproto for coprocessor streaming API (pingcap#5214)

glide.yaml

@@ -156,7 +156,7 @@ import:
   - go-tipb
   - sharedbytes
 - package: github.com/pingcap/kvproto
-  version: 3c5b40fb2000acb6b3441d5695cb470a23e8f1b5
+  version: e33073e1475021e04c795c3de5e1f4e28baa708a
 - package: github.com/gogo/protobuf
   version: ^0.3.0
   subpackages:

store/tikv/mock-tikv/rpc.go

@@ -109,17 +109,17 @@ func (h *rpcHandler) checkRequestContext(ctx *kvrpcpb.Context) *errorpb.Error {
 	ctxPeer := ctx.GetPeer()
 	if ctxPeer != nil && ctxPeer.GetStoreId() != h.storeID {
 		return &errorpb.Error{
-			Message:       proto.String("store not match"),
+			Message:       *proto.String("store not match"),
 			StoreNotMatch: &errorpb.StoreNotMatch{},
 		}
 	}
 	region, leaderID := h.cluster.GetRegion(ctx.GetRegionId())
 	// No region found.
 	if region == nil {
 		return &errorpb.Error{
-			Message: proto.String("region not found"),
+			Message: *proto.String("region not found"),
 			RegionNotFound: &errorpb.RegionNotFound{
-				RegionId: proto.Uint64(ctx.GetRegionId()),
+				RegionId: *proto.Uint64(ctx.GetRegionId()),
 			},
 		}
 	}
@@ -135,27 +135,27 @@ func (h *rpcHandler) checkRequestContext(ctx *kvrpcpb.Context) *errorpb.Error {
 	// The Store does not contain a Peer of the Region.
 	if storePeer == nil {
 		return &errorpb.Error{
-			Message: proto.String("region not found"),
+			Message: *proto.String("region not found"),
 			RegionNotFound: &errorpb.RegionNotFound{
-				RegionId: proto.Uint64(ctx.GetRegionId()),
+				RegionId: *proto.Uint64(ctx.GetRegionId()),
 			},
 		}
 	}
 	// No leader.
 	if leaderPeer == nil {
 		return &errorpb.Error{
-			Message: proto.String("no leader"),
+			Message: *proto.String("no leader"),
 			NotLeader: &errorpb.NotLeader{
-				RegionId: proto.Uint64(ctx.GetRegionId()),
+				RegionId: *proto.Uint64(ctx.GetRegionId()),
 			},
 		}
 	}
 	// The Peer on the Store is not leader.
 	if storePeer.GetId() != leaderPeer.GetId() {
 		return &errorpb.Error{
-			Message: proto.String("not leader"),
+			Message: *proto.String("not leader"),
 			NotLeader: &errorpb.NotLeader{
-				RegionId: proto.Uint64(ctx.GetRegionId()),
+				RegionId: *proto.Uint64(ctx.GetRegionId()),
 				Leader:   leaderPeer,
 			},
 		}
@@ -168,7 +168,7 @@ func (h *rpcHandler) checkRequestContext(ctx *kvrpcpb.Context) *errorpb.Error {
 			newRegions = append(newRegions, nextRegion)
 		}
 		return &errorpb.Error{
-			Message: proto.String("stale epoch"),
+			Message: *proto.String("stale epoch"),
 			StaleEpoch: &errorpb.StaleEpoch{
 				NewRegions: newRegions,
 			},
@@ -387,7 +387,7 @@ func (h *rpcHandler) handleKvRawScan(req *kvrpcpb.RawScanRequest) *kvrpcpb.RawSc
 		errStr := "not implemented"
 		return &kvrpcpb.RawScanResponse{
 			RegionError: &errorpb.Error{
-				Message: &errStr,
+				Message: errStr,
 			},
 		}
 	}

store/tikv/region_request_test.go

@@ -227,6 +227,10 @@ func (s *mockTikvGrpcServer) SplitRegion(goctx.Context, *kvrpcpb.SplitRegionRequ
 	return nil, errors.New("unreachable")
 }
 
+func (s *mockTikvGrpcServer) CoprocessorStream(*coprocessor.Request, tikvpb.Tikv_CoprocessorStreamServer) error {
+	return errors.New("unreachable")
+}
+
 func (s *testRegionRequestSuite) TestNoReloadRegionForGrpcWhenCtxCanceled(c *C) {
 	// prepare a mock tikv grpc server
 	addr := "localhost:56341"