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