mirror of
https://github.com/OpenNebula/one.git
synced 2025-03-21 14:50:08 +03:00
feature #863: fix some bugs introduced with library changes
This commit is contained in:
parent
c472c6c9f5
commit
09fe832399
@ -54,12 +54,16 @@ class ImageDriver < OpenNebulaDriver
|
||||
@options={
|
||||
:concurrency => 10,
|
||||
:threaded => true,
|
||||
:retries => 0
|
||||
:retries => 0,
|
||||
:local_actions => {
|
||||
'MV' => nil,
|
||||
'CP' => nil,
|
||||
'RM' => nil,
|
||||
'MKFS' => nil
|
||||
}
|
||||
}.merge!(options)
|
||||
|
||||
super('', @options)
|
||||
|
||||
@actions_path = "#{VAR_LOCATION}/remotes/image/#{fs_type}"
|
||||
super("image/#{fs_type}", @options)
|
||||
|
||||
register_action(ACTION[:mv].to_sym, method("mv"))
|
||||
register_action(ACTION[:cp].to_sym, method("cp"))
|
||||
@ -69,23 +73,21 @@ class ImageDriver < OpenNebulaDriver
|
||||
|
||||
# Image Manager Protocol Actions (generic implementation
|
||||
def mv(id, src, dst)
|
||||
do_action("#{@actions_path}/mv #{src} #{dst} #{id}", id, nil,
|
||||
ACTION[:mv], :local => true)
|
||||
do_action("#{src} #{dst} #{id}", id, nil,
|
||||
ACTION[:mv])
|
||||
end
|
||||
|
||||
def cp(id, src)
|
||||
do_action("#{@actions_path}/cp #{src} #{id}", id, nil, ACTION[:cp],
|
||||
:local => true)
|
||||
do_action("#{src} #{id}", id, nil, ACTION[:cp])
|
||||
end
|
||||
|
||||
def rm(id, dst)
|
||||
do_action("#{@actions_path}/rm #{dst} #{id}", id, nil, ACTION[:rm],
|
||||
:local => true)
|
||||
do_action("#{dst} #{id}", id, nil, ACTION[:rm])
|
||||
end
|
||||
|
||||
def mkfs(id, fs, size)
|
||||
do_action("#{@actions_path}/mkfs #{fs} #{size} #{id}", id, nil,
|
||||
ACTION[:mkfs], :local => true)
|
||||
do_action("#{fs} #{size} #{id}", id, nil,
|
||||
ACTION[:mkfs])
|
||||
end
|
||||
end
|
||||
|
||||
|
@ -224,7 +224,7 @@ class ExecDriver < VirtualMachineDriver
|
||||
log(id, "Successfully executed network driver #{net_drv}" <<
|
||||
" (clean-cancel)")
|
||||
|
||||
send_message(ACTION[:shutdown], RESULT[:success], id, domain_id)
|
||||
send_message(ACTION[:shutdown], RESULT[:success], id, deploy_id)
|
||||
end
|
||||
|
||||
def save(id, drv_message)
|
||||
|
Loading…
x
Reference in New Issue
Block a user