protected
def job_main()
@log.info( "Invoking a thread for building Job #{@id}", Log::LV_USER)
- if @status == "ERROR" then return end
@log.info( "New Job #{@id} is started", Log::LV_USER)
# checking build dependency
- if not @is_remote_job and not @is_verified and
- not check_build_dependency() then
- @status = "ERROR"
- return false
+ if not @is_remote_job and not @is_verified then
+ check_build_dependency()
end
# clean build
- if not build() then
- if @is_verified then copy_result_files_to_master() end
-
- @status = "ERROR"
- return false
- end
+ build()
lock_event
- # upload
- if not @is_rev_build_check_job and not @send_result_back and
- @parent.nil? and not upload() then
+ if not @parent.nil? and not @is_rev_build_check_job then
+ copy_result_files(@parent.source_path)
+ end
- @status = "ERROR"
- return false
+ # upload
+ if not @is_rev_build_check_job and not @send_result_back and @parent.nil? then
+ upload()
end
# copy result files to transport path
- if @send_result_back then
+ if @send_result_back and not @is_rev_build_check_job then
copy_result_files_to_master()
- elsif not @parent.nil? and not @is_rev_build_check_job then
- copy_result_files(@parent.source_path)
end
# INFO. don't change this string
@log.info( "Job is completed!", Log::LV_USER)
@status = "FINISHED"
- return true
end
# unmet dependencies found , report the errors
if not unmet_bdeps.empty? or not unmet_ideps.empty? then
- @log.error( "Unmet dependency found!", Log::LV_USER)
+ unmet_pkgs = []
unmet_bdeps.each do |d|
os = (d.target_os_list.empty?) ? @os : d.target_os_list[0]
- @log.error( " * #{d.package_name}(#{os}) for build-dependency", Log::LV_USER)
+ unmet_pkgs.push "#{d.package_name}(#{os})"
end
unmet_ideps.each do |d|
os = (d.target_os_list.empty?) ? @os : d.target_os_list[0]
- @log.error( " * #{d.package_name}(#{os}) for install-dependency", Log::LV_USER)
+ unmet_pkgs.push "#{d.package_name}(#{os})"
end
-
- return false
- else
- return true
+ unmet_pkgs.uniq!
+ raise BuildServerException.new("ERR200"), unmet_pkgs.join(",")
end
end
else
builder = Builder.create( "JB#{@id}", @pkgsvr_url, nil,
"#{@buildroot_dir}", @server.build_cache_dir )
- if builder.nil?
- @log.error( "Creating job builder failed", Log::LV_USER)
- return false
+ if builder.nil? then
+ raise BuildServerException.new("ERR201")
end
@log.info( "JobBuilder##{@id} is created", Log::LV_USER)
@log.info( " - Package Server : #{@pkgsvr_url}" )
result = builder.build_job(self, use_clean, local_pkgs, false )
end
if not result then
- @log.error( "Building job failed", Log::LV_USER)
- write_log_url()
- return false
+ raise BuildServerException.new("ERR202")
end
end
# check reverse dependecy if not sub jobs
+ if not @no_reverse and not @is_rev_build_check_job and not @is_verified and
+ not ReverseBuildChecker.check( self, true ).empty? then
- if not @no_reverse then
- if not @is_rev_build_check_job and not @is_verified and
- not ReverseBuildChecker.check( self, true ).empty? then
- @log.error( "Reverse-build-check failed!" )
- return false
- end
+ raise BuildServerException.new("ERR203")
end
-
- return true
end
snapshot = u_client.upload( @pkgsvr_ip, @pkgsvr_port, binpkg_path_list, @server.ftp_addr, @server.ftp_port, @server.ftp_username, @server.ftp_passwd, @pkgsvr_password)
if snapshot.nil? then
- @log.info( "Upload failed...", Log::LV_USER)
- return false
+ raise BuildServerException.new("ERR204")
end
# update local
ensure
add_timestamp("UPLOAD_END")
end
-
- return true
end
@log.info( " * #{file}", Log::LV_USER)
FileUtils.ln(file,"#{dst_path}/", :force => true)
end
-
- return true
end
FileUtils.mkdir_p outgoing_dir
end
- # copy result files, if not reverse build
- if not @is_rev_build_check_job then
- return copy_result_files( outgoing_dir )
- else
- return true
- end
+ # copy result files
+ copy_result_files( outgoing_dir )
end
end
- # write web url for log
- protected
- def write_log_url()
- url = get_log_url()
- if not url.empty? then
- @log.info( " ** Log1: #{url}", Log::LV_USER)
- end
- end
-
-
# get target os of dependency
protected
def get_os_of_dependency(dep)
"ERR109" => "Extracting package file failed!",
"ERR110" => "Initializing sub jobs failed!",
+ "ERR200" => "Unmet dependency found!",
+ "ERR201" => "Creating job builder failed!",
+ "ERR202" => "Building job failed!",
+ "ERR203" => "Reverse-build-check failed!",
+ "ERR204" => "Uploading package file(s) failed!",
+ "ERR205" => "Job stopped by failure of its sub job!",
+
"ERR900" => "Cancel event received!",
"ERR901" => "Job already upload status. Cancel failed!"
}
@thread = Thread.new do
begin
job_main()
-
- # parent job will call sub job's terminate method
- if not is_sub_job? then terminate() end
rescue BuildServerException => e
- @log.error e.message
+ @log.error( e.err_message, Log::LV_USER )
# "CANCEL" operation(ERR900) must be excluded
if @status == "WORKING" and e.err_code != "ERR900" then @status = "ERROR" end
rescue => e
@log.error e.message
@log.error e.backtrace.inspect
- if @status == "WORKING" then @status = "ERROR" end
+ @status = "ERROR"
ensure
+ # parent job will call sub job's terminate method
+ # if "WORKING"(canceled) and "ERROR", must call "terminate" here
+ if not is_sub_job? and (@status == "ERROR" or @status == "FINISHED") then
+ terminate()
+ end
@thread = nil
end
end
rescue => e
@server.log.error e.message
@server.log.error e.backtrace.inspect
+ job.status = "ERROR"
ensure
job.thread = nil
end
# start build
set_remote(job, rserver)
+
+ # status change & job control
+ job.status = "REMOTE_WORKING"
+ save_job_status(job)
+ job.add_timestamp("WORK_START")
+
if job.execute() then
- # status change & job control
- job.status = "REMOTE_WORKING"
- save_job_status(job)
- job.add_timestamp("WORK_START")
@server.log.info "Moved the job \"#{job.id}\" to remote job list"
else
@server.log.info "Moving the job \"#{job.id}\" to remote failed"
protected
def job_main()
@log.info( "Invoking a thread for MULTI-BUILD Job #{@id}", Log::LV_USER)
- if @status == "ERROR" then return end
@log.info( "New Job #{@id} is started", Log::LV_USER)
# initialize status map
@server.jobmgr.add_internal_job(job)
@log.info( "Added new job \"#{job.get_project().name}\" for #{job.os}! (#{job.id})",
Log::LV_USER)
- if not @server.job_log_url.empty? then
- @log.info( " * Log URL : #{@server.job_log_url}/#{job.id}/log", Log::LV_USER)
- end
end
end
# check there is some error or cancel
if stop_status == "FINISHED" and
(job_status == "ERROR" or job_status == "CANCELED") then
- # write url
- write_log_url(job)
# cancel all other un-finished jobs
@sub_jobs.each do |sub|
sub_status = sub.status
check_event
end
- if stop_status == "ERROR" or stop_status == "CANCELED" then
- @status = stop_status
- return
+ if stop_status == "ERROR" then
+ raise BuildServerException.new("ERR205")
+ elsif stop_status == "CANCELED" then
+ @event = "CANCEL" if @event == "NONE"
+ raise BuildServerException.new("ERR205")
end
lock_event
# upload
- if not @send_result_back and not upload() then
- @status = "ERROR"
- return
+ if not @send_result_back then
+ upload()
end
# copy result files to transport path
snapshot = u_client.upload( @pkgsvr_ip, @pkgsvr_port, binpkg_path_list, @server.ftp_addr, @server.ftp_port, @server.ftp_username, @server.ftp_passwd, @pkgsvr_password)
if snapshot.nil? then
- @log.info( "Upload failed...", Log::LV_USER)
-
- return false
+ raise BuildServerException.new("ERR204")
end
# update local
@log.info( "Upload succeeded. Sync local pkg-server again...", Log::LV_USER)
@pkgsvr_client.update
@log.info("Snapshot: #{snapshot}", Log::LV_USER)
-
- return true
- end
-
-
- # write web url for log
- private
- def write_log_url(job)
- url = job.get_log_url()
- if not url.empty? then
- @log.info( " ** Log1: #{url}", Log::LV_USER)
- end
end
FileUtils.mkdir_p outgoing_dir
end
- # copy result files, if not reverse build
- return copy_result_files( outgoing_dir )
+ # copy result files
+ copy_result_files( outgoing_dir )
end
@log.info( " * #{file}", Log::LV_USER)
FileUtils.ln(file,"#{dst_path}/", :force => true)
end
-
- return true
end
end
protected
def job_main()
@log.info( "Invoking a thread for REGISTER Job #{@id}", Log::LV_USER)
- if @status == "ERROR" then return end
@log.info( "New Job #{@id} is started", Log::LV_USER)
# clean build
if not ReverseBuildChecker.check( self, true ).empty? then
- @status = "ERROR"
- @log.error( "Reverse-build-check failed!" )
- return
+ raise BuildServerException.new("ERR203")
end
# if this package has compatible OS, check
# reverse check
if not @no_reverse then
if not ReverseBuildChecker.check( self, true, os ) then
- @status = "ERROR"
- @log.error( "Reverse-build-check failed!" )
- return
+ raise BuildServerException.new("ERR203")
end
end
end
lock_event
# upload
- if not upload() then
- @status = "ERROR"
- return
- end
+ upload()
# INFO. don't change this string
@log.info( "Job is completed!", Log::LV_USER)
snapshot = u_client.upload( @pkgsvr_ip, @pkgsvr_port, binpkg_path_list, @server.ftp_addr, @server.ftp_port, @server.ftp_username, @server.ftp_passwd, @pkgsvr_password)
if snapshot.nil? then
- @log.info( "Upload failed...", Log::LV_USER)
-
- return false
+ raise BuildServerException.new("ERR204")
end
# update local
@log.info( "Upload succeeded. Sync local pkg-server again...", Log::LV_USER)
@pkgsvr_client.update
@log.info("Snapshot: #{snapshot}", Log::LV_USER)
-
- return true
end
if not is_project_included?(failure_list, rev_prj, rev_os) then
log.info( " * Reverse-build FAIL ... #{rev_prj.name}(#{rev_os}) (#{rev_job.id})", Log::LV_USER)
failure_list.push [ rev_prj, rev_os ]
- write_log_url(log, rev_job)
end
# if "exist on error" cancel all other jobs
return false
end
-
-
- # write web url for log
- private
- def self.write_log_url(log, job)
- url = job.get_log_url()
- if not url.empty? then
- log.info( " ** Log1: #{url}", Log::LV_USER)
- end
- end
end
Info: New Job
Info: Checking build dependency ...
Info: Checking install dependency ...
-Error: Unmet dependency found!
-Error: * a(ubuntu-32) for build-dependency
+Error: Error: Unmet dependency found!: a(ubuntu-32)
Error: Job is stopped by ERROR
+Error: Building job on remote server failed!
Info: Zipping...
Info: Creating package file ... a_0.0.2_ubuntu-32.zip
Info: Checking reverse build dependency ...
-Info: * Will check reverse-build for projects: testb(ubuntu-32)
-Info: * Added new job for reverse-build ... testb(ubuntu-32)
-Info: * Reverse-build FAIL ... testb(ubuntu-32)
+Info: * Will check reverse-build for projects:
+Info: * Added new job for reverse-build ... testb
+Info: * Reverse-build FAIL ... testb
+Error: Error: Reverse-build-check failed!
Error: Job is stopped by ERROR
+Error: Building job on remote server failed!
build-svr create -n <server name> [-t <ftp server url>]
build-svr remove -n <server name>
build-svr migrate -n <server name> [--dsn <db dsn> [--dbuser <db_user> --dbpassword <db_password>] ]
-build-svr start -n <server name> -p <port>
+build-svr start -n <server name> [-p <port>]
build-svr stop -n <server name>
build-svr upgrade -n <server name>
build-svr add-svr -n <server name> -d <friend server address>
projects / sdk / tools / sdk-build.git / commitdiff