Commit a72143de96ccd70474c1e1c7212c61d841b8a2e4
2023-02-26T01:47:22
rbpkg_ci_mux
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 105 106 107
diff --git a/bin/rbpkg_ci_mux b/bin/rbpkg_ci_mux
index ebb80f6..ddd883d 100755
--- a/bin/rbpkg_ci_mux
+++ b/bin/rbpkg_ci_mux
@@ -33,6 +33,7 @@ end
def rbpkg_ci_mux
clean = false
+ remote = true
upgrade = false
while case $ARGS[0]
when "--clean"
@@ -42,6 +43,9 @@ def rbpkg_ci_mux
usage
when "--help"
usage
+ when "--no-remote"
+ remote = false
+ shift
when "--upgrade"
Rbpkg.upgrade_self
shift
@@ -59,23 +63,74 @@ def rbpkg_ci_mux
verbose(1, cmd)
raise "command failed: #{cmd.inspect}" unless system(cmd)
Rbpkg.ci_init
- hosts.each do |host|
- cmd! "ssh #{sh_quote(host)} rbpkg/bin/rbpkg_ci --clean"
+ if remote
+ hosts.each do |host|
+ cmd! "ssh #{sh_quote(host)} rbpkg/bin/rbpkg_ci --clean"
+ end
end
- end
- if upgrade
+ end
+ if upgrade && remote
hosts.each do |host|
cmd! "ssh #{sh_quote(host)} rbpkg/bin/rbpkg upgrade"
end
end
- hosts.each do |host|
- Thread.report_on_exception = false
- threads << Thread.new do
- Rbpkg.ci_remote(repo, branch, commit, host)
+ if remote
+ hosts.each do |host|
+ Thread.report_on_exception = false
+ threads << Thread.new do
+ Rbpkg.ci_remote(repo, branch, commit, host)
+ end
+ end
+ threads.each do |t|
+ t.join
+ end
+ end
+ status = {}
+ Dir.chdir("#{Rbpkg.ci_dir}/status") do
+ Dir["*/*"].each do |dir|
+ Dir.chdir(dir) do
+ Dir["*/*.status"].each do |subdir_file|
+ name = File.basename(subdir_file, ".status")
+ file = "#{name}.status"
+ if ! status[name] || ! FileUtils.uptodate?(file, [subdir_file])
+ FileUtils.cp(subdir_file, file)
+ case File.read(file)
+ when "running"
+ status[name] = :running
+ when "ko"
+ if status[name] != :running
+ status[name] = :ko
+ end
+ when "ok"
+ if ! status[name]
+ status[name] = :ok
+ end
+ end
+ end
+ end
+ end
+ end
+ status.each do |name, status|
+ File.write("#{name}.status", status)
end
end
- threads.each do |t|
- t.join
+ log = {}
+ Dir.chdir("#{Rbpkg.ci_dir}/log") do
+ Dir["*/*"].each do |dir|
+ Dir.chdir(dir) do
+ Dir["*/*.log"].each do |subdir_file|
+ name = File.basename(subdir_file, ".log")
+ file = "#{name}.log"
+ if ! log[name] || ! FileUtils.uptodate?(file, [subdir_file])
+ FileUtils.cp(subdir_file, file)
+ log[name] = true
+ end
+ end
+ end
+ end
+ log.each do |name, l|
+ puts name
+ end
end
end