Fcalva/cyclone
1
0
Fork 0
mirror of https://github.com/justinethier/cyclone.git synced 2025-07-12 07:17:37 +02:00
Code Issues Projects Releases Packages Wiki Activity Actions

Fix resize function

Browse source
This commit is contained in:
Justin Ethier 2019-06-25 18:20:48 -04:00
parent af2008cbcf
commit 364d2594b8
1 changed files with 15 additions and 10 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

25
libs/cyclone/shared-queue.sld
View file

@ -91,16 +91,21 @@
)
(define (%queue-resize! q)
(write "TODO: resize the queue")(newline)
; ;; TODO: assumes we already have the lock
; ;; TODO: error if size is larger than fixnum??
; (let ((old-store (q:store q))
; (new-store (make-vector (* (vector-length old-store) 2) #f)))
; (q:set-size! q 0)
; (let loop ((i (vector-length old-store)))
; (when (not (zero? i))
; (%queue-add! q (vector-ref
; (loop (- i 1)))))
;; (write "TODO: resize the queue")(newline)
;; TODO: assumes we already have the lock
;; TODO: error if size is larger than fixnum??
(let* ((old-start (q:start q))
(old-end (q:end q))
(old-store (q:store q))
(new-store (make-vector (* (vector-length old-store) 2) #f)))
(q:set-start! q 0)
(q:set-end! q 0)
(q:set-store! q new-store)
(let loop ((i 0)
(start old-start))
(when (not (= i (vector-length old-store)))
(%queue-add! q (vector-ref old-store start))
(loop (+ i 1) (inc start (vector-length old-store))))))
)
;- queue-remove! - remove item (when to block? would be nice if we can block until an item becomes available)