code.consxy.com Git - candle/blob - src/main/processor.lisp

   1 (in-package #:candle)
   2
   3 (defvar *mutex* (sb-thread:make-mutex))
   4 (defvar *waitq* (sb-thread:make-waitqueue))
   5
   6 (defvar *job-system*)
   7 (defgeneric process-job-in-system (job-system job))
   8
   9 (defun start-processor-thread ()
  10  (sb-thread:make-thread
  11   (lambda ()
  12    (loop
  13     (let
  14      ((job (find :queued *all-job* :key #'job-status)))
  15      (if job
  16       (process-job job)
  17       ; We just wait here until the processor is released, which is usually done
  18       ; when a project is refreshed.
  19       (sb-thread:with-mutex (*mutex*)
  20        (sb-thread:condition-wait *waitq* *mutex*))))))
  21   :name "Processor"))
  22
  23 (defun awaken-processor-thread ()
  24  (sb-thread:with-mutex (*mutex*)
  25   (sb-thread:condition-broadcast *waitq*)))
  26
  27 (defun process-job (job)
  28  (set-job-status job :in-progress)
  29  (git (job-project job) "checkout" (job-sha job))
  30  (if (not (probe-file (format nil "~A.candle" (project-dir (job-project job)))))
  31   (set-job-status job :no-candle-file)
  32   (multiple-value-bind (result log) (process-job-in-system *job-system* job)
  33    (set-job-status job (if result :succeeded :failed))
  34    (set-job-log job log))))