module Roma::Command::BackgroundCommandReceiver

Public Instance Methods

ev_balance(s) click to toggle source
   # File lib/roma/command/bg_command_receiver.rb
11 def ev_balance(s)
12   res = broadcast_cmd("rbalance\r\n")
13   if @stats.run_join == false &&
14       @stats.run_recover == false &&
15       @stats.run_balance == false &&
16       @rttable.vnode_balance(@stats.ap_str)==:less
17     Roma::AsyncProcess::queue.push(Roma::AsyncMessage.new('start_balance_process'))
18     res[@stats.ap_str] = 'STARTED'
19   else
20     res[@stats.ap_str] = 'SERVER_ERROR Not unbalance or othre process is already running.'
21   end
22   send_data("#{res}\r\n")
23 end
ev_rbalance(s) click to toggle source
   # File lib/roma/command/bg_command_receiver.rb
25 def ev_rbalance(s)
26   if @stats.run_join == false &&
27       @stats.run_recover == false &&
28       @stats.run_balance == false &&
29       @rttable.vnode_balance(@stats.ap_str)==:less
30     Roma::AsyncProcess::queue.push(Roma::AsyncMessage.new('start_balance_process'))
31     send_data("STARTED\r\n")
32   else
33     send_data("SERVER_ERROR Not unbalance or other process is already running.\r\n")
34   end
35 end
ev_recover(s) click to toggle source

recover

   # File lib/roma/command/bg_command_receiver.rb
51 def ev_recover(s)
52   if @rttable.can_i_recover?
53     cmd = "rrecover"
54     res = broadcast_cmd("#{cmd}\r\n")
55     unless @stats.run_recover
56       Roma::AsyncProcess::queue.push(Roma::AsyncMessage.new('start_recover_process'))
57       res[@nid] = "STARTED"
58     else
59       res[@nid] = "SERVER_ERROR Recover process is already running."
60     end
61     send_data("#{res}\r\n")
62   else
63     send_data("SERVER_ERROR nodes num < redundant num\r\n")
64   end
65 end
ev_release(s) click to toggle source
   # File lib/roma/command/bg_command_receiver.rb
37 def ev_release(s)
38   if @stats.run_join == false &&
39       @stats.run_recover == false &&
40       @stats.run_balance == false &&
41       @stats.run_release == false &&
42       @stats.run_iterate_storage == false
43     Roma::AsyncProcess::queue.push(Roma::AsyncMessage.new('start_release_process'))
44     send_data("STARTED\r\n")
45   else
46     send_data("SERVER_ERROR Other process is already running.\r\n")
47   end
48 end
ev_rrecover(s) click to toggle source

rrecover

   # File lib/roma/command/bg_command_receiver.rb
68 def ev_rrecover(s)
69   if @rttable.can_i_recover?
70     unless @stats.run_recover
71       Roma::AsyncProcess::queue.push(Roma::AsyncMessage.new('start_recover_process'))
72       send_data("STARTED\r\n")
73     else
74       send_data("SERVER_ERROR Recover process is already running.\r\n")
75     end
76   else
77     send_data("SERVER_ERROR nodes num < redundant num\r\n")
78   end
79 end