|
24 | 24 | test 'sending TERM to scheduler breaks out of poll_sleep' do |
25 | 25 | Resque::Scheduler.expects(:release_master_lock) |
26 | 26 |
|
27 | | - @pid = Process.pid |
| 27 | + pid = Process.pid |
28 | 28 | Thread.new do |
29 | 29 | sleep(0.05) |
30 | | - Process.kill(:TERM, @pid) |
| 30 | + Process.kill(:TERM, pid) |
31 | 31 | end |
32 | 32 |
|
33 | 33 | assert_raises SystemExit do |
|
41 | 41 | test 'can start successfully' do |
42 | 42 | Resque::Scheduler.poll_sleep_amount = nil |
43 | 43 |
|
44 | | - @pid = Process.pid |
| 44 | + pid = Process.pid |
45 | 45 | Thread.new do |
46 | 46 | sleep(0.15) |
47 | | - Process.kill(:TERM, @pid) |
| 47 | + Process.kill(:TERM, pid) |
48 | 48 | end |
49 | 49 |
|
50 | 50 | assert_raises SystemExit do |
|
56 | 56 | Resque::Scheduler.poll_sleep_amount = 0 |
57 | 57 | Resque::Scheduler.expects(:release_master_lock) |
58 | 58 |
|
59 | | - @pid = Process.pid |
| 59 | + pid = Process.pid |
60 | 60 | Thread.new do |
61 | 61 | sleep(0.05) |
62 | | - Process.kill(:TERM, @pid) |
| 62 | + Process.kill(:TERM, pid) |
63 | 63 | end |
64 | 64 |
|
65 | 65 | assert_raises SystemExit do |
|
86 | 86 | test 'logs scheduler master' do |
87 | 87 | Resque::Scheduler.expects(:master?).returns(true) |
88 | 88 |
|
89 | | - @pid = Process.pid |
| 89 | + pid = Process.pid |
90 | 90 | Thread.new do |
91 | 91 | sleep(0.1) |
92 | | - Process.kill(:TERM, @pid) |
| 92 | + Process.kill(:TERM, pid) |
93 | 93 | end |
94 | 94 |
|
95 | 95 | assert_raises SystemExit do |
|
102 | 102 | test 'logs scheduler child' do |
103 | 103 | Resque::Scheduler.expects(:master?).returns(false) |
104 | 104 |
|
105 | | - @pid = Process.pid |
| 105 | + pid = Process.pid |
106 | 106 | Thread.new do |
107 | 107 | sleep(0.1) |
108 | | - Process.kill(:TERM, @pid) |
| 108 | + Process.kill(:TERM, pid) |
109 | 109 | end |
110 | 110 |
|
111 | 111 | assert_raises SystemExit do |
|
0 commit comments