# init job mgr
@log.info "Intializing Job Manager..."
@jobmgr.init()
-
- pkgsvr_id = @id
- pkgsvr_dist = @pkgserver_url.split("/")[-1]
# set job request listener
@log.info "Setting listener..."
# if already exit, return false
for entry in @remote_pkg_servers
- u = entry[0]; p = entry[1]
+ u = entry[0]
if u == url then
return false
- end
+ end
end
@remote_pkg_servers.push [url, proxy]
#return passwd
def is_passwd_set?()
- return @passwd.empty? ? false:true
+ return ( not @passwd.empty? )
end
def passwd_match?(word)
if not is_passwd_set? then return true end
- if word.nil? then return false end
- if word.eql? @passwd then
+ if word.eql? @passwd then
return true
else
return false
def has_same_packages?( wjob )
- return self == wjob ? true : false
+ return self.eql? wjob
end
if ( @server.send_mail.eql? "YES" ) and ( not @pkginfo.nil? ) and ( not @pkginfo.packages.nil? ) then
mail_list = []
contents = []
- done_pkg_list = []
contents.push " "
contents.push " Git information : #{@git_commit} "
contents.push " "
# clean after some time
def clean_afterwards(job_id)
- curr = Time.now
time = Time.now + @server.keep_time
job_path = "#{@server.path}/jobs/#{job_id}"
@handler.register(JobCleanAction.new(time, job_path, @list_file, @server))
# check there are working jobs
def has_working_jobs
- working_cnt = 0
for job in @jobs + @internal_jobs + @reverse_build_jobs
if job.status == "WORKING" then
return true
- end
+ end
end
return false
# check there are waiting jobs
def has_waiting_jobs
- waiting_cnt = 0
for job in @jobs + @internal_jobs + @reverse_build_jobs
if job.status == "WAITING" then
return true
- end
+ end
end
return false
attr_accessor :id, :status, :pkginfo, :pkgsvr_client, :thread, :log, :rev_fail_list, :rev_success_list, :source_path
# initialize
- def initialize (local_path, os, pkgserver_url, options, server, parent, outstream, resolve )
+ def initialize (local_path, os, pkgsvr_url, options, server, parent, outstream, resolve )
super(server.jobmgr.get_new_job_id(), server)
@rev_fail_list = []
@rev_success_list = []
if ( @server.send_mail.eql? "YES" ) and ( not @pkginfo.nil? ) and ( not @pkginfo.packages.nil? ) then
mail_list = []
contents = []
- done_pkg_list = []
contents.push " "
contents.push "%-30s| %10s | %10s" % ["package name", "version", "os"]
contents.push "---------------------------------------------------------------"
# get package path list
binpkg_path_list = Dir.glob("#{@source_path}/*_*_*.zip")
- srcpkg_path_list = Dir.glob("#{@source_path}/*.tar.gz")
# upload
u_client = Client.new( @server.pkgserver_url, nil, @log )
result = MultiBuildJob.new( @server )
# create sub jobs
- build_jobs = []
for prj in @projects
if prj.type != "GIT" then next end