;;; GNU Guix --- Functional package management for GNU
;;; Copyright © 2017 Ludovic Courtès <ludo@gnu.org>
;;;
;;; This file is part of GNU Guix.
;;;
;;; GNU Guix is free software; you can redistribute it and/or modify it
;;; under the terms of the GNU General Public License as published by
;;; the Free Software Foundation; either version 3 of the License, or (at
;;; your option) any later version.
;;;
;;; GNU Guix is distributed in the hope that it will be useful, but
;;; WITHOUT ANY WARRANTY; without even the implied warranty of
;;; MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
;;; GNU General Public License for more details.
;;;
;;; You should have received a copy of the GNU General Public License
;;; along with GNU Guix.  If not, see <http://www.gnu.org/licenses/>.

(define-module (test-workers)
  #:use-module (guix workers)
  #:use-module (ice-9 threads)
  #:use-module (srfi srfi-64))

(test-begin "workers")

(test-equal "enqueue"
  4242
  (let* ((pool   (make-pool))
         (result 0)
         (1+!    (let ((lock (make-mutex)))
                   (lambda ()
                     (with-mutex lock
                       (set! result (+ result 1)))))))
    (let loop ((i 4242))
      (unless (zero? i)
        (pool-enqueue! pool 1+!)
        (loop (- i 1))))
    (let poll ()
      (unless (pool-idle? pool)
        (pk 'busy result)
        (sleep 1)
        (poll)))
    result))

;; Same as above, but throw exceptions within the workers and make sure they
;; remain alive.
(test-equal "exceptions"
  4242
  (let* ((pool   (make-pool 10))
         (result 0)
         (1+!    (let ((lock (make-mutex)))
                   (lambda ()
                     (with-mutex lock
                       (set! result (+ result 1)))))))
    (let loop ((i 10))
      (unless (zero? i)
        (pool-enqueue! pool (lambda ()
                              (throw 'whatever)))
        (loop (- i 1))))
    (let loop ((i 4242))
      (unless (zero? i)
        (pool-enqueue! pool 1+!)
        (loop (- i 1))))
    (let poll ()
      (unless (pool-idle? pool)
        (pk 'busy result)
        (sleep 1)
        (poll)))
    result))

(test-end)
ass='list nowrap'><tr class='nohover'><th class='left'>Age</th><th class='left'>Commit message (<a href='/guix/log/AUTHORS?id=b79e1fbe962c0ba9134ffb7d1250170aaeafdecf&amp;showmsg=1'>Expand</a>)</th><th class='left'>Author</th></tr>
.guix-authorizations?id=8643bb4a82ae4c906e79e3a1e7f60124b3b0d7c3&amp;showmsg=1'>Expand</a>)</th><th class='left'>Author</th></tr>
<tr><td><span title='2024-04-20 13:05:23 -0400'>2024-04-20</span></td><td><a href='/guix/commit/.guix-authorizations?id=43a4215cad8c6da357f895569c0cedf5e854cee0'>Authorize the PGP key of Zheng Junjie (z572).</a><span class='msg-avail'>...</span></td><td>Maxim Cournoyer</td></tr>
<tr><td><span title='2024-04-09 16:17:23 -0400'>2024-04-09</span></td><td><a href='/guix/commit/.guix-authorizations?id=0945e9f17a3fa77cf42665d7487a555adf76b4e8'>.guix-authorizations: Remove Björn Höfling due to inactivity.</a><span class='msg-avail'>...</span></td><td>Leo Famulari</td></tr>
<tr><td><span title='2024-04-09 16:10:48 -0400'>2024-04-09</span></td><td><a href='/guix/commit/.guix-authorizations?id=d6a6af892a3c212a088dc518547829994f945625'>.guix-authorizations: Remove Raghav Gururajan due to inactivity.</a><span class='msg-avail'>...</span></td><td>Leo Famulari</td></tr>
<tr><td><span title='2024-01-09 23:08:17 -0500'>2024-01-09</span></td><td><a href='/guix/commit/.guix-authorizations?id=e541f9593f8bfc84b6140c2408b393243289fae6'>Authorize Oleg (Sharlatan)'s key.</a><span class='msg-avail'>...</span></td><td>Maxim Cournoyer</td></tr>
<tr><td><span title='2023-07-23 22:26:01 -0400'>2023-07-23</span></td><td><a href='/guix/commit/.guix-authorizations?id=4c4222f32a2906b7bcab74fab70ff2c2f152e8eb'>.guix-authorizations: Update lfam's key.</a><span class='msg-avail'>...</span></td><td>Leo Famulari</td></tr>
<tr><td><span title='2023-08-13 02:00:00 +0200'>2023-08-13</span></td><td><a href='/guix/commit/.guix-authorizations?id=85dbe6d13f20b884f343032e5d1829cc0ef9000d'>.guix-authorizations: Authorise Hilton Chain.</a><span class='msg-avail'>...</span></td><td>Tobias Geerinckx-Rice</td></tr>
<tr><td><span title='2023-06-14 07:33:18 +0200'>2023-06-14</span></td><td><a href='/guix/commit/.guix-authorizations?id=384381f0f900af17c9ec703ebe35b8b3445750f3'>.guix-authorizations: Remove Lars-Dominik Braun’s professional key.</a><span class='msg-avail'>...</span></td><td>Lars-Dominik Braun</td></tr>
<tr><td><span title='2023-05-15 21:29:46 -0400'>2023-05-15</span></td><td><a href='/guix/commit/.guix-authorizations?id=35cf72651742ffbbf9e55e3b02db916e1574186d'>.guix-authorizations: Authorize Jorge Gomez.</a><span class='msg-avail'>...</span></td><td>Maxim Cournoyer</td></tr>
<tr><td><span title='2023-05-11 11:18:48 -0400'>2023-05-11</span></td><td><a href='/guix/commit/.guix-authorizations?id=f43c0290416a25183304c2a6e3ff27babef2c03a'>.guix-authorizations: Authorize Josselin Poiret.</a><span class='msg-avail'>...</span></td><td>Maxim Cournoyer</td></tr>
<tr><td><span title='2023-05-11 10:35:16 -0400'>2023-05-11</span></td><td><a href='/guix/commit/.guix-authorizations?id=ef0aa7ff8b54041ae6718c0d77c1de69a3175231'>.guix-authorizations: Authorize Simon Tournier.</a><span class='msg-avail'>...</span></td><td>Maxim Cournoyer</td></tr>
<tr><td><span title='2023-03-24 12:15:38 -0400'>2023-03-24</span></td><td><a href='/guix/commit/.guix-authorizations?id=33bb60fe0208e1c6167619e1971222d86c48b8dd'>.guix-authorizations: Remove Paul Garlick due to inactivity.</a><span class='msg-avail'>...</span></td><td>Leo Famulari</td></tr>
<tr><td><span title='2023-03-24 12:15:38 -0400'>2023-03-24</span></td><td><a href='/guix/commit/.guix-authorizations?id=703ee77115aa35f6e4736d5cc5726ab839e76899'>.guix-authorizations: Remove Jakub Kądziołka due to inactivity.</a><span class='msg-avail'>...</span></td><td>Leo Famulari</td></tr>
<tr><td><span title='2023-03-24 12:15:38 -0400'>2023-03-24</span></td><td><a href='/guix/commit/.guix-authorizations?id=169e60801db4360b9ea0f7d8faef21b29f8961f4'>.guix-authorizations: Remove Chris Marusich due to inactivity.</a><span class='msg-avail'>...</span></td><td>Leo Famulari</td></tr>
<tr><td><span title='2023-03-24 12:15:38 -0400'>2023-03-24</span></td><td><a href='/guix/commit/.guix-authorizations?id=d873903edc5f840cf8866b6c3d3d1f50779643bb'>.guix-authorizations: Remove Brice Waegeneire due to inactivity.</a><span class='msg-avail'>...</span></td><td>Leo Famulari</td></tr>
<tr><td><span title='2023-03-24 12:15:38 -0400'>2023-03-24</span></td><td><a href='/guix/commit/.guix-authorizations?id=5d70500acbef52958d3959d7e36c2ca8288552f2'>.guix-authorizations: Remove Alex Kost due to inactivity.</a><span class='msg-avail'>...</span></td><td>Leo Famulari</td></tr>