shaba/one
1
0
Fork 0
mirror of https://github.com/OpenNebula/one.git synced 2025-03-21 14:50:08 +03:00
Code Releases Wiki Activity

bug: remote dir is not recreated if removed

Browse Source
This commit is contained in:
Ruben S. Montero 2011-06-18 01:26:45 +02:00
parent ffce8af029
commit b796817b97
1 changed files with 17 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

30
src/mad/ruby/CommandManager.rb
View File

@ -160,15 +160,6 @@ private
end
class RemotesCommand < SSHCommand
ONE_LOCATION=ENV["ONE_LOCATION"]
if !ONE_LOCATION
REMOTES_LOCATION="/var/lib/one/remotes"
else
REMOTES_LOCATION=ONE_LOCATION+"/var/remotes/"
end
MAGIC_RC = 42
# Creates a command and runs it
def self.run(command, host, remote_dir, logger=nil, stdin=nil, retries=0)
@ -182,9 +173,7 @@ class RemotesCommand < SSHCommand
while cmd.code != 0 and retries != 0
if cmd.code == MAGIC_RC
cmd.update_remotes(host, remote_dir, logger)
@command = command
update_remotes(host, remote_dir, logger)
cmd.run
end
@ -196,10 +185,25 @@ class RemotesCommand < SSHCommand
cmd
end
def update_remotes(host, remote_dir, logger=nil)
private
ONE_LOCATION=ENV["ONE_LOCATION"]
if !ONE_LOCATION
REMOTES_LOCATION="/var/lib/one/remotes"
else
REMOTES_LOCATION=ONE_LOCATION+"/var/remotes/"
end
MAGIC_RC = 42
def self.update_remotes(host, remote_dir, logger=nil)
log("Remote worker node files not found")
log("Updating remotes")
#recreate remote dir structure
SSHCommand.run("mkdir -p #{remote_dir}",host,logger)
# Use SCP to sync:
sync_cmd = "scp -r #{REMOTES_LOCATION}/. #{host}:#{remote_dir}"