remove bootstrap check

Signed-off-by: Ryan Leung <rleungx@gmail.com>
tikv · Dec 26, 2019 · d7603f7 · d7603f7
1 parent db94a10
commit d7603f7
Showing 1 changed file with 0 additions and 31 deletions.
diff --git a/server/config_manager/grpc_service.go b/server/config_manager/grpc_service.go
@@ -30,14 +30,6 @@ func (c *ConfigManager) Create(ctx context.Context, request *configpb.CreateRequ
 		return nil, err
 	}
 
-	cluster := c.svr.GetRaftCluster()
-	if cluster == nil {
-		return &configpb.CreateResponse{Header: c.componentHeader(), Status: &configpb.Status{
-			Code:    configpb.StatusCode_UNKNOWN,
-			Message: "cluster is not bootstrapped",
-		}}, nil
-	}
-
 	version, config, status := c.CreateConfig(request.GetVersion(), request.GetComponent(), request.GetComponentId(), request.GetConfig())
 	if status.GetCode() == configpb.StatusCode_OK {
 		c.Persist(c.svr.GetStorage())
@@ -57,14 +49,6 @@ func (c *ConfigManager) Get(ctx context.Context, request *configpb.GetRequest) (
 		return nil, err
 	}
 
-	cluster := c.svr.GetRaftCluster()
-	if cluster == nil {
-		return &configpb.GetResponse{Header: c.componentHeader(), Status: &configpb.Status{
-			Code:    configpb.StatusCode_UNKNOWN,
-			Message: "cluster is not bootstrapped",
-		}}, nil
-	}
-
 	version, config, status := c.GetConfig(request.GetVersion(), request.GetComponent(), request.GetComponentId())
 
 	return &configpb.GetResponse{
@@ -81,14 +65,6 @@ func (c *ConfigManager) Update(ctx context.Context, request *configpb.UpdateRequ
 		return nil, err
 	}
 
-	cluster := c.svr.GetRaftCluster()
-	if cluster == nil {
-		return &configpb.UpdateResponse{Header: &configpb.Header{ClusterId: c.svr.ClusterID()}, Status: &configpb.Status{
-			Code:    configpb.StatusCode_UNKNOWN,
-			Message: "cluster is not bootstrapped",
-		}}, nil
-	}
-
 	version, status := c.UpdateConfig(request.GetKind(), request.GetVersion(), request.GetEntries())
 	if status.GetCode() == configpb.StatusCode_OK {
 		c.Persist(c.svr.GetStorage())
@@ -107,13 +83,6 @@ func (c *ConfigManager) Delete(ctx context.Context, request *configpb.DeleteRequ
 		return nil, err
 	}
 
-	cluster := c.svr.GetRaftCluster()
-	if cluster == nil {
-		return &configpb.DeleteResponse{Header: &configpb.Header{ClusterId: c.svr.ClusterID()}, Status: &configpb.Status{
-			Code:    configpb.StatusCode_UNKNOWN,
-			Message: "cluster is not bootstrapped",
-		}}, nil
-	}
 	status := c.DeleteConfig(request.GetKind(), request.GetVersion())
 	if status.GetCode() == configpb.StatusCode_OK {
 		c.Persist(c.svr.GetStorage())