Revision f94d64b1
Added by Marc Dequènes almost 14 years ago
- ID f94d64b1dcfe6f1dfa8f92cf0c53f1068b92c497
| lib/cyborghood/cyborg/server.rb | ||
|---|---|---|
|
MaxLineLength = 16*1024
|
||
|
|
||
|
EOD = "\033[0J"
|
||
|
NODE_PATTERN = /^([a-zA-Z0-9_]+(?:\.[a-zA-Z0-9_]+)*[?=]?)(?: ([+?]+))?$/
|
||
|
|
||
|
def initialize(interface)
|
||
|
@interface = interface
|
||
| ... | ... | |
|
@config = Config.instance
|
||
|
@split_data_mode = false
|
||
|
@split_data_cmd = nil
|
||
|
@split_data_cmd_args = []
|
||
|
@split_data = []
|
||
|
end
|
||
|
|
||
| ... | ... | |
|
else
|
||
|
logger.debug "Received data [#{identifier}]: #{data}"
|
||
|
|
||
|
begin
|
||
|
cmd_parts = Shellwords.shellsplit(data)
|
||
|
rescue
|
||
|
unless data =~ NODE_PATTERN
|
||
|
logger.error "Error [#{identifier}]: syntax error"
|
||
|
send_line "552 syntax error"
|
||
|
send_line "552 syntax error in command"
|
||
|
return
|
||
|
end
|
||
|
cmd = cmd_parts.shift
|
||
|
args = cmd_parts
|
||
|
cmd = $1
|
||
|
flags = $2 || ""
|
||
|
|
||
|
if @interface.is_split_mode_command? cmd
|
||
|
enter_split_mode(cmd, args)
|
||
|
if flags.index '?'
|
||
|
send_line "250+ ok"
|
||
|
send_line({'exists?' => @interface.has_node?(cmd)}.to_yaml)
|
||
|
return
|
||
|
end
|
||
|
|
||
|
if flags.index '+'
|
||
|
enter_split_mode(cmd)
|
||
|
else
|
||
|
receive_command(cmd, args)
|
||
|
receive_command(cmd)
|
||
|
end
|
||
|
end
|
||
|
end
|
||
|
end
|
||
|
|
||
|
def receive_command(cmd, args, data = nil)
|
||
|
def receive_command(cmd, data = nil)
|
||
|
logger.debug "Executing command '#{cmd}' [#{identifier}]"
|
||
|
send_line @interface.instance.call(cmd, args, data)
|
||
|
send_line @interface.instance.call(cmd, data)
|
||
|
end
|
||
|
|
||
|
def receive_error(msg)
|
||
| ... | ... | |
|
|
||
|
protected
|
||
|
|
||
|
def enter_split_mode(cmd, args)
|
||
|
def enter_split_mode(cmd)
|
||
|
if @split_data_mode
|
||
|
logger.error "Error [#{identifier}]: already in split mode"
|
||
|
send_line "551 protocol error"
|
||
|
@split_data_mode = false
|
||
|
@split_data_cmd = nil
|
||
|
@split_data_cmd_args = []
|
||
|
else
|
||
|
logger.debug "Entered split mode for command '#{cmd}' [#{identifier}]"
|
||
|
@split_data_mode = true
|
||
|
@split_data_cmd = cmd
|
||
|
@split_data_cmd_args = args
|
||
|
end
|
||
|
@split_data = []
|
||
|
end
|
||
| ... | ... | |
|
def exit_split_mode
|
||
|
if @split_data_mode
|
||
|
logger.debug "Quit split mode for command '#{@split_data_cmd}' [#{identifier}]"
|
||
|
receive_command(@split_data_cmd, @split_data_cmd_args, @split_data.join("\n"))
|
||
|
receive_command(@split_data_cmd, @split_data.join("\n"))
|
||
|
else
|
||
|
logger.error "Error [#{identifier}]: not in split mode"
|
||
|
send_line "551 protocol error"
|
||
|
end
|
||
|
@split_data_mode = false
|
||
|
@split_data_cmd = nil
|
||
|
@split_data_cmd_args = []
|
||
|
@split_data = []
|
||
|
end
|
||
|
end
|
||
Also available in: Unified diff
[evol] work on cyborg server protocol and API #2 (refs #31)