Skip to content

Commit 6683748

Browse files
committed
TNTP-2109: Do not disable safe mode on server stop
1 parent 0c6370f commit 6683748

File tree

2 files changed

+4
-8
lines changed

2 files changed

+4
-8
lines changed

crud/common/rebalance.lua

Lines changed: 4 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -71,6 +71,8 @@ local function safe_mode_enable()
7171
for hook, _ in pairs(M.safe_mode_enable_hooks) do
7272
hook()
7373
end
74+
75+
log.info('Rebalance safe mode enabled')
7476
end
7577

7678
local function safe_mode_disable()
@@ -83,6 +85,8 @@ local function safe_mode_disable()
8385
for hook, _ in pairs(M.safe_mode_disable_hooks) do
8486
hook()
8587
end
88+
89+
log.info('Rebalance safe mode disabled')
8690
end
8791

8892
local function rebalance_init()
@@ -129,10 +133,6 @@ local function rebalance_init()
129133
end)
130134
end
131135

132-
local function rebalance_stop()
133-
M.safe_mode_disable()
134-
end
135-
136136
local function router_cache_clear()
137137
M._router_cache_last_clear_ts = fiber.time()
138138
return utils.get_vshard_router_instance():_route_map_clear()
@@ -183,7 +183,6 @@ local function enable_router_metrics()
183183
end
184184

185185
M.init = rebalance_init
186-
M.stop = rebalance_stop
187186
M.safe_mode_status = safe_mode_status
188187
M.safe_mode_enable = safe_mode_enable
189188
M.safe_mode_disable = safe_mode_disable

crud/storage.lua

Lines changed: 0 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -145,9 +145,6 @@ function storage.stop()
145145
internal_stash.watcher:unregister()
146146
internal_stash.watcher = nil
147147
end
148-
149-
rebalance.stop()
150-
151148
rawset(_G, utils.STORAGE_NAMESPACE, nil)
152149
end
153150

0 commit comments

Comments
 (0)