From 8db501749d47964b436bc63cafb80a17bfd42396 Mon Sep 17 00:00:00 2001 From: Piotr Szarmanski Date: Sun, 25 Sep 2022 19:54:42 +0200 Subject: Add parallel decoder. --- tests/parallel-tests.lisp | 38 ++++++++++++++++++++++++++++++++++++++ 1 file changed, 38 insertions(+) create mode 100644 tests/parallel-tests.lisp (limited to 'tests/parallel-tests.lisp') diff --git a/tests/parallel-tests.lisp b/tests/parallel-tests.lisp new file mode 100644 index 0000000..c139b31 --- /dev/null +++ b/tests/parallel-tests.lisp @@ -0,0 +1,38 @@ +;; This file is part of eris-cl. +;; Copyright (C) 2022 Piotr Szarmański + +;; eris-cl is free software: you can redistribute it and/or modify it under the +;; terms of the GNU Lesser General Public License as published by the Free +;; Software Foundation, either version 3 of the License, or (at your option) any +;; later versqion. + +;; eris-cl 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 +;; eris-cl. If not, see . + +(in-package :eris/test) + +(def-suite* parallel-tests :in eris-tests) + +(defmacro assert-parallel-decode (array block-size) + `(uiop:with-temporary-file (:stream output-file :pathname pathname :direction :io) + (let* ((*table* (make-hash-table :test #'equalp)) + (array ,array) + (read-capability (eris-encode array ,block-size #'hashtable-encode))) + (eris-decode-parallel read-capability #'hashtable-decode pathname + :initial-bindings (acons '*table* *table* bordeaux-threads:*default-special-bindings*) + :threads 4) + (is (equalp array + (alexandria:read-stream-content-into-byte-vector output-file)))))) + +(test simple-parallel-decode + (assert-parallel-decode (make-octets 4096 :element 101) 1024) + (assert-parallel-decode (make-octets 4095 :element 102) 1024) + (assert-parallel-decode (make-octets 18000 :element 103) 1024) + (assert-parallel-decode (make-octets 128000 :element 104) 32768) + (assert-parallel-decode (make-octets 131071 :element 104) 32768) + (assert-parallel-decode (make-octets 131072 :element 104) 32768) + (assert-parallel-decode (make-octets 131073 :element 104) 32768)) -- cgit v1.2.3