On Fri, Mar 12, 2021 at 11:09:50AM +0800, Wu Zhende wrote:
1.optimize function name 2.the host and port are transferred when the MQClient is initalized 3.reboot vm cyclically
add space between $num. and text.
-------- Thanks, Xijian
Signed-off-by: Wu Zhende wuzhende666@163.com
providers/multi-qemu | 20 ++++++++++++++------ 1 file changed, 14 insertions(+), 6 deletions(-)
diff --git a/providers/multi-qemu b/providers/multi-qemu index 5979cc9..d3f8406 100755 --- a/providers/multi-qemu +++ b/providers/multi-qemu @@ -104,8 +104,19 @@ def save_pid(arr) f.close end
-def reboot_deadline_machine(hostname)
- mq = MQClient.new
+def loop_reboot_vm(hostname)
- loop do
- begin
reboot_vm(hostname)
- rescue StandardError => e
puts e.backtrace
sleep 5
- end
- end
+end
+def reboot_vm(hostname)
- mq = MQClient.new(MQ_HOST, MQ_PORT) queue = mq.queue(hostname, {:durable => true}) queue.subscribe({:block => true, :manual_ack => true}) do |info, _pro, msg| puts msg
@@ -118,10 +129,7 @@ end
def multiqemu Process.fork do
- reboot_deadline_machine(HOSTNAME)
- rescue StandardError => e
- puts e.backtrace
- sleep 5
loop_reboot_vm(HOSTNAME) end
pids = []
-- 2.23.0