cluster: expel instances removed from config in cluster.sync

CHANGELOG.md

@@ -4,6 +4,10 @@
 
 - Fixed a bug when `server:grep_log()` failed to find a string logged in
   `server:exec()` called immediately before it (gh-421).
+- Fixed a bug when it wasn't possible to reload the cluster config with
+  `cluster:reload()` after removing an instance with `cluster:sync()`.
+  Also added an option to `cluster:sync()` to start/stop added/removed
+  instances (gh-423).
 
 ## 1.1.0
 

luatest/cluster.lua

@@ -187,8 +187,12 @@ function Cluster:drop()
     for _, iserver in ipairs(self._servers or {}) do
         iserver:drop()
     end
+    for _, iserver in ipairs(self._expelled_servers or {}) do
+        iserver:drop()
+    end
     self._servers = nil
     self._server_map = nil
+    self._expelled_servers = nil
 end
 
 --- Sync the cluster object with the new config.
@@ -197,25 +201,50 @@ end
 --
 -- * Write the new config into the config file.
 -- * Update the internal list of instances.
+-- * Optionally starts instances added to the config and stops instances
+--   removed from the config.
 --
 -- @tab config New config.
-function Cluster:sync(config)
+-- @tab[opt] opts Options.
+-- @bool[opt] opts.start_stop Start/stop added/removed servers (default: false).
+function Cluster:sync(config, opts)
     assert(type(config) == 'table')
 
+    local start_stop = false
+    if opts ~= nil and opts.start_stop ~= nil then
+        start_stop = opts.start_stop
+    end
+
     local instance_names = instance_names_from_config(config)
 
     treegen.write_file(self._dir, self._config_file_rel, yaml.encode(config))
 
-    for i, name in ipairs(instance_names) do
-        if self._server_map[name] == nil then
-            local iserver = server:new(fun.chain(self._server_opts, {
+    local server_map = self._server_map
+    self._server_map = {}
+    self._servers = {}
+
+    for _, name in ipairs(instance_names) do
+        local iserver = server_map[name]
+        if iserver == nil then
+            iserver = server:new(fun.chain(self._server_opts, {
                 alias = name,
             }):tomap())
-            table.insert(self._servers, i, iserver)
-            self._server_map[name] = iserver
+            if start_stop then
+                iserver:start()
+            end
+        else
+            server_map[name] = nil
         end
+        self._server_map[name] = iserver
+        table.insert(self._servers, iserver)
     end
 
+    for _, iserver in pairs(server_map) do
+        table.insert(self._expelled_servers, iserver)
+        if start_stop then
+            iserver:stop()
+        end
+    end
 end
 
 --- Reload configuration on all the instances.
@@ -297,6 +326,7 @@ function Cluster:new(config, server_opts, opts)
     -- Store a cluster object in 'g'.
     self._servers = servers
     self._server_map = server_map
+    self._expelled_servers = {}
     self._dir = dir
     self._config_file_rel = config_file_rel
     self._server_opts = server_opts

test/cluster_test.lua

@@ -142,9 +142,6 @@ g.test_sync = function()
     c:start()
     assert_instance_running(c, 'i-001')
 
-    c:stop()
-    assert_instance_stopped(c, 'i-001')
-
     local config2 = cbuilder:new()
         :use_group('g-001')
         :use_replicaset('r-001')
@@ -156,18 +153,85 @@ g.test_sync = function()
 
         :config()
 
+    local server1 = c['i-001']
+
     c:sync(config2)
 
-    t.assert_equals(c:size(), 3)
+    -- Check that the server that was removed from the config is expelled
+    -- from the cluster but not stopped.
+    t.assert_equals(c:size(), 2)
+    t.assert_is(c['i-001'], nil)
+    t.assert_is_not(server1.process, nil)
 
-    c:start_instance('i-002')
-    c:start_instance('i-003')
+    -- Check that the new servers are not started.
+    assert_instance_stopped(c, 'i-002')
+    assert_instance_stopped(c, 'i-003')
+
+    c:start()
     assert_instance_running(c, 'i-002')
     assert_instance_running(c, 'i-003')
 
+    -- Check config reload works after sync.
+    c:reload()
+
     c:stop()
     assert_instance_stopped(c, 'i-002')
     assert_instance_stopped(c, 'i-003')
+
+    -- Starting/stopping the cluster shouldn't affect the expelled server.
+    -- However, dropping the cluster should also drop the expelled server.
+    t.assert_is_not(server1.process, nil)
+    c:drop()
+    t.assert_is(server1.process, nil)
+end
+
+g.test_sync_start_stop = function()
+    t.run_only_if(utils.version_current_ge_than(3, 0, 0),
+                  [[Declarative configuration works on Tarantool 3.0.0+.
+                    See tarantool/tarantool@13149d65bc9d for details]])
+
+    t.assert_equals(g._cluster, nil)
+
+    local config = cbuilder:new()
+        :use_group('g-001')
+        :use_replicaset('r-001')
+        :add_instance('i-001', {})
+        :config()
+
+    local c = cluster:new(config, server_opts)
+
+    t.assert_equals(c:size(), 1)
+
+    c:start()
+    assert_instance_running(c, 'i-001')
+
+    local config2 = cbuilder:new()
+        :use_group('g-001')
+        :use_replicaset('r-001')
+        :add_instance('i-002', {})
+
+        :use_group('g-002')
+        :use_replicaset('r-002')
+        :add_instance('i-003', {})
+
+        :config()
+
+    local server1 = c['i-001']
+
+    c:sync(config2, {start_stop = true})
+
+    -- Check that the server that was removed from the config is expelled
+    -- from the cluster and stopped.
+    t.assert_equals(c:size(), 2)
+    t.assert_is(c['i-001'], nil)
+    t.assert_is(server1.process, nil)
+
+    -- Check that the new servers are started.
+    assert_instance_running(c, 'i-002')
+    assert_instance_running(c, 'i-003')
+
+    -- Check config reload works after sync.
+    c:reload()
 end
 
 g.test_reload = function()