diff options
author | Simon Glass <sjg@chromium.org> | 2021-04-11 16:27:26 +1200 |
---|---|---|
committer | Simon Glass <sjg@chromium.org> | 2021-04-29 03:23:39 -0700 |
commit | ab9b4f35e38bf9725a13d2e487d1d5962ab412bb (patch) | |
tree | 27675d4d1b170fa327f8b9e379eed01587fdaef6 | |
parent | 249933136f860eb35f8729f4774b7058744bf31f (diff) | |
download | u-boot-ab9b4f35e38bf9725a13d2e487d1d5962ab412bb.zip u-boot-ab9b4f35e38bf9725a13d2e487d1d5962ab412bb.tar.gz u-boot-ab9b4f35e38bf9725a13d2e487d1d5962ab412bb.tar.bz2 |
buildman: Use common code to send an result
At present the code to report a build result is duplicated. Put it in a
common function to avoid this.
Signed-off-by: Simon Glass <sjg@chromium.org>
-rw-r--r-- | tools/buildman/builderthread.py | 21 |
1 files changed, 13 insertions, 8 deletions
diff --git a/tools/buildman/builderthread.py b/tools/buildman/builderthread.py index 6f08ff2..76ffbb6 100644 --- a/tools/buildman/builderthread.py +++ b/tools/buildman/builderthread.py @@ -444,6 +444,17 @@ class BuilderThread(threading.Thread): target = '%s-%s%s' % (base, dirname, ext) shutil.copy(fname, os.path.join(build_dir, target)) + def _SendResult(self, result): + """Send a result to the builder for processing + + Args: + result: CommandResult object containing the results of the build + """ + if self.thread_num != -1: + self.builder.out_queue.put(result) + else: + self.builder.ProcessResult(result) + def RunJob(self, job): """Run a single job @@ -517,10 +528,7 @@ class BuilderThread(threading.Thread): # We have the build results, so output the result self._WriteResult(result, job.keep_outputs, job.work_in_output) - if self.thread_num != -1: - self.builder.out_queue.put(result) - else: - self.builder.ProcessResult(result) + self._SendResult(result) else: # Just build the currently checked-out build result, request_config = self.RunCommit(None, brd, work_dir, True, @@ -529,10 +537,7 @@ class BuilderThread(threading.Thread): work_in_output=job.work_in_output) result.commit_upto = 0 self._WriteResult(result, job.keep_outputs, job.work_in_output) - if self.thread_num != -1: - self.builder.out_queue.put(result) - else: - self.builder.ProcessResult(result) + self._SendResult(result) def run(self): """Our thread's run function |