Skip to content

Commit 2cab65b

Browse files
committed
WIP: remove sidekiq pausing as it’s been useless for at least a year
1 parent 4bb0f24 commit 2cab65b

File tree

3 files changed

+6
-21
lines changed

3 files changed

+6
-21
lines changed

lib/docker_manager/unicorn_adapter.rb

Lines changed: 0 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -17,15 +17,5 @@ def master_pid
1717
def workers
1818
`pgrep -f -P #{master_pid} worker`.split("\n").map(&:to_i)
1919
end
20-
21-
def pause_sidekiq
22-
return if ENV["UNICORN_SIDEKIQS"].to_i <= 0
23-
24-
log "Stopping job queue to reclaim memory, master pid is #{master_pid}"
25-
Process.kill("TSTP", master_pid)
26-
sleep 1
27-
# Older versions do not have support, so quickly send a CONT so master process is not hung
28-
Process.kill("CONT", master_pid)
29-
end
3020
end
3121
end

lib/docker_manager/upgrader.rb

Lines changed: 6 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -7,14 +7,14 @@
77
class DockerManager::Upgrader
88
attr_reader :web_server
99

10-
delegate :min_workers, :server_name, to: :web_server
10+
delegate :min_workers, :server_name, :launcher_pid, :master_pid, :workers, to: :web_server
1111

1212
def initialize(user_id, repos, from_version)
1313
@user_id = user_id
1414
@user = User.find(user_id)
1515
@repos = repos.is_a?(Array) ? repos : [repos]
1616
@from_version = from_version
17-
@web_server = select_web_server_adapter
17+
@web_server = web_server_adapter
1818
end
1919

2020
def reset!
@@ -36,12 +36,12 @@ def upgrade
3636
log("*** Please be patient, next steps might take a while ***")
3737
log("********************************************************")
3838

39-
if web_server.workers.size <= min_workers
39+
if workers.size <= min_workers
4040
log("ABORTING, you do not have enough #{server_name} workers running")
4141
raise "Not enough workers"
4242
end
4343

44-
if web_server.launcher_pid <= 0 || web_server.master_pid <= 0
44+
if launcher_pid <= 0 || master_pid <= 0
4545
log("ABORTING, missing #{server_name} launcher or master/monitor")
4646
raise "No #{server_name} master or launcher"
4747
end
@@ -53,15 +53,13 @@ def upgrade
5353

5454
percent(10)
5555
reloaded = false
56-
num_workers_spun_down = web_server.workers.size - min_workers
56+
num_workers_spun_down = workers.size - min_workers
5757

5858
if num_workers_spun_down.positive?
5959
log "Stopping #{num_workers_spun_down} #{server_name} worker(s), to free up memory"
6060
web_server.scale_down_workers(num_workers_spun_down)
6161
end
6262

63-
web_server.pause_sidekiq
64-
6563
# HEAD@{upstream} is just a fancy way how to say origin/main (in normal case)
6664
# see http://stackoverflow.com/a/12699604/84283
6765
@repos.each_with_index do |repo, index|
@@ -265,7 +263,7 @@ def log_version_upgrade
265263

266264
private
267265

268-
def select_web_server_adapter
266+
def web_server_adapter
269267
if `pgrep -f '^unicorn[^_]'`.present?
270268
DockerManager::UnicornAdapter
271269
else

lib/docker_manager/web_server_adapter.rb

Lines changed: 0 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -24,9 +24,6 @@ def scale_up_workers(count)
2424
count.times { Process.kill("TTIN", master_pid) }
2525
end
2626

27-
def pause_sidekiq
28-
end
29-
3027
def min_workers
3128
1
3229
end

0 commit comments

Comments
 (0)