Last clean up

Author: yngvar-antonsson

CHANGELOG.md

@@ -6,7 +6,13 @@ and this project adheres to [Semantic Versioning](http://semver.org/spec/v2.0.0.
 
 ## [Unreleased]
 
+### Added
+
+- `remove_member` function to clean up member data.
+
+
 ## [2.4.1] - 2023-09-28
+
 ### Fixed
 
 - Log overflow when inner fibers weren't canceled.

membership.lua

@@ -536,11 +536,9 @@ local function _protocol_step()
     end
 end
 
-local protocol_step_in_progress = fiber.cond()
 local function protocol_step()
     local t1 = fiber.clock()
     local ok, res = xpcall(_protocol_step, debug.traceback)
-    protocol_step_in_progress:signal()
     fiber.testcancel()
 
     if not ok then
@@ -938,12 +936,11 @@ local function set_payload(key, value)
     return true
 end
 
---- Remove a member.
+--- Remove a member. Don't use it unless you having a trouble with stale members.
 -- @function remove_member
 -- @tparam uri string
 local function remove_member(uri)
     checks('string')
-    protocol_step_in_progress:wait(60)
     local member = members.get(uri)
     if member == nil then
         return

membership/options.lua

@@ -71,7 +71,6 @@ options.MAX_PACKET_SIZE = 1472
 --- Initialization vector for aes256 CBC encryption.
 options.ENCRYPTION_INIT = 'init-key-16-byte'
 
-
 options.log_debug = log.debug
 
 function options.get_encryption_key()